input: Change how synthesized events are dispatched in telemetry tests.

content/browser/renderer_host/render_widget_host_impl.cc

 // Copyright (c) 2012 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 "content/browser/renderer_host/render_widget_host_impl.h"
 
 #include <math.h>
 
 #include <set>
 #include <tuple>
@@ skipping 471 matching lines @@
   if (!view_)
     return;
 
   last_view_screen_rect_ = view_->GetViewBounds();
   last_window_screen_rect_ = view_->GetBoundsInRootWindow();
   Send(new ViewMsg_UpdateScreenRects(
       GetRoutingID(), last_view_screen_rect_, last_window_screen_rect_));
   waiting_for_screen_rects_ack_ = true;
 }
 
-void RenderWidgetHostImpl::FlushInput() {
-  input_router_->RequestNotificationWhenFlushed();
-  if (synthetic_gesture_controller_)
-    synthetic_gesture_controller_->Flush(base::TimeTicks::Now());
-}
-
-void RenderWidgetHostImpl::SetNeedsFlush() {
-  if (view_)
-    view_->OnSetNeedsFlushInput();
+void RenderWidgetHostImpl::OnBeginFrame() {
+  if (begin_frame_callback_)
+    std::move(begin_frame_callback_).Run();
 }
 
 void RenderWidgetHostImpl::Init() {
   DCHECK(process_->HasConnection());
 
   renderer_initialized_ = true;
 
   SendScreenRects();
   WasResized();
 
@@ skipping 798 matching lines @@
     Send(
         new InputMsg_SetEditCommandsForNextKeyEvent(GetRoutingID(), *commands));
   }
   input_router_->SendKeyboardEvent(key_event_with_latency);
 }
 
 void RenderWidgetHostImpl::QueueSyntheticGesture(
     std::unique_ptr<SyntheticGesture> synthetic_gesture,
     const base::Callback<void(SyntheticGesture::Result)>& on_complete) {
   if (!synthetic_gesture_controller_ && view_) {
-    synthetic_gesture_controller_.reset(
-        new SyntheticGestureController(view_->CreateSyntheticGestureTarget()));
+    synthetic_gesture_controller_ =
+        base::MakeUnique<SyntheticGestureController>(
+            view_->CreateSyntheticGestureTarget(),
+            base::Bind(
+                &RenderWidgetHostImpl::RequestBeginFrameForSynthesizedInput,
+                base::Unretained(this)));
   }
   if (synthetic_gesture_controller_) {
     synthetic_gesture_controller_->QueueSyntheticGesture(
         std::move(synthetic_gesture), on_complete);
   }
 }
 
 void RenderWidgetHostImpl::SetCursor(const WebCursor& cursor) {
   if (!view_)
     return;
@@ skipping 524 matching lines @@
                    weak_factory_.GetWeakPtr(), sequence_number),
         base::TimeDelta::FromSecondsD(1. / 6));
 #else
     WindowSnapshotReachedScreen(sequence_number);
 #endif
   }
 
   latency_tracker_.OnGpuSwapBuffersCompleted(latency_info);
 }
 
+void RenderWidgetHostImpl::RequestBeginFrameForSynthesizedInput(
+    base::OnceClosure begin_frame_callback) {
+  DCHECK(view_);
+  begin_frame_callback_ = std::move(begin_frame_callback);
+  view_->OnSetNeedsFlushInput();
+}
+
 void RenderWidgetHostImpl::OnRenderProcessGone(int status, int exit_code) {
   // RenderFrameHost owns a RenderWidgetHost when it needs one, in which case
   // it handles destruction.
   if (!owned_by_render_frame_host_) {
     // TODO(evanm): This synchronously ends up calling "delete this".
     // Is that really what we want in response to this message?  I'm matching
     // previous behavior of the code here.
     Destroy(true);
   } else {
     RendererExited(static_cast<base::TerminationStatus>(status), exit_code);
@@ skipping 333 matching lines @@
     if (ack_source == InputEventAckSource::MAIN_THREAD)
       RestartHangMonitorTimeoutIfNecessary();
   }
 }
 
 void RenderWidgetHostImpl::OnHasTouchEventHandlers(bool has_handlers) {
   has_touch_handler_ = has_handlers;
 }
 
 void RenderWidgetHostImpl::DidFlush() {
-  if (synthetic_gesture_controller_)
-    synthetic_gesture_controller_->OnDidFlushInput();
 }
 
 void RenderWidgetHostImpl::DidOverscroll(
     const ui::DidOverscrollParams& params) {
   if (view_)
     view_->DidOverscroll(params);
 }
 
 void RenderWidgetHostImpl::DidStopFlinging() {
   is_in_touchpad_gesture_fling_ = false;
@@ skipping 415 matching lines @@
   RenderProcessHost* rph = GetProcess();
   for (std::vector<IPC::Message>::const_iterator i = messages.begin();
        i != messages.end(); ++i) {
     rph->OnMessageReceived(*i);
     if (i->dispatch_error())
       rph->OnBadMessageReceived(*i);
   }
 }
 
 }  // namespace content