| 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 "platform/scheduler/base/task_queue_manager.h" | 5 #include "platform/scheduler/base/task_queue_manager.h" | 
| 6 | 6 | 
| 7 #include <queue> | 7 #include <queue> | 
| 8 #include <set> | 8 #include <set> | 
| 9 | 9 | 
| 10 #include "base/bind.h" | 10 #include "base/bind.h" | 
| (...skipping 208 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
| 219       case ProcessTaskResult::EXECUTED: | 219       case ProcessTaskResult::EXECUTED: | 
| 220         break; | 220         break; | 
| 221       case ProcessTaskResult::TASK_QUEUE_MANAGER_DELETED: | 221       case ProcessTaskResult::TASK_QUEUE_MANAGER_DELETED: | 
| 222         return;  // The TaskQueueManager got deleted, we must bail out. | 222         return;  // The TaskQueueManager got deleted, we must bail out. | 
| 223     } | 223     } | 
| 224 | 224 | 
| 225     lazy_now = real_time_domain()->CreateLazyNow(); | 225     lazy_now = real_time_domain()->CreateLazyNow(); | 
| 226     if (!delegate_->IsNested() && task_start_time != base::TimeTicks()) { | 226     if (!delegate_->IsNested() && task_start_time != base::TimeTicks()) { | 
| 227       // Only report top level task durations. | 227       // Only report top level task durations. | 
| 228       base::TimeTicks task_end_time = lazy_now.Now(); | 228       base::TimeTicks task_end_time = lazy_now.Now(); | 
|  | 229 | 
| 229       FOR_EACH_OBSERVER(TaskTimeObserver, task_time_observers_, | 230       FOR_EACH_OBSERVER(TaskTimeObserver, task_time_observers_, | 
| 230                         ReportTaskTime(MonotonicTimeInSeconds(task_start_time), | 231                         ReportTaskTime(work_queue->task_queue(), | 
| 231                                        MonotonicTimeInSeconds(task_end_time))); | 232                                        task_start_time, task_end_time)); | 
|  | 233 | 
| 232       task_start_time = task_end_time; | 234       task_start_time = task_end_time; | 
| 233     } | 235     } | 
| 234 | 236 | 
| 235     work_queue = nullptr;  // The queue may have been unregistered. | 237     work_queue = nullptr;  // The queue may have been unregistered. | 
| 236 | 238 | 
| 237     UpdateWorkQueues(lazy_now); | 239     UpdateWorkQueues(lazy_now); | 
| 238 | 240 | 
| 239     // Only run a single task per batch in nested run loops so that we can | 241     // Only run a single task per batch in nested run loops so that we can | 
| 240     // properly exit the nested loop when someone calls RunLoop::Quit(). | 242     // properly exit the nested loop when someone calls RunLoop::Quit(). | 
| 241     if (delegate_->IsNested()) | 243     if (delegate_->IsNested()) | 
| (...skipping 190 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
| 432   DCHECK(main_thread_checker_.CalledOnValidThread()); | 434   DCHECK(main_thread_checker_.CalledOnValidThread()); | 
| 433   DCHECK(!work_queue->Empty()); | 435   DCHECK(!work_queue->Empty()); | 
| 434   if (observer_) { | 436   if (observer_) { | 
| 435     observer_->OnTriedToExecuteBlockedTask(*work_queue->task_queue(), | 437     observer_->OnTriedToExecuteBlockedTask(*work_queue->task_queue(), | 
| 436                                            *work_queue->GetFrontTask()); | 438                                            *work_queue->GetFrontTask()); | 
| 437   } | 439   } | 
| 438 } | 440 } | 
| 439 | 441 | 
| 440 }  // namespace scheduler | 442 }  // namespace scheduler | 
| 441 }  // namespace blink | 443 }  // namespace blink | 
| OLD | NEW | 
|---|