[scheduler] Initial budget for time-based throttling.

third_party/WebKit/Source/platform/scheduler/renderer/task_queue_throttler.cc

 // 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 "platform/scheduler/renderer/task_queue_throttler.h"
 
 #include <cstdint>
 
 #include "base/format_macros.h"
 #include "base/logging.h"
@@ skipping 63 matching lines @@
     : name_(name),
       task_queue_throttler_(task_queue_throttler),
       max_budget_level_(max_budget_level),
       max_throttling_duration_(max_throttling_duration),
       last_checkpoint_(now),
       cpu_percentage_(1),
       is_enabled_(true) {}
 
 TaskQueueThrottler::TimeBudgetPool::~TimeBudgetPool() {}
 
-void TaskQueueThrottler::TimeBudgetPool::SetTimeBudget(base::TimeTicks now,
-                                                       double cpu_percentage) {
+void TaskQueueThrottler::TimeBudgetPool::SetTimeBudgetRecoveryRate(
+    base::TimeTicks now,
+    double cpu_percentage) {
   Advance(now);
   cpu_percentage_ = cpu_percentage;
   EnforceBudgetLevelRestrictions();
 }
 
 void TaskQueueThrottler::TimeBudgetPool::AddQueue(base::TimeTicks now,
                                                   TaskQueue* queue) {
   std::pair<TaskQueueMap::iterator, bool> insert_result =
       task_queue_throttler_->queue_details_.insert(
           std::make_pair(queue, Metadata(0, queue->IsQueueEnabled())));
@@ skipping 52 matching lines @@
   }
 
   // TODO(altimin): We need to disable TimeBudgetQueues here or they will
   // regenerate extra time budget when they are disabled.
 }
 
 bool TaskQueueThrottler::TimeBudgetPool::IsThrottlingEnabled() const {
   return is_enabled_;
 }
 
+void TaskQueueThrottler::TimeBudgetPool::GrantAdditionalBudget(
+    base::TimeTicks now,
+    base::TimeDelta budget_level) {
+  Advance(now);
+  current_budget_level_ += budget_level;
+  EnforceBudgetLevelRestrictions();
+}
+
 void TaskQueueThrottler::TimeBudgetPool::SetReportingCallback(
     base::Callback<void(base::TimeDelta)> reporting_callback) {
   reporting_callback_ = reporting_callback;
 }
 
 void TaskQueueThrottler::TimeBudgetPool::Close() {
   DCHECK_EQ(0u, associated_task_queues_.size());
 
   task_queue_throttler_->time_budget_pools_.erase(this);
 }
@@ skipping 458 matching lines @@
 
     queue->SetQueueEnabled(false);
     queue->SetTimeDomain(time_domain_.get());
     MaybeSchedulePumpQueue(FROM_HERE, lazy_now.Now(), queue,
                            GetNextAllowedRunTime(lazy_now.Now(), queue));
   }
 }
 
 }  // namespace scheduler
 }  // namespace blink