Chromium Code Reviews| 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; |