| OLD | NEW | 
|   1 // Copyright 2014 The Chromium Authors. All rights reserved. |   1 // Copyright 2014 The Chromium Authors. All rights reserved. | 
|   2 // Use of this source code is governed by a BSD-style license that can be |   2 // Use of this source code is governed by a BSD-style license that can be | 
|   3 // found in the LICENSE file. |   3 // found in the LICENSE file. | 
|   4  |   4  | 
|   5 #include "content/child/scheduler/worker_scheduler_impl.h" |   5 #include "components/scheduler/child/worker_scheduler_impl.h" | 
|   6  |   6  | 
|   7 #include "base/bind.h" |   7 #include "base/bind.h" | 
|   8 #include "base/message_loop/message_loop_proxy.h" |   8 #include "base/message_loop/message_loop_proxy.h" | 
|   9 #include "base/trace_event/trace_event.h" |   9 #include "base/trace_event/trace_event.h" | 
|  10 #include "base/trace_event/trace_event_argument.h" |  10 #include "base/trace_event/trace_event_argument.h" | 
|  11 #include "content/child/scheduler/nestable_single_thread_task_runner.h" |  11 #include "components/scheduler/child/nestable_single_thread_task_runner.h" | 
|  12  |  12  | 
|  13 namespace content { |  13 namespace scheduler { | 
|  14  |  14  | 
|  15 WorkerSchedulerImpl::WorkerSchedulerImpl( |  15 WorkerSchedulerImpl::WorkerSchedulerImpl( | 
|  16     scoped_refptr<NestableSingleThreadTaskRunner> main_task_runner) |  16     scoped_refptr<NestableSingleThreadTaskRunner> main_task_runner) | 
|  17     : helper_(main_task_runner, |  17     : helper_(main_task_runner, | 
|  18               this, |  18               this, | 
|  19               "worker.scheduler", |  19               "worker.scheduler", | 
|  20               TRACE_DISABLED_BY_DEFAULT("worker.scheduler"), |  20               TRACE_DISABLED_BY_DEFAULT("worker.scheduler"), | 
|  21               "WorkerSchedulerIdlePeriod", |  21               "WorkerSchedulerIdlePeriod", | 
|  22               SchedulerHelper::TASK_QUEUE_COUNT, |  22               SchedulerHelper::TASK_QUEUE_COUNT, | 
|  23               base::TimeDelta::FromMilliseconds(300)) { |  23               base::TimeDelta::FromMilliseconds(300)) { | 
| (...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
|  72  |  72  | 
|  73 void WorkerSchedulerImpl::Shutdown() { |  73 void WorkerSchedulerImpl::Shutdown() { | 
|  74   DCHECK(initialized_); |  74   DCHECK(initialized_); | 
|  75   helper_.Shutdown(); |  75   helper_.Shutdown(); | 
|  76 } |  76 } | 
|  77  |  77  | 
|  78 SchedulerHelper* WorkerSchedulerImpl::GetSchedulerHelperForTesting() { |  78 SchedulerHelper* WorkerSchedulerImpl::GetSchedulerHelperForTesting() { | 
|  79   return &helper_; |  79   return &helper_; | 
|  80 } |  80 } | 
|  81  |  81  | 
|  82 void WorkerSchedulerImpl::SetWorkBatchSizeForTesting(size_t work_batch_size) { |  | 
|  83   helper_.SetWorkBatchSizeForTesting(work_batch_size); |  | 
|  84 } |  | 
|  85  |  | 
|  86 bool WorkerSchedulerImpl::CanEnterLongIdlePeriod(base::TimeTicks, |  82 bool WorkerSchedulerImpl::CanEnterLongIdlePeriod(base::TimeTicks, | 
|  87                                                  base::TimeDelta*) { |  83                                                  base::TimeDelta*) { | 
|  88   return true; |  84   return true; | 
|  89 } |  85 } | 
|  90  |  86  | 
|  91 base::TimeTicks WorkerSchedulerImpl::CurrentIdleTaskDeadlineForTesting() const { |  87 base::TimeTicks WorkerSchedulerImpl::CurrentIdleTaskDeadlineForTesting() const { | 
|  92   base::TimeTicks deadline; |  88   base::TimeTicks deadline; | 
|  93   helper_.CurrentIdleTaskDeadlineCallback(&deadline); |  89   helper_.CurrentIdleTaskDeadlineCallback(&deadline); | 
|  94   return deadline; |  90   return deadline; | 
|  95 } |  91 } | 
|  96  |  92  | 
|  97 }  // namespace content |  93 }  // namespace scheduler | 
| OLD | NEW |