| 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 604 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 615 bool task_was_run = task_was_run_on_quiescence_monitored_queue_; | 615 bool task_was_run = task_was_run_on_quiescence_monitored_queue_; |
| 616 task_was_run_on_quiescence_monitored_queue_ = false; | 616 task_was_run_on_quiescence_monitored_queue_ = false; |
| 617 return !task_was_run; | 617 return !task_was_run; |
| 618 } | 618 } |
| 619 | 619 |
| 620 const scoped_refptr<TaskQueueManagerDelegate>& TaskQueueManager::Delegate() | 620 const scoped_refptr<TaskQueueManagerDelegate>& TaskQueueManager::Delegate() |
| 621 const { | 621 const { |
| 622 return delegate_; | 622 return delegate_; |
| 623 } | 623 } |
| 624 | 624 |
| 625 internal::EnqueueOrder TaskQueueManager::GetNextSequenceNumber() { | 625 internal::EnqueueOrder TaskQueueManager::GetNextEnqueueOrder( |
| 626 return enqueue_order_generator_.GenerateNext(); | 626 base::TimeTicks delayed_run_time) { |
| 627 return enqueue_order_generator_.GenerateNext(delayed_run_time); |
| 627 } | 628 } |
| 628 | 629 |
| 629 LazyNow TaskQueueManager::CreateLazyNow() const { | 630 LazyNow TaskQueueManager::CreateLazyNow() const { |
| 630 return LazyNow(delegate_.get()); | 631 return LazyNow(delegate_.get()); |
| 631 } | 632 } |
| 632 | 633 |
| 633 size_t TaskQueueManager::GetNumberOfPendingTasks() const { | 634 size_t TaskQueueManager::GetNumberOfPendingTasks() const { |
| 634 size_t task_count = 0; | 635 size_t task_count = 0; |
| 635 for (auto& queue : queues_) | 636 for (auto& queue : queues_) |
| 636 task_count += queue->GetNumberOfPendingTasks(); | 637 task_count += queue->GetNumberOfPendingTasks(); |
| (...skipping 74 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 711 for (const scoped_refptr<internal::TaskQueueImpl>& queue : queues_) { | 712 for (const scoped_refptr<internal::TaskQueueImpl>& queue : queues_) { |
| 712 TimeDomain* time_domain = queue->GetTimeDomain(); | 713 TimeDomain* time_domain = queue->GetTimeDomain(); |
| 713 if (time_domain_now.find(time_domain) == time_domain_now.end()) | 714 if (time_domain_now.find(time_domain) == time_domain_now.end()) |
| 714 time_domain_now.insert(std::make_pair(time_domain, time_domain->Now())); | 715 time_domain_now.insert(std::make_pair(time_domain, time_domain->Now())); |
| 715 queue->SweepCanceledDelayedTasks(time_domain_now[time_domain]); | 716 queue->SweepCanceledDelayedTasks(time_domain_now[time_domain]); |
| 716 } | 717 } |
| 717 } | 718 } |
| 718 | 719 |
| 719 } // namespace scheduler | 720 } // namespace scheduler |
| 720 } // namespace blink | 721 } // namespace blink |
| OLD | NEW |