LineageOS/android_development
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge "Merge ModuleIR within single thread" am: 79f4b7a0fc am: e0de71ef07

Browse Source 
Original change: https://android-review.googlesource.com/c/platform/development/+/1411807

Change-Id: I3bdbfc4da8fc5ad2da3cf49278fb626570474a05
This commit is contained in:
Treehugger Robot
2020-08-31 06:13:50 +00:00
committed by Automerger Merge Worker
parent 4ab01796c3 e0de71ef07
commit 692d59ac59
1 changed files with 42 additions and 43 deletions
Download Patch File Download Diff File Expand all files Collapse all files

85
vndk/tools/header-checker/src/linker/header_abi_linker.cpp
View File

@@ -29,7 +29,6 @@
#include <functional>
#include <iostream>
#include <memory>
#include <mutex>
#include <string>
#include <thread>
#include <vector>
@@ -191,58 +190,58 @@ class HeaderAbiLinker {
std::unique_ptr<repr::ExportedSymbolSet> version_script_symbols_;
};
static void
DeDuplicateAbiElementsThread(const std::vector<std::string> &dump_files,
const std::set<std::string> *exported_headers,
linker::ModuleMerger *global_merger,
std::mutex *global_merger_lock,
std::atomic<std::size_t> *cnt) {
linker::ModuleMerger local_merger(exported_headers);
auto begin_it = dump_files.begin();
std::size_t num_sources = dump_files.size();
while (1) {
std::size_t i = cnt->fetch_add(sources_per_thread);
if (i >= num_sources) {
break;
}
std::size_t end = std::min(i + sources_per_thread, num_sources);
for (auto it = begin_it + i; it != begin_it + end; it++) {
std::unique_ptr<repr::IRReader> reader =
repr::IRReader::CreateIRReader(input_format, exported_headers);
assert(reader != nullptr);
if (!reader->ReadDump(*it)) {
llvm::errs() << "ReadDump failed\n";
::exit(1);
}
local_merger.MergeGraphs(reader->GetModule());
static void DeDuplicateAbiElementsThread(
std::vector<std::string>::const_iterator dump_files_begin,
std::vector<std::string>::const_iterator dump_files_end,
const std::set<std::string> *exported_headers,
linker::ModuleMerger *merger) {
for (auto it = dump_files_begin; it != dump_files_end; it++) {
std::unique_ptr<repr::IRReader> reader =
repr::IRReader::CreateIRReader(input_format, exported_headers);
assert(reader != nullptr);
if (!reader->ReadDump(*it)) {
llvm::errs() << "ReadDump failed\n";
::exit(1);
}
merger->MergeGraphs(reader->GetModule());
}
std::lock_guard<std::mutex> lock(*global_merger_lock);
global_merger->MergeGraphs(local_merger.GetModule());
}
std::unique_ptr<linker::ModuleMerger> HeaderAbiLinker::ReadInputDumpFiles() {
std::unique_ptr<linker::ModuleMerger> merger(
new linker::ModuleMerger(&exported_headers_));
std::size_t max_threads = std::thread::hardware_concurrency();
std::size_t num_threads =
sources_per_thread < dump_files_.size()
? std::min(dump_files_.size() / sources_per_thread, max_threads)
: 1;
std::size_t num_threads = std::max<std::size_t>(
std::min(dump_files_.size() / sources_per_thread, max_threads), 1);
std::vector<std::thread> threads;
std::atomic<std::size_t> cnt(0);
std::mutex merger_lock;
for (std::size_t i = 1; i < num_threads; i++) {
threads.emplace_back(DeDuplicateAbiElementsThread, dump_files_,
&exported_headers_, merger.get(), &merger_lock, &cnt);
std::vector<linker::ModuleMerger> thread_mergers;
thread_mergers.reserve(num_threads - 1);
std::size_t dump_files_index = 0;
std::size_t first_end_index = 0;
for (std::size_t i = 0; i < num_threads; i++) {
std::size_t cnt = dump_files_.size() / num_threads +
(i < dump_files_.size() % num_threads ? 1 : 0);
if (i == 0) {
first_end_index = cnt;
} else {
thread_mergers.emplace_back(&exported_headers_);
threads.emplace_back(DeDuplicateAbiElementsThread,
dump_files_.begin() + dump_files_index,
dump_files_.begin() + dump_files_index + cnt,
&exported_headers_, &thread_mergers.back());
}
dump_files_index += cnt;
}
DeDuplicateAbiElementsThread(dump_files_, &exported_headers_, merger.get(),
&merger_lock, &cnt);
for (auto &thread : threads) {
thread.join();
assert(dump_files_index == dump_files_.size());
DeDuplicateAbiElementsThread(dump_files_.begin(),
dump_files_.begin() + first_end_index,
&exported_headers_, merger.get());
for (std::size_t i = 0; i < threads.size(); i++) {
threads[i].join();
merger->MergeGraphs(thread_mergers[i].GetModule());
}
return merger;