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 |