Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(422)

Side by Side Diff: components/scheduler/child/task_queue_manager.cc

Issue 1151353003: [scheduler]: Avoid waking up the scheduler to end long idle periods. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@end_idle_sync_2
Patch Set: Fix tests and update for review. Created 5 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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
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
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
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698