Commit c5be8d2a authored by ahaas's avatar ahaas Committed by Commit bot

[wasm] Store the semaphore for parallel compilation in exactly one smart pointer.

R=mlippautz@chromium.org

Review-Url: https://codereview.chromium.org/2080223005
Cr-Commit-Position: refs/heads/master@{#37175}
parent bedcc31b
...@@ -530,8 +530,8 @@ uint32_t* StartCompilationTasks( ...@@ -530,8 +530,8 @@ uint32_t* StartCompilationTasks(
Isolate* isolate, Isolate* isolate,
std::vector<compiler::WasmCompilationUnit*>& compilation_units, std::vector<compiler::WasmCompilationUnit*>& compilation_units,
std::queue<compiler::WasmCompilationUnit*>& executed_units, std::queue<compiler::WasmCompilationUnit*>& executed_units,
const base::SmartPointer<base::Semaphore>& pending_tasks, base::Semaphore* pending_tasks, base::Mutex& result_mutex,
base::Mutex& result_mutex, base::AtomicNumber<size_t>& next_unit) { base::AtomicNumber<size_t>& next_unit) {
const size_t num_tasks = const size_t num_tasks =
Min(static_cast<size_t>(FLAG_wasm_num_compilation_tasks), Min(static_cast<size_t>(FLAG_wasm_num_compilation_tasks),
V8::GetCurrentPlatform()->NumberOfAvailableBackgroundThreads()); V8::GetCurrentPlatform()->NumberOfAvailableBackgroundThreads());
...@@ -539,7 +539,7 @@ uint32_t* StartCompilationTasks( ...@@ -539,7 +539,7 @@ uint32_t* StartCompilationTasks(
for (size_t i = 0; i < num_tasks; i++) { for (size_t i = 0; i < num_tasks; i++) {
WasmCompilationTask* task = WasmCompilationTask* task =
new WasmCompilationTask(isolate, &compilation_units, &executed_units, new WasmCompilationTask(isolate, &compilation_units, &executed_units,
pending_tasks.get(), &result_mutex, &next_unit); pending_tasks, &result_mutex, &next_unit);
task_ids[i] = task->id(); task_ids[i] = task->id();
V8::GetCurrentPlatform()->CallOnBackgroundThread( V8::GetCurrentPlatform()->CallOnBackgroundThread(
task, v8::Platform::kShortRunningTask); task, v8::Platform::kShortRunningTask);
...@@ -547,9 +547,8 @@ uint32_t* StartCompilationTasks( ...@@ -547,9 +547,8 @@ uint32_t* StartCompilationTasks(
return task_ids; return task_ids;
} }
void WaitForCompilationTasks( void WaitForCompilationTasks(Isolate* isolate, uint32_t* task_ids,
Isolate* isolate, uint32_t* task_ids, base::Semaphore* pending_tasks) {
const base::SmartPointer<base::Semaphore>& pending_tasks) {
const size_t num_tasks = const size_t num_tasks =
Min(static_cast<size_t>(FLAG_wasm_num_compilation_tasks), Min(static_cast<size_t>(FLAG_wasm_num_compilation_tasks),
V8::GetCurrentPlatform()->NumberOfAvailableBackgroundThreads()); V8::GetCurrentPlatform()->NumberOfAvailableBackgroundThreads());
...@@ -624,7 +623,7 @@ void CompileInParallel(Isolate* isolate, const WasmModule* module, ...@@ -624,7 +623,7 @@ void CompileInParallel(Isolate* isolate, const WasmModule* module,
// the background threads. // the background threads.
base::SmartArrayPointer<uint32_t> task_ids( base::SmartArrayPointer<uint32_t> task_ids(
StartCompilationTasks(isolate, compilation_units, executed_units, StartCompilationTasks(isolate, compilation_units, executed_units,
pending_tasks, result_mutex, next_unit)); pending_tasks.get(), result_mutex, next_unit));
// 3.a) The background threads and the main thread pick one compilation // 3.a) The background threads and the main thread pick one compilation
// unit at a time and execute the parallel phase of the compilation // unit at a time and execute the parallel phase of the compilation
...@@ -641,7 +640,7 @@ void CompileInParallel(Isolate* isolate, const WasmModule* module, ...@@ -641,7 +640,7 @@ void CompileInParallel(Isolate* isolate, const WasmModule* module,
} }
// 4) After the parallel phase of all compilation units has started, the // 4) After the parallel phase of all compilation units has started, the
// main thread waits for all {WasmCompilationTask} instances to finish. // main thread waits for all {WasmCompilationTask} instances to finish.
WaitForCompilationTasks(isolate, task_ids.get(), pending_tasks); WaitForCompilationTasks(isolate, task_ids.get(), pending_tasks.get());
// Finish the compilation of the remaining compilation units. // Finish the compilation of the remaining compilation units.
FinishCompilationUnits(executed_units, functions, result_mutex); FinishCompilationUnits(executed_units, functions, result_mutex);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment