Force events to be non blocking if main thread is unresponsive.

content/renderer/input/main_thread_event_queue.cc

 // Copyright 2016 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/main_thread_event_queue.h"
 
 #include "content/common/input/event_with_latency_info.h"
 #include "content/common/input_messages.h"
 
 namespace content {
@@ skipping 28 matching lines @@
     int routing_id,
     MainThreadEventQueueClient* client,
     const scoped_refptr<base::SingleThreadTaskRunner>& main_task_runner,
     blink::scheduler::RendererScheduler* renderer_scheduler)
     : routing_id_(routing_id),
       client_(client),
       is_flinging_(false),
       last_touch_start_forced_nonblocking_due_to_fling_(false),
       enable_fling_passive_listener_flag_(base::FeatureList::IsEnabled(
           features::kPassiveEventListenersDueToFling)),
+      enable_non_blocking_due_to_main_thread_responsiveness_flag_(
+          base::FeatureList::IsEnabled(
+              features::kMainThreadBusyScrollIntervention)),
       main_task_runner_(main_task_runner),
       renderer_scheduler_(renderer_scheduler) {}
 
 MainThreadEventQueue::~MainThreadEventQueue() {}
 
 bool MainThreadEventQueue::HandleEvent(
     ui::ScopedWebInputEvent event,
     const ui::LatencyInfo& latency,
     InputEventDispatchType original_dispatch_type,
     InputEventAckState ack_result) {
@@ skipping 25 matching lines @@
         touch_event->dispatchType == blink::WebInputEvent::Blocking) {
       // If the touch start is forced to be passive due to fling, its following
       // touch move should also be passive.
       if (is_flinging_ || last_touch_start_forced_nonblocking_due_to_fling_) {
         touch_event->dispatchType =
             blink::WebInputEvent::ListenersForcedNonBlockingDueToFling;
         non_blocking = true;
         last_touch_start_forced_nonblocking_due_to_fling_ = true;
       }
     }
+
+    if (enable_non_blocking_due_to_main_thread_responsiveness_flag_ &&
+        touch_event->dispatchType == blink::WebInputEvent::Blocking) {
+      bool passive_due_to_unresponsive_main =
+          renderer_scheduler_
+              ->ShouldForceEventsNonBlockingForUnresponsiveMainThread();
+      if (passive_due_to_unresponsive_main) {
+        touch_event->dispatchType = blink::WebInputEvent::
+            ListenersForcedNonBlockingDueToMainThreadResponsiveness;
+        non_blocking = true;
+      }
+    }
   }
   if (is_wheel && non_blocking) {
     // Adjust the |dispatchType| on the event since the compositor
     // determined all event listeners are passive.
     static_cast<blink::WebMouseWheelEvent*>(event.get())
         ->dispatchType = blink::WebInputEvent::ListenersNonBlockingPassive;
   }
 
   InputEventDispatchType dispatch_type =
       non_blocking ? DISPATCH_TYPE_NON_BLOCKING : DISPATCH_TYPE_BLOCKING;
@@ skipping 55 matching lines @@
     base::AutoLock lock(event_queue_lock_);
     size_t size_before = events_.size();
     events_.Queue(std::move(event));
     send_notification = events_.size() != size_before;
   }
   if (send_notification)
     SendEventNotificationToMainThread();
 }
 
 }  // namespace content