| 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 "components/scheduler/child/task_queue_manager.h" | 5 #include "components/scheduler/child/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 694 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 705 | 705 |
| 706 void TaskQueueManager::SetWorkBatchSize(int work_batch_size) { | 706 void TaskQueueManager::SetWorkBatchSize(int work_batch_size) { |
| 707 DCHECK(main_thread_checker_.CalledOnValidThread()); | 707 DCHECK(main_thread_checker_.CalledOnValidThread()); |
| 708 DCHECK_GE(work_batch_size, 1); | 708 DCHECK_GE(work_batch_size, 1); |
| 709 work_batch_size_ = work_batch_size; | 709 work_batch_size_ = work_batch_size; |
| 710 } | 710 } |
| 711 | 711 |
| 712 void TaskQueueManager::AddTaskObserver( | 712 void TaskQueueManager::AddTaskObserver( |
| 713 base::MessageLoop::TaskObserver* task_observer) { | 713 base::MessageLoop::TaskObserver* task_observer) { |
| 714 DCHECK(main_thread_checker_.CalledOnValidThread()); | 714 DCHECK(main_thread_checker_.CalledOnValidThread()); |
| 715 base::MessageLoop::current()->AddTaskObserver(task_observer); | 715 main_task_runner_->AddTaskObserver(task_observer); |
| 716 task_observers_.AddObserver(task_observer); | 716 task_observers_.AddObserver(task_observer); |
| 717 } | 717 } |
| 718 | 718 |
| 719 void TaskQueueManager::RemoveTaskObserver( | 719 void TaskQueueManager::RemoveTaskObserver( |
| 720 base::MessageLoop::TaskObserver* task_observer) { | 720 base::MessageLoop::TaskObserver* task_observer) { |
| 721 DCHECK(main_thread_checker_.CalledOnValidThread()); | 721 DCHECK(main_thread_checker_.CalledOnValidThread()); |
| 722 base::MessageLoop::current()->RemoveTaskObserver(task_observer); | 722 main_task_runner_->RemoveTaskObserver(task_observer); |
| 723 task_observers_.RemoveObserver(task_observer); | 723 task_observers_.RemoveObserver(task_observer); |
| 724 } | 724 } |
| 725 | 725 |
| 726 void TaskQueueManager::SetTimeSourceForTesting( | 726 void TaskQueueManager::SetTimeSourceForTesting( |
| 727 scoped_ptr<TimeSource> time_source) { | 727 scoped_ptr<TimeSource> time_source) { |
| 728 DCHECK(main_thread_checker_.CalledOnValidThread()); | 728 DCHECK(main_thread_checker_.CalledOnValidThread()); |
| 729 time_source_ = time_source.Pass(); | 729 time_source_ = time_source.Pass(); |
| 730 } | 730 } |
| 731 | 731 |
| 732 uint64 TaskQueueManager::GetAndClearTaskWasRunOnQueueBitmap() { | 732 uint64 TaskQueueManager::GetAndClearTaskWasRunOnQueueBitmap() { |
| (...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 786 return nullptr; | 786 return nullptr; |
| 787 } | 787 } |
| 788 } | 788 } |
| 789 | 789 |
| 790 void TaskQueueManager::OnTaskQueueEnabled() { | 790 void TaskQueueManager::OnTaskQueueEnabled() { |
| 791 DCHECK(main_thread_checker_.CalledOnValidThread()); | 791 DCHECK(main_thread_checker_.CalledOnValidThread()); |
| 792 MaybePostDoWorkOnMainRunner(); | 792 MaybePostDoWorkOnMainRunner(); |
| 793 } | 793 } |
| 794 | 794 |
| 795 } // namespace scheduler | 795 } // namespace scheduler |
| OLD | NEW |