| OLD | NEW |
| 1 // Copyright 2012 the V8 project authors. All rights reserved. | 1 // Copyright 2012 the V8 project authors. All rights reserved. |
| 2 // Redistribution and use in source and binary forms, with or without | 2 // Redistribution and use in source and binary forms, with or without |
| 3 // modification, are permitted provided that the following conditions are | 3 // modification, are permitted provided that the following conditions are |
| 4 // met: | 4 // met: |
| 5 // | 5 // |
| 6 // * Redistributions of source code must retain the above copyright | 6 // * Redistributions of source code must retain the above copyright |
| 7 // notice, this list of conditions and the following disclaimer. | 7 // notice, this list of conditions and the following disclaimer. |
| 8 // * Redistributions in binary form must reproduce the above | 8 // * Redistributions in binary form must reproduce the above |
| 9 // copyright notice, this list of conditions and the following | 9 // copyright notice, this list of conditions and the following |
| 10 // disclaimer in the documentation and/or other materials provided | 10 // disclaimer in the documentation and/or other materials provided |
| (...skipping 30 matching lines...) Expand all Loading... |
| 41 #ifdef DEBUG | 41 #ifdef DEBUG |
| 42 { ScopedLock lock(thread_id_mutex_); | 42 { ScopedLock lock(thread_id_mutex_); |
| 43 thread_id_ = ThreadId::Current().ToInteger(); | 43 thread_id_ = ThreadId::Current().ToInteger(); |
| 44 } | 44 } |
| 45 #endif | 45 #endif |
| 46 Isolate::SetIsolateThreadLocals(isolate_, NULL); | 46 Isolate::SetIsolateThreadLocals(isolate_, NULL); |
| 47 DisallowHeapAllocation no_allocation; | 47 DisallowHeapAllocation no_allocation; |
| 48 DisallowHandleAllocation no_handles; | 48 DisallowHandleAllocation no_handles; |
| 49 DisallowHandleDereference no_deref; | 49 DisallowHandleDereference no_deref; |
| 50 | 50 |
| 51 int64_t epoch = 0; | 51 ElapsedTimer total_timer; |
| 52 if (FLAG_trace_concurrent_recompilation) epoch = OS::Ticks(); | 52 if (FLAG_trace_concurrent_recompilation) total_timer.Start(); |
| 53 | 53 |
| 54 while (true) { | 54 while (true) { |
| 55 input_queue_semaphore_->Wait(); | 55 input_queue_semaphore_->Wait(); |
| 56 Logger::TimerEventScope timer( | 56 Logger::TimerEventScope timer( |
| 57 isolate_, Logger::TimerEventScope::v8_recompile_concurrent); | 57 isolate_, Logger::TimerEventScope::v8_recompile_concurrent); |
| 58 | 58 |
| 59 if (FLAG_concurrent_recompilation_delay != 0) { | 59 if (FLAG_concurrent_recompilation_delay != 0) { |
| 60 OS::Sleep(FLAG_concurrent_recompilation_delay); | 60 OS::Sleep(FLAG_concurrent_recompilation_delay); |
| 61 } | 61 } |
| 62 | 62 |
| 63 switch (static_cast<StopFlag>(Acquire_Load(&stop_thread_))) { | 63 switch (static_cast<StopFlag>(Acquire_Load(&stop_thread_))) { |
| 64 case CONTINUE: | 64 case CONTINUE: |
| 65 break; | 65 break; |
| 66 case STOP: | 66 case STOP: |
| 67 if (FLAG_trace_concurrent_recompilation) { | 67 if (FLAG_trace_concurrent_recompilation) { |
| 68 time_spent_total_ = OS::Ticks() - epoch; | 68 time_spent_total_ = total_timer.Elapsed(); |
| 69 } | 69 } |
| 70 stop_semaphore_->Signal(); | 70 stop_semaphore_->Signal(); |
| 71 return; | 71 return; |
| 72 case FLUSH: | 72 case FLUSH: |
| 73 // The main thread is blocked, waiting for the stop semaphore. | 73 // The main thread is blocked, waiting for the stop semaphore. |
| 74 { AllowHandleDereference allow_handle_dereference; | 74 { AllowHandleDereference allow_handle_dereference; |
| 75 FlushInputQueue(true); | 75 FlushInputQueue(true); |
| 76 } | 76 } |
| 77 Release_Store(&queue_length_, static_cast<AtomicWord>(0)); | 77 Release_Store(&queue_length_, static_cast<AtomicWord>(0)); |
| 78 Release_Store(&stop_thread_, static_cast<AtomicWord>(CONTINUE)); | 78 Release_Store(&stop_thread_, static_cast<AtomicWord>(CONTINUE)); |
| 79 stop_semaphore_->Signal(); | 79 stop_semaphore_->Signal(); |
| 80 // Return to start of consumer loop. | 80 // Return to start of consumer loop. |
| 81 continue; | 81 continue; |
| 82 } | 82 } |
| 83 | 83 |
| 84 int64_t compiling_start = 0; | 84 ElapsedTimer compiling_timer; |
| 85 if (FLAG_trace_concurrent_recompilation) compiling_start = OS::Ticks(); | 85 if (FLAG_trace_concurrent_recompilation) compiling_timer.Start(); |
| 86 | 86 |
| 87 CompileNext(); | 87 CompileNext(); |
| 88 | 88 |
| 89 if (FLAG_trace_concurrent_recompilation) { | 89 if (FLAG_trace_concurrent_recompilation) { |
| 90 time_spent_compiling_ += OS::Ticks() - compiling_start; | 90 time_spent_compiling_ += compiling_timer.Elapsed(); |
| 91 } | 91 } |
| 92 } | 92 } |
| 93 } | 93 } |
| 94 | 94 |
| 95 | 95 |
| 96 void OptimizingCompilerThread::CompileNext() { | 96 void OptimizingCompilerThread::CompileNext() { |
| 97 OptimizingCompiler* optimizing_compiler = NULL; | 97 OptimizingCompiler* optimizing_compiler = NULL; |
| 98 bool result = input_queue_.Dequeue(&optimizing_compiler); | 98 bool result = input_queue_.Dequeue(&optimizing_compiler); |
| 99 USE(result); | 99 USE(result); |
| 100 ASSERT(result); | 100 ASSERT(result); |
| (...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 168 // happens in CompileNext on the same thread. | 168 // happens in CompileNext on the same thread. |
| 169 // This is used only for testing. | 169 // This is used only for testing. |
| 170 while (NoBarrier_Load(&queue_length_) > 0) CompileNext(); | 170 while (NoBarrier_Load(&queue_length_) > 0) CompileNext(); |
| 171 InstallOptimizedFunctions(); | 171 InstallOptimizedFunctions(); |
| 172 } else { | 172 } else { |
| 173 FlushInputQueue(false); | 173 FlushInputQueue(false); |
| 174 FlushOutputQueue(false); | 174 FlushOutputQueue(false); |
| 175 } | 175 } |
| 176 | 176 |
| 177 if (FLAG_trace_concurrent_recompilation) { | 177 if (FLAG_trace_concurrent_recompilation) { |
| 178 double compile_time = static_cast<double>(time_spent_compiling_); | 178 double percentage = time_spent_compiling_.PercentOf(time_spent_total_); |
| 179 double total_time = static_cast<double>(time_spent_total_); | |
| 180 double percentage = (compile_time * 100) / total_time; | |
| 181 PrintF(" ** Compiler thread did %.2f%% useful work\n", percentage); | 179 PrintF(" ** Compiler thread did %.2f%% useful work\n", percentage); |
| 182 } | 180 } |
| 183 | 181 |
| 184 Join(); | 182 Join(); |
| 185 } | 183 } |
| 186 | 184 |
| 187 | 185 |
| 188 void OptimizingCompilerThread::InstallOptimizedFunctions() { | 186 void OptimizingCompilerThread::InstallOptimizedFunctions() { |
| 189 ASSERT(!IsOptimizerThread()); | 187 ASSERT(!IsOptimizerThread()); |
| 190 HandleScope handle_scope(isolate_); | 188 HandleScope handle_scope(isolate_); |
| (...skipping 22 matching lines...) Expand all Loading... |
| 213 #ifdef DEBUG | 211 #ifdef DEBUG |
| 214 bool OptimizingCompilerThread::IsOptimizerThread() { | 212 bool OptimizingCompilerThread::IsOptimizerThread() { |
| 215 if (!FLAG_concurrent_recompilation) return false; | 213 if (!FLAG_concurrent_recompilation) return false; |
| 216 ScopedLock lock(thread_id_mutex_); | 214 ScopedLock lock(thread_id_mutex_); |
| 217 return ThreadId::Current().ToInteger() == thread_id_; | 215 return ThreadId::Current().ToInteger() == thread_id_; |
| 218 } | 216 } |
| 219 #endif | 217 #endif |
| 220 | 218 |
| 221 | 219 |
| 222 } } // namespace v8::internal | 220 } } // namespace v8::internal |
| OLD | NEW |