| Index: content/renderer/scheduler/task_queue_manager.cc
|
| diff --git a/content/renderer/scheduler/task_queue_manager.cc b/content/renderer/scheduler/task_queue_manager.cc
|
| index 083c7734acdd7f9e61fbbf6e4d3492ea5e021285..12c4e184996d249a7946d1adfcbfb07ebbc9ddad 100644
|
| --- a/content/renderer/scheduler/task_queue_manager.cc
|
| +++ b/content/renderer/scheduler/task_queue_manager.cc
|
| @@ -317,13 +317,13 @@ bool TaskQueueManager::IsQueueEmpty(size_t queue_index) const {
|
| }
|
|
|
| void TaskQueueManager::SetAutoPump(size_t queue_index, bool auto_pump) {
|
| - main_thread_checker_.CalledOnValidThread();
|
| + DCHECK(main_thread_checker_.CalledOnValidThread());
|
| internal::TaskQueue* queue = Queue(queue_index);
|
| queue->SetAutoPump(auto_pump);
|
| }
|
|
|
| void TaskQueueManager::PumpQueue(size_t queue_index) {
|
| - main_thread_checker_.CalledOnValidThread();
|
| + DCHECK(main_thread_checker_.CalledOnValidThread());
|
| internal::TaskQueue* queue = Queue(queue_index);
|
| queue->PumpQueue();
|
| }
|
| @@ -333,7 +333,7 @@ bool TaskQueueManager::UpdateWorkQueues(
|
| // TODO(skyostil): This is not efficient when the number of queues grows very
|
| // large due to the number of locks taken. Consider optimizing when we get
|
| // there.
|
| - main_thread_checker_.CalledOnValidThread();
|
| + DCHECK(main_thread_checker_.CalledOnValidThread());
|
| bool has_work = false;
|
| for (auto& queue : queues_) {
|
| has_work |= queue->UpdateWorkQueue(next_pending_delayed_task);
|
| @@ -367,7 +367,7 @@ void TaskQueueManager::DoWork(bool posted_from_main_thread) {
|
| pending_dowork_count_--;
|
| DCHECK_GE(pending_dowork_count_, 0);
|
| }
|
| - main_thread_checker_.CalledOnValidThread();
|
| + DCHECK(main_thread_checker_.CalledOnValidThread());
|
|
|
| base::TimeTicks next_pending_delayed_task(
|
| base::TimeTicks::FromInternalValue(kMaxTimeTicks));
|
| @@ -404,7 +404,7 @@ void TaskQueueManager::DidQueueTask(base::PendingTask* pending_task) {
|
| }
|
|
|
| void TaskQueueManager::ProcessTaskFromWorkQueue(size_t queue_index) {
|
| - main_thread_checker_.CalledOnValidThread();
|
| + DCHECK(main_thread_checker_.CalledOnValidThread());
|
| internal::TaskQueue* queue = Queue(queue_index);
|
| base::PendingTask pending_task = queue->TakeTaskFromWorkQueue();
|
| if (!pending_task.nestable) {
|
| @@ -431,20 +431,20 @@ bool TaskQueueManager::PostDelayedTask(
|
| }
|
|
|
| void TaskQueueManager::SetQueueName(size_t queue_index, const char* name) {
|
| - main_thread_checker_.CalledOnValidThread();
|
| + DCHECK(main_thread_checker_.CalledOnValidThread());
|
| internal::TaskQueue* queue = Queue(queue_index);
|
| queue->set_name(name);
|
| }
|
|
|
| void TaskQueueManager::SetWorkBatchSize(int work_batch_size) {
|
| - main_thread_checker_.CalledOnValidThread();
|
| + DCHECK(main_thread_checker_.CalledOnValidThread());
|
| DCHECK_GE(work_batch_size, 1);
|
| work_batch_size_ = work_batch_size;
|
| }
|
|
|
| void TaskQueueManager::SetTimeSourceForTesting(
|
| scoped_refptr<cc::TestNowSource> time_source) {
|
| - main_thread_checker_.CalledOnValidThread();
|
| + DCHECK(main_thread_checker_.CalledOnValidThread());
|
| time_source_ = time_source;
|
| }
|
|
|
| @@ -455,7 +455,7 @@ base::TimeTicks TaskQueueManager::Now() const {
|
| scoped_refptr<base::debug::ConvertableToTraceFormat>
|
| TaskQueueManager::AsValueWithSelectorResult(bool should_run,
|
| size_t selected_queue) const {
|
| - main_thread_checker_.CalledOnValidThread();
|
| + DCHECK(main_thread_checker_.CalledOnValidThread());
|
| scoped_refptr<base::debug::TracedValue> state =
|
| new base::debug::TracedValue();
|
| state->BeginArray("queues");
|
|
|