Add UMA metric for tracking listeners for blocking touch while fling is happening

content/renderer/input/input_event_filter.cc

 // 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.
 
 #include "content/renderer/input/input_event_filter.h"
 
 #include <utility>
 
 #include "base/auto_reset.h"
 #include "base/bind.h"
@@ skipping 32 matching lines @@
 namespace content {
 
 InputEventFilter::InputEventFilter(
     const base::Callback<void(const IPC::Message&)>& main_listener,
     const scoped_refptr<base::SingleThreadTaskRunner>& main_task_runner,
     const scoped_refptr<base::SingleThreadTaskRunner>& target_task_runner)
     : main_task_runner_(main_task_runner),
       main_listener_(main_listener),
       sender_(NULL),
       target_task_runner_(target_task_runner),
-      current_overscroll_params_(NULL) {
+      current_overscroll_params_(NULL),
+      is_flinging_on_main_(false),
+      is_flinging_on_impl_(false) {
   DCHECK(target_task_runner_.get());
 }
 
 void InputEventFilter::SetBoundHandler(const Handler& handler) {
   DCHECK(main_task_runner_->BelongsToCurrentThread());
   handler_ = handler;
 }
 
 void InputEventFilter::DidAddInputHandler(int routing_id) {
   base::AutoLock locked(routes_lock_);
@@ skipping 12 matching lines @@
   if (current_overscroll_params_) {
     current_overscroll_params_->reset(new DidOverscrollParams(params));
     return;
   }
 
   SendMessage(std::unique_ptr<IPC::Message>(
       new InputHostMsg_DidOverscroll(routing_id, params)));
 }
 
 void InputEventFilter::DidStopFlinging(int routing_id) {
+  is_flinging_on_main_ = false;
+  is_flinging_on_impl_ = false;
   SendMessage(base::WrapUnique(new InputHostMsg_DidStopFlinging(routing_id)));
 }
 
+void InputEventFilter::DidStartFlinging(bool is_on_impl) {
+  if (is_on_impl)
+    is_flinging_on_impl_ = true;
+  else
+    is_flinging_on_main_ = true;
+}
+
 void InputEventFilter::NotifyInputEventHandled(
     int routing_id,
     blink::WebInputEvent::Type type) {
   DCHECK(target_task_runner_->BelongsToCurrentThread());
   RouteQueueMap::iterator iter = route_queues_.find(routing_id);
   if (iter == route_queues_.end() || !iter->second)
     return;
 
   iter->second->EventHandled(type);
 }
@@ skipping 77 matching lines @@
       auto_reset_current_overscroll_params(
           &current_overscroll_params_, send_ack ? &overscroll_params : NULL);
 
   InputEventAckState ack_state = handler_.Run(routing_id, event, &latency_info);
 
   if (ack_state == INPUT_EVENT_ACK_STATE_SET_NON_BLOCKING ||
       ack_state == INPUT_EVENT_ACK_STATE_NOT_CONSUMED) {
     DCHECK(!overscroll_params);
     RouteQueueMap::iterator iter = route_queues_.find(routing_id);
     if (iter != route_queues_.end())
-      send_ack &= iter->second->HandleEvent(event, latency_info, dispatch_type,
-                                            ack_state);
+      send_ack &= iter->second->HandleEvent(
+          event, latency_info, dispatch_type, ack_state,
+          (is_flinging_on_main_ || is_flinging_on_impl_));
   }
 
   if (!send_ack)
     return;
 
   InputEventAck ack(event->type, ack_state, latency_info,
                     std::move(overscroll_params),
                     WebInputEventTraits::GetUniqueTouchEventId(*event));
   SendMessage(std::unique_ptr<IPC::Message>(
       new InputHostMsg_HandleInputEvent_ACK(routing_id, ack)));
@@ skipping 24 matching lines @@
     InputEventDispatchType dispatch_type) {
   TRACE_EVENT_INSTANT0(
       "input", "InputEventFilter::ForwardToHandler::SendEventToMainThread",
       TRACE_EVENT_SCOPE_THREAD);
   IPC::Message new_msg =
       InputMsg_HandleInputEvent(routing_id, event, latency_info, dispatch_type);
   main_task_runner_->PostTask(FROM_HERE, base::Bind(main_listener_, new_msg));
 }
 
 }  // namespace content