Chromium Code Reviews| Index: components/scheduler/base/task_queue_manager.cc |
| diff --git a/components/scheduler/base/task_queue_manager.cc b/components/scheduler/base/task_queue_manager.cc |
| index 36f08de540fe8529ab593f6248504b0d23561795..eeaa0dc4cf3e54eceeb4365ca899fa4bc9b19062 100644 |
| --- a/components/scheduler/base/task_queue_manager.cc |
| +++ b/components/scheduler/base/task_queue_manager.cc |
| @@ -14,6 +14,7 @@ |
| #include "components/scheduler/base/task_queue_impl.h" |
| #include "components/scheduler/base/task_queue_manager_delegate.h" |
| #include "components/scheduler/base/task_queue_selector.h" |
| +#include "components/scheduler/base/task_time_tracker.h" |
| #include "components/scheduler/base/work_queue.h" |
| #include "components/scheduler/base/work_queue_sets.h" |
| @@ -38,12 +39,16 @@ TaskQueueManager::TaskQueueManager( |
| scoped_refptr<TaskQueueManagerDelegate> delegate, |
| const char* tracing_category, |
| const char* disabled_by_default_tracing_category, |
| - const char* disabled_by_default_verbose_tracing_category) |
| + const char* disabled_by_default_verbose_tracing_category, |
| + TaskTimeTracker* task_time_tracker) |
| : real_time_domain_(new RealTimeDomain(tracing_category)), |
| delegate_(delegate), |
| task_was_run_on_quiescence_monitored_queue_(false), |
| work_batch_size_(1), |
| task_count_(0), |
| + task_time_tracker_(new TaskTimeTracker()), |
| + timer_(new base::DefaultTickClock()), |
|
Sami
2016/07/04 09:56:49
You might be able to read the time from real_time_
|
| + next_task_start_time_(base::TimeTicks()), |
| tracing_category_(tracing_category), |
| disabled_by_default_tracing_category_( |
| disabled_by_default_tracing_category), |
| @@ -192,6 +197,7 @@ void TaskQueueManager::DoWork(base::TimeTicks run_time, bool from_main_thread) { |
| UpdateWorkQueues(false, nullptr); |
| internal::TaskQueueImpl::Task previous_task; |
| + base::TimeTicks task_start_time = timer_->NowTicks(); |
| for (int i = 0; i < work_batch_size_; i++) { |
| internal::WorkQueue* work_queue; |
| if (!SelectWorkQueueToService(&work_queue)) { |
| @@ -211,6 +217,10 @@ void TaskQueueManager::DoWork(base::TimeTicks run_time, bool from_main_thread) { |
| case ProcessTaskResult::TASK_QUEUE_MANAGER_DELETED: |
| return; // The TaskQueueManager got deleted, we must bail out. |
| } |
| + base::TimeTicks task_end_time = timer_->NowTicks(); |
| + task_time_tracker_->ReportTaskTime(task_start_time, task_end_time); |
| + task_start_time = task_end_time; |
| + |
| work_queue = nullptr; // The queue may have been unregistered. |
| UpdateWorkQueues(should_trigger_wakeup, &previous_task); |