[Reland] Per WebViewScheduler virtual time

components/scheduler/renderer/web_frame_scheduler_impl.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 "components/scheduler/renderer/web_frame_scheduler_impl.h"
 
 #include "components/scheduler/base/real_time_domain.h"
 #include "components/scheduler/base/virtual_time_domain.h"
 #include "components/scheduler/child/web_task_runner_impl.h"
+#include "components/scheduler/renderer/auto_advancing_virtual_time_domain.h"
 #include "components/scheduler/renderer/renderer_scheduler_impl.h"
 #include "components/scheduler/renderer/web_view_scheduler_impl.h"
 #include "third_party/WebKit/public/platform/WebString.h"
 
 namespace scheduler {
 
 WebFrameSchedulerImpl::WebFrameSchedulerImpl(
     RendererSchedulerImpl* renderer_scheduler,
     WebViewSchedulerImpl* parent_web_view_scheduler)
     : renderer_scheduler_(renderer_scheduler),
       parent_web_view_scheduler_(parent_web_view_scheduler),
+      virtual_time_domain_(nullptr),

[Sami, 2016/02/01 11:15:07]

If a new frame gets created under a WebViewScheduler which uses virtual time, it
should probably get virtual time automatically too. Maybe a pull model would
work better for that? (That is we'd ask WebViewScheduler for our time domain &
pump policy.)

[alex clarke (OOO till 29th), 2016/02/01 14:16:54]

I think the pull vs push is cleaner, done.

+      virtual_time_pump_policy_(TaskQueue::PumpPolicy::AUTO),
       frame_visible_(true),
       page_visible_(true) {}
 
 WebFrameSchedulerImpl::~WebFrameSchedulerImpl() {
   if (loading_task_queue_.get())
     loading_task_queue_->UnregisterTaskQueue();
 
   if (timer_task_queue_.get())
     timer_task_queue_->UnregisterTaskQueue();
 
   if (parent_web_view_scheduler_)
     parent_web_view_scheduler_->Unregister(this);
 }
 
 void WebFrameSchedulerImpl::DetachFromWebViewScheduler() {
   parent_web_view_scheduler_ = nullptr;
 }
 
 void WebFrameSchedulerImpl::setFrameVisible(bool frame_visible) {
   frame_visible_ = frame_visible;
   // TODO(alexclarke): Do something with this flag.
 }
 
 blink::WebTaskRunner* WebFrameSchedulerImpl::loadingTaskRunner() {
   if (!loading_web_task_runner_) {
     loading_task_queue_ =
         renderer_scheduler_->NewLoadingTaskRunner("frame_loading_tq");
+    if (virtual_time_domain_) {
+      loading_task_queue_->SetTimeDomain(virtual_time_domain_);
+      loading_task_queue_->SetPumpPolicy(virtual_time_pump_policy_);
+    }
     loading_web_task_runner_.reset(new WebTaskRunnerImpl(loading_task_queue_));
   }
   return loading_web_task_runner_.get();
 }
 
 blink::WebTaskRunner* WebFrameSchedulerImpl::timerTaskRunner() {
   if (!timer_web_task_runner_) {
     timer_task_queue_ =
         renderer_scheduler_->NewTimerTaskRunner("frame_timer_tq");
-    if (!page_visible_) {
+    if (virtual_time_domain_) {
+      timer_task_queue_->SetTimeDomain(virtual_time_domain_);
+      timer_task_queue_->SetPumpPolicy(virtual_time_pump_policy_);
+    } else if (!page_visible_) {
       renderer_scheduler_->throttling_helper()->IncreaseThrottleRefCount(
           timer_task_queue_.get());
     }
     timer_web_task_runner_.reset(new WebTaskRunnerImpl(timer_task_queue_));
   }
   return timer_web_task_runner_.get();
 }
 
 void WebFrameSchedulerImpl::setFrameOrigin(
     const blink::WebSecurityOrigin& origin) {
   origin_ = origin;
   // TODO(skyostil): Associate the task queues with this origin.
 }
 
 void WebFrameSchedulerImpl::setPageVisible(bool page_visible) {
   if (page_visible_ == page_visible)
     return;
 
   page_visible_ = page_visible;
 
-  if (!timer_web_task_runner_)
+  if (!timer_web_task_runner_ || virtual_time_domain_)
     return;
 
   if (page_visible_) {
     renderer_scheduler_->throttling_helper()->DecreaseThrottleRefCount(
         timer_task_queue_.get());
   } else {
     renderer_scheduler_->throttling_helper()->IncreaseThrottleRefCount(
         timer_task_queue_.get());
   }
 }
 
+void WebFrameSchedulerImpl::UseVirtualTime(
+    AutoAdvancingVirtualTimeDomain* virtual_time_domain) {
+  virtual_time_domain_ = virtual_time_domain;
+
+  if (timer_task_queue_.get()) {
+    renderer_scheduler_->throttling_helper()->UnregisterTaskQueue(
+        timer_task_queue_.get());
+    timer_task_queue_->SetTimeDomain(virtual_time_domain);
+    timer_task_queue_->SetPumpPolicy(virtual_time_pump_policy_);
+  }
+
+  if (loading_task_queue_.get()) {
+    loading_task_queue_->SetTimeDomain(virtual_time_domain);
+    loading_task_queue_->SetPumpPolicy(virtual_time_pump_policy_);
+  }
+}
+
+void WebFrameSchedulerImpl::SetCanAdvanceVirtualTime(
+    bool allow_virtual_time_to_advance) {
+  virtual_time_pump_policy_ = allow_virtual_time_to_advance ?
+      TaskQueue::PumpPolicy::AUTO : TaskQueue::PumpPolicy::MANUAL;
+

[Sami, 2016/02/01 11:15:07]

DCHECK(virtual_time_domain_) instead to make sure everyone enables virtual time
before trying to use it.

[alex clarke (OOO till 29th), 2016/02/01 14:16:54]

Why do we need to enforce that? We can make it do the right thing regardless.

+  if (!virtual_time_domain_)
+    return;
+
+  if (timer_task_queue_.get())
+    timer_task_queue_->SetPumpPolicy(virtual_time_pump_policy_);
+
+  if (loading_task_queue_.get())
+    loading_task_queue_->SetPumpPolicy(virtual_time_pump_policy_);
+}
+
 }  // namespace scheduler