OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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/renderer/task_queue_throttler.h" | 5 #include "platform/scheduler/renderer/task_queue_throttler.h" |
6 | 6 |
7 #include <cstdint> | 7 #include <cstdint> |
8 | 8 |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "base/memory/ptr_util.h" | 10 #include "base/memory/ptr_util.h" |
(...skipping 168 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
179 // Iterator may have been deleted by BudgetPool::RemoveQueue, so don't | 179 // Iterator may have been deleted by BudgetPool::RemoveQueue, so don't |
180 // use it here. | 180 // use it here. |
181 queue_details_.erase(task_queue); | 181 queue_details_.erase(task_queue); |
182 | 182 |
183 // NOTE: Observer is automatically unregistered when unregistering task queue. | 183 // NOTE: Observer is automatically unregistered when unregistering task queue. |
184 } | 184 } |
185 | 185 |
186 void TaskQueueThrottler::OnQueueNextWakeUpChanged( | 186 void TaskQueueThrottler::OnQueueNextWakeUpChanged( |
187 TaskQueue* queue, | 187 TaskQueue* queue, |
188 base::TimeTicks next_wake_up) { | 188 base::TimeTicks next_wake_up) { |
189 if (!control_task_queue_->RunsTasksOnCurrentThread()) { | 189 if (!control_task_queue_->RunsTasksInCurrentSequence()) { |
190 control_task_queue_->PostTask( | 190 control_task_queue_->PostTask( |
191 FROM_HERE, | 191 FROM_HERE, |
192 base::Bind(forward_immediate_work_callback_, queue, next_wake_up)); | 192 base::Bind(forward_immediate_work_callback_, queue, next_wake_up)); |
193 return; | 193 return; |
194 } | 194 } |
195 | 195 |
196 TRACE_EVENT0("renderer.scheduler", | 196 TRACE_EVENT0("renderer.scheduler", |
197 "TaskQueueThrottler::OnQueueNextWakeUpChanged"); | 197 "TaskQueueThrottler::OnQueueNextWakeUpChanged"); |
198 | 198 |
199 // We don't expect this to get called for disabled queues, but we can't DCHECK | 199 // We don't expect this to get called for disabled queues, but we can't DCHECK |
(...skipping 357 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
557 queue->InsertFence(TaskQueue::InsertFencePosition::BEGINNING_OF_TIME); | 557 queue->InsertFence(TaskQueue::InsertFencePosition::BEGINNING_OF_TIME); |
558 queue->SetTimeDomain(time_domain_.get()); | 558 queue->SetTimeDomain(time_domain_.get()); |
559 UpdateQueueThrottlingState(lazy_now.Now(), queue); | 559 UpdateQueueThrottlingState(lazy_now.Now(), queue); |
560 } | 560 } |
561 | 561 |
562 TRACE_EVENT0("renderer.scheduler", "TaskQueueThrottler_EnableThrottling"); | 562 TRACE_EVENT0("renderer.scheduler", "TaskQueueThrottler_EnableThrottling"); |
563 } | 563 } |
564 | 564 |
565 } // namespace scheduler | 565 } // namespace scheduler |
566 } // namespace blink | 566 } // namespace blink |
OLD | NEW |