diff options
Diffstat (limited to 'chromium/third_party/blink/renderer/core/inspector/inspector_task_runner.cc')
-rw-r--r-- | chromium/third_party/blink/renderer/core/inspector/inspector_task_runner.cc | 18 |
1 files changed, 8 insertions, 10 deletions
diff --git a/chromium/third_party/blink/renderer/core/inspector/inspector_task_runner.cc b/chromium/third_party/blink/renderer/core/inspector/inspector_task_runner.cc index b76d7d34ccd..aeb1d5074a0 100644 --- a/chromium/third_party/blink/renderer/core/inspector/inspector_task_runner.cc +++ b/chromium/third_party/blink/renderer/core/inspector/inspector_task_runner.cc @@ -85,18 +85,15 @@ bool InspectorTaskRunner::IsRunningTask() { InspectorTaskRunner::Task InspectorTaskRunner::TakeNextTask( InspectorTaskRunner::WaitMode wait_mode) { MutexLocker lock(mutex_); - bool timed_out = false; - static double infinite_time = std::numeric_limits<double>::max(); - double absolute_time = wait_mode == kWaitForTask ? infinite_time : 0.0; - while (!disposed_ && !timed_out && queue_.IsEmpty()) - timed_out = !condition_.TimedWait(mutex_, absolute_time); - DCHECK(!timed_out || absolute_time != infinite_time); + if (wait_mode == kWaitForTask) { + while (!disposed_ && queue_.IsEmpty()) + condition_.Wait(mutex_); + } - if (disposed_ || timed_out) + if (disposed_ || queue_.IsEmpty()) return Task(); - SECURITY_DCHECK(!queue_.IsEmpty()); return queue_.TakeFirst(); } @@ -116,10 +113,11 @@ void InspectorTaskRunner::PerformSingleTask(Task task) { } void InspectorTaskRunner::PerformSingleTaskDontWait() { - DCHECK(isolate_task_runner_->BelongsToCurrentThread()); Task task = TakeNextTask(kDontWaitForTask); - if (task) + if (task) { + DCHECK(isolate_task_runner_->BelongsToCurrentThread()); PerformSingleTask(std::move(task)); + } } void InspectorTaskRunner::V8InterruptCallback(v8::Isolate*, void* data) { |