summaryrefslogtreecommitdiff
path: root/chromium/third_party/blink/renderer/core/inspector/inspector_task_runner.cc
diff options
context:
space:
mode:
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.cc18
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) {