Index: components/scheduler/child/webthread_impl_for_worker_scheduler.cc |
diff --git a/components/scheduler/child/webthread_impl_for_worker_scheduler.cc b/components/scheduler/child/webthread_impl_for_worker_scheduler.cc |
index 0654c9ab2f4c7fa9da1cd151bbddb80e6b09defd..4f960783ee5f8d46e77296c75aac4b1db3673381 100644 |
--- a/components/scheduler/child/webthread_impl_for_worker_scheduler.cc |
+++ b/components/scheduler/child/webthread_impl_for_worker_scheduler.cc |
@@ -11,6 +11,7 @@ |
#include "components/scheduler/child/scheduler_task_runner_delegate_impl.h" |
#include "components/scheduler/child/task_queue.h" |
#include "components/scheduler/child/web_scheduler_impl.h" |
+#include "components/scheduler/child/web_task_runner_impl.h" |
#include "components/scheduler/child/worker_scheduler_impl.h" |
#include "third_party/WebKit/public/platform/WebTraceLocation.h" |
@@ -53,6 +54,7 @@ void WebThreadImplForWorkerScheduler::InitOnThread( |
worker_scheduler_->DefaultTaskRunner(), |
worker_scheduler_->DefaultTaskRunner())); |
base::MessageLoop::current()->AddDestructionObserver(this); |
+ web_task_runner_ = make_scoped_ptr(new WebTaskRunnerImpl(task_runner_)); |
completion->Signal(); |
} |
@@ -87,6 +89,10 @@ SingleThreadIdleTaskRunner* WebThreadImplForWorkerScheduler::IdleTaskRunner() |
return idle_task_runner_.get(); |
} |
+blink::WebTaskRunner* WebThreadImplForWorkerScheduler::taskRunner() { |
+ return web_task_runner_.get(); |
+} |
+ |
void WebThreadImplForWorkerScheduler::AddTaskObserverInternal( |
base::MessageLoop::TaskObserver* observer) { |
worker_scheduler_->AddTaskObserver(observer); |