| Index: components/scheduler/renderer/throttling_helper.cc
|
| diff --git a/components/scheduler/renderer/throttling_helper.cc b/components/scheduler/renderer/throttling_helper.cc
|
| deleted file mode 100644
|
| index 88f9ae77d89d6931430ca5f7d166cbdb4f53595a..0000000000000000000000000000000000000000
|
| --- a/components/scheduler/renderer/throttling_helper.cc
|
| +++ /dev/null
|
| @@ -1,106 +0,0 @@
|
| -// Copyright 2015 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#include "components/scheduler/renderer/throttling_helper.h"
|
| -
|
| -#include "base/logging.h"
|
| -#include "components/scheduler/base/real_time_domain.h"
|
| -#include "components/scheduler/base/virtual_time_domain.h"
|
| -#include "components/scheduler/child/scheduler_tqm_delegate.h"
|
| -#include "components/scheduler/renderer/renderer_scheduler_impl.h"
|
| -#include "components/scheduler/renderer/web_frame_scheduler_impl.h"
|
| -#include "third_party/WebKit/public/platform/WebFrameScheduler.h"
|
| -
|
| -namespace scheduler {
|
| -
|
| -ThrottlingHelper::ThrottlingHelper(RendererSchedulerImpl* renderer_scheduler,
|
| - const char* tracing_category)
|
| - : task_runner_(renderer_scheduler->ControlTaskRunner()),
|
| - renderer_scheduler_(renderer_scheduler),
|
| - tick_clock_(renderer_scheduler->tick_clock()),
|
| - tracing_category_(tracing_category),
|
| - time_domain_(new VirtualTimeDomain(this, tick_clock_->NowTicks())),
|
| - pending_pump_throttled_tasks_(false),
|
| - weak_factory_(this) {
|
| - pump_throttled_tasks_closure_ = base::Bind(
|
| - &ThrottlingHelper::PumpThrottledTasks, weak_factory_.GetWeakPtr());
|
| - forward_immediate_work_closure_ =
|
| - base::Bind(&ThrottlingHelper::OnTimeDomainHasImmediateWork,
|
| - weak_factory_.GetWeakPtr());
|
| - renderer_scheduler_->RegisterTimeDomain(time_domain_.get());
|
| -}
|
| -
|
| -ThrottlingHelper::~ThrottlingHelper() {
|
| - renderer_scheduler_->UnregisterTimeDomain(time_domain_.get());
|
| -}
|
| -
|
| -void ThrottlingHelper::Throttle(TaskQueue* task_queue) {
|
| - throttled_queues_.insert(task_queue);
|
| -
|
| - task_queue->SetTimeDomain(time_domain_.get());
|
| - task_queue->SetPumpPolicy(TaskQueue::PumpPolicy::MANUAL);
|
| -
|
| - MaybeSchedulePumpThrottledTasksLocked();
|
| -}
|
| -
|
| -void ThrottlingHelper::Unthrottle(TaskQueue* task_queue) {
|
| - throttled_queues_.erase(task_queue);
|
| -
|
| - task_queue->SetTimeDomain(renderer_scheduler_->real_time_domain());
|
| - task_queue->SetPumpPolicy(TaskQueue::PumpPolicy::AUTO);
|
| -}
|
| -
|
| -void ThrottlingHelper::OnTimeDomainHasImmediateWork() {
|
| - // Forward to the main thread if called from another thread.
|
| - if (!task_runner_->RunsTasksOnCurrentThread()) {
|
| - task_runner_->PostTask(FROM_HERE, forward_immediate_work_closure_);
|
| - return;
|
| - }
|
| - TRACE_EVENT0(tracing_category_,
|
| - "ThrottlingHelper::OnTimeDomainHasImmediateWork");
|
| - MaybeSchedulePumpThrottledTasksLocked();
|
| -}
|
| -
|
| -void ThrottlingHelper::OnTimeDomainHasDelayedWork() {
|
| - TRACE_EVENT0(tracing_category_,
|
| - "ThrottlingHelper::OnTimeDomainHasDelayedWork");
|
| - MaybeSchedulePumpThrottledTasksLocked();
|
| -}
|
| -
|
| -void ThrottlingHelper::PumpThrottledTasks() {
|
| - TRACE_EVENT0(tracing_category_, "ThrottlingHelper::PumpThrottledTasks");
|
| - pending_pump_throttled_tasks_ = false;
|
| -
|
| - time_domain_->AdvanceTo(tick_clock_->NowTicks());
|
| - bool work_to_do = false;
|
| - for (TaskQueue* task_queue : throttled_queues_) {
|
| - if (task_queue->GetQueueState() == TaskQueue::QueueState::EMPTY)
|
| - continue;
|
| -
|
| - work_to_do = true;
|
| - task_queue->PumpQueue();
|
| - }
|
| -
|
| - if (work_to_do)
|
| - MaybeSchedulePumpThrottledTasksLocked();
|
| -}
|
| -
|
| -/* static */
|
| -base::TimeDelta ThrottlingHelper::DelayToNextRunTimeInSeconds(
|
| - base::TimeTicks now) {
|
| - const base::TimeDelta one_second = base::TimeDelta::FromSeconds(1);
|
| - return one_second - ((now - base::TimeTicks()) % one_second);
|
| -}
|
| -
|
| -void ThrottlingHelper::MaybeSchedulePumpThrottledTasksLocked() {
|
| - if (pending_pump_throttled_tasks_)
|
| - return;
|
| -
|
| - pending_pump_throttled_tasks_ = true;
|
| - task_runner_->PostDelayedTask(
|
| - FROM_HERE, pump_throttled_tasks_closure_,
|
| - DelayToNextRunTimeInSeconds(tick_clock_->NowTicks()));
|
| -}
|
| -
|
| -} // namespace scheduler
|
|
|