Provided batched input delivery with a BufferedInputRouter

content/browser/renderer_host/input/immediate_input_router.h

 // Copyright 2013 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.
 
 #ifndef CONTENT_BROWSER_RENDERER_HOST_INPUT_IMMEDIATE_INPUT_ROUTER_H_
 #define CONTENT_BROWSER_RENDERER_HOST_INPUT_IMMEDIATE_INPUT_ROUTER_H_
 
 #include <queue>
 
 #include "base/basictypes.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/time/time.h"
 #include "content/browser/renderer_host/input/input_router.h"
 #include "content/browser/renderer_host/input/touch_event_queue.h"
 #include "content/public/browser/native_web_keyboard_event.h"
 
 namespace ui {
 struct LatencyInfo;
 }
 
 namespace content {
 
 class GestureEventFilter;
+class InputAckHandler;
 class InputRouterClient;
 class RenderProcessHost;
 class RenderWidgetHostImpl;
 
 // A default implementation for browser input event routing. Input commands are
 // forwarded to the renderer immediately upon receipt.
 class CONTENT_EXPORT ImmediateInputRouter
     : public NON_EXPORTED_BASE(InputRouter),
       public NON_EXPORTED_BASE(TouchEventQueueClient) {
  public:
   ImmediateInputRouter(RenderProcessHost* process,
                        InputRouterClient* client,
+                       InputAckHandler* ack_handler,
                        int routing_id);
   virtual ~ImmediateInputRouter();
 
   // InputRouter
-  virtual bool SendInput(IPC::Message* message) OVERRIDE;
+  virtual void Flush() OVERRIDE;
+  virtual bool SendInput(scoped_ptr<IPC::Message> message) OVERRIDE;
   virtual void SendMouseEvent(
       const MouseEventWithLatencyInfo& mouse_event) OVERRIDE;
   virtual void SendWheelEvent(
       const MouseWheelEventWithLatencyInfo& wheel_event) OVERRIDE;
   virtual void SendKeyboardEvent(
       const NativeWebKeyboardEvent& key_event,
       const ui::LatencyInfo& latency_info) OVERRIDE;
   virtual void SendGestureEvent(
       const GestureEventWithLatencyInfo& gesture_event) OVERRIDE;
   virtual void SendTouchEvent(
@@ skipping 19 matching lines @@
 
   TouchEventQueue* touch_event_queue() {
     return touch_event_queue_.get();
   }
 
 private:
   // TouchEventQueueClient
   virtual void OnTouchEventAck(const TouchEventWithLatencyInfo& event,
                                InputEventAckState ack_result) OVERRIDE;
 
-  bool SendMoveCaret(IPC::Message* message);
-  bool SendSelectRange(IPC::Message* message);
+  bool SendMoveCaret(scoped_ptr<IPC::Message> message);
+  bool SendSelectRange(scoped_ptr<IPC::Message> message);
   bool Send(IPC::Message* message);
 
   // Transmits the given input event an as an IPC::Message. This is an internal
   // helper for |FilterAndSendInputEvent()| and should not be used otherwise.
   void SendWebInputEvent(const WebKit::WebInputEvent& input_event,
                          const ui::LatencyInfo& latency_info,
                          bool is_keyboard_shortcut);
 
   // Filters and forwards the given WebInputEvent to |SendWebInputEvent()|. This
   // is an internal helper for |Send*Event()| and should not be used otherwise.
@@ skipping 33 matching lines @@
   // This can result in a gesture event being generated and sent back to the
   // renderer.
   void ProcessTouchAck(InputEventAckState ack_result,
                        const ui::LatencyInfo& latency_info);
 
   int routing_id() const { return routing_id_; }
 
 
   RenderProcessHost* process_;
   InputRouterClient* client_;
+  InputAckHandler* ack_handler_;
   int routing_id_;
 
   // (Similar to |mouse_move_pending_|.) True while waiting for SelectRange_ACK.
   bool select_range_pending_;
 
   // (Similar to |next_mouse_move_|.) The next SelectRange to send, if any.
   scoped_ptr<IPC::Message> next_selection_range_;
 
   // (Similar to |mouse_move_pending_|.) True while waiting for MoveCaret_ACK.
   bool move_caret_pending_;
@@ skipping 43 matching lines @@
 
   scoped_ptr<TouchEventQueue> touch_event_queue_;
   scoped_ptr<GestureEventFilter> gesture_event_filter_;
 
   DISALLOW_COPY_AND_ASSIGN(ImmediateInputRouter);
 };
 
 }  // namespace content
 
 #endif // CONTENT_BROWSER_RENDERER_HOST_INPUT_IMMEDIATE_INPUT_ROUTER_H_