Index: src/optimizing-compiler-thread.cc |
diff --git a/src/optimizing-compiler-thread.cc b/src/optimizing-compiler-thread.cc |
index 1f77d5ae05438ecbea55d04c6e6bf9a1e06e5fa4..96847dcc84d76ad75949a136c4125dcf0e8bc7da 100644 |
--- a/src/optimizing-compiler-thread.cc |
+++ b/src/optimizing-compiler-thread.cc |
@@ -52,7 +52,7 @@ void OptimizingCompilerThread::Run() { |
if (FLAG_trace_concurrent_recompilation) total_timer.Start(); |
while (true) { |
- input_queue_semaphore_->Wait(); |
+ input_queue_semaphore_.Wait(); |
Logger::TimerEventScope timer( |
isolate_, Logger::TimerEventScope::v8_recompile_concurrent); |
@@ -67,7 +67,7 @@ void OptimizingCompilerThread::Run() { |
if (FLAG_trace_concurrent_recompilation) { |
time_spent_total_ = total_timer.Elapsed(); |
} |
- stop_semaphore_->Signal(); |
+ stop_semaphore_.Signal(); |
return; |
case FLUSH: |
// The main thread is blocked, waiting for the stop semaphore. |
@@ -76,7 +76,7 @@ void OptimizingCompilerThread::Run() { |
} |
Release_Store(&queue_length_, static_cast<AtomicWord>(0)); |
Release_Store(&stop_thread_, static_cast<AtomicWord>(CONTINUE)); |
- stop_semaphore_->Signal(); |
+ stop_semaphore_.Signal(); |
// Return to start of consumer loop. |
continue; |
} |
@@ -123,7 +123,7 @@ void OptimizingCompilerThread::FlushInputQueue(bool restore_function_code) { |
while (input_queue_.Dequeue(&optimizing_compiler)) { |
// This should not block, since we have one signal on the input queue |
// semaphore corresponding to each element in the input queue. |
- input_queue_semaphore_->Wait(); |
+ input_queue_semaphore_.Wait(); |
CompilationInfo* info = optimizing_compiler->info(); |
if (restore_function_code) { |
Handle<JSFunction> function = info->closure(); |
@@ -151,8 +151,8 @@ void OptimizingCompilerThread::FlushOutputQueue(bool restore_function_code) { |
void OptimizingCompilerThread::Flush() { |
ASSERT(!IsOptimizerThread()); |
Release_Store(&stop_thread_, static_cast<AtomicWord>(FLUSH)); |
- input_queue_semaphore_->Signal(); |
- stop_semaphore_->Wait(); |
+ input_queue_semaphore_.Signal(); |
+ stop_semaphore_.Wait(); |
FlushOutputQueue(true); |
} |
@@ -160,8 +160,8 @@ void OptimizingCompilerThread::Flush() { |
void OptimizingCompilerThread::Stop() { |
ASSERT(!IsOptimizerThread()); |
Release_Store(&stop_thread_, static_cast<AtomicWord>(STOP)); |
- input_queue_semaphore_->Signal(); |
- stop_semaphore_->Wait(); |
+ input_queue_semaphore_.Signal(); |
+ stop_semaphore_.Wait(); |
if (FLAG_concurrent_recompilation_delay != 0) { |
// Barrier when loading queue length is not necessary since the write |
@@ -204,7 +204,7 @@ void OptimizingCompilerThread::QueueForOptimization( |
Barrier_AtomicIncrement(&queue_length_, static_cast<Atomic32>(1)); |
optimizing_compiler->info()->closure()->MarkInRecompileQueue(); |
input_queue_.Enqueue(optimizing_compiler); |
- input_queue_semaphore_->Signal(); |
+ input_queue_semaphore_.Signal(); |
} |