Index: content/child/scheduler/webthread_impl_for_worker_scheduler.cc |
diff --git a/content/child/scheduler/webthread_impl_for_worker_scheduler.cc b/content/child/scheduler/webthread_impl_for_worker_scheduler.cc |
index 20379b1212f2ffaa05b2850e4326355412a1ebca..9930b6b913b650602d70f04e13cfd8f850c21c5b 100644 |
--- a/content/child/scheduler/webthread_impl_for_worker_scheduler.cc |
+++ b/content/child/scheduler/webthread_impl_for_worker_scheduler.cc |
@@ -8,6 +8,7 @@ |
#include "base/synchronization/waitable_event.h" |
#include "content/child/scheduler/scheduler_message_loop_delegate.h" |
#include "content/child/scheduler/worker_scheduler_impl.h" |
+#include "content/child/scheduler/worker_web_scheduler_impl.h" |
#include "third_party/WebKit/public/platform/WebTraceLocation.h" |
namespace content { |
@@ -42,6 +43,7 @@ void WebThreadImplForWorkerScheduler::InitOnThread( |
worker_scheduler_->Init(); |
task_runner_ = worker_scheduler_->DefaultTaskRunner(); |
idle_task_runner_ = worker_scheduler_->IdleTaskRunner(); |
+ web_scheduler_.reset(new WorkerWebSchedulerImpl(worker_scheduler_.get())); |
completion->Signal(); |
} |
@@ -49,6 +51,7 @@ void WebThreadImplForWorkerScheduler::ShutDownOnThread( |
base::WaitableEvent* completion) { |
task_runner_ = nullptr; |
idle_task_runner_ = nullptr; |
+ web_scheduler_.reset(nullptr); |
Sami
2015/04/16 10:44:01
nit: I think you can just call reset() without any
alex clarke (OOO till 29th)
2015/04/16 13:35:01
Done.
|
worker_scheduler_.reset(nullptr); |
completion->Signal(); |
} |
@@ -57,6 +60,10 @@ blink::PlatformThreadId WebThreadImplForWorkerScheduler::threadId() const { |
return thread_->thread_id(); |
} |
+blink::WebScheduler* WebThreadImplForWorkerScheduler::scheduler() const { |
+ return web_scheduler_.get(); |
+} |
+ |
base::MessageLoop* WebThreadImplForWorkerScheduler::MessageLoop() const { |
// As per WebThreadImpl::MessageLoop() |
return nullptr; |