Add Mojo API for Blink hit testing

content/renderer/input/frame_input_hit_test_impl.cc

Index: content/renderer/input/frame_input_hit_test_impl.cc
diff --git a/content/renderer/input/frame_input_hit_test_impl.cc b/content/renderer/input/frame_input_hit_test_impl.cc
new file mode 100644
index 0000000000000000000000000000000000000000..9570c39a0352e371ba1c416383f2d3c5c3add5d0
--- /dev/null
+++ b/content/renderer/input/frame_input_hit_test_impl.cc
@@ -0,0 +1,97 @@
+// Copyright 2017 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/frame_input_hit_test_impl.h"
+
+#include "base/bind.h"
+#include "base/debug/stack_trace.h"
+#include "base/logging.h"
+#include "content/renderer/render_widget.h"
+
+namespace content {
+
+FrameInputHitTestImpl::FrameInputHitTestImpl(
+    base::WeakPtr<RenderFrameImpl> render_frame,
+    viz::mojom::FrameInputHitTestRequest request)
+    : binding_(this),
+      render_frame_(render_frame),
+      input_event_queue_(render_frame->GetRenderWidget()->GetInputEventQueue()),
+      main_thread_task_runner_(base::ThreadTaskRunnerHandle::Get()),
+      weak_ptr_factory_(this)
+
+{
+  weak_this_ = weak_ptr_factory_.GetWeakPtr();
+  // If we have created an input event queue move the mojo request over to the
+  // compositor thread.
+  if (RenderThreadImpl::current()->compositor_task_runner() &&
+      input_event_queue_) {
+    // Mojo channel bound on compositor thread.
+    RenderThreadImpl::current()->compositor_task_runner()->PostTask(
+        FROM_HERE, base::BindOnce(&FrameInputHitTestImpl::BindNow,
+                                  base::Unretained(this), std::move(request)));
+  } else {
+    // Mojo channel bound on main thread.
+    BindNow(std::move(request));
+  }
+}
+
+FrameInputHitTestImpl::~FrameInputHitTestImpl() {}
+
+// static
+void FrameInputHitTestImpl::CreateMojoService(
+    base::WeakPtr<RenderFrameImpl> render_frame,
+    viz::mojom::FrameInputHitTestRequest request) {
+  DCHECK(render_frame);
+
+  // Owns itself. Will be deleted when message pipe is destroyed.
+  new FrameInputHitTestImpl(render_frame, std::move(request));
+}
+
+void FrameInputHitTestImpl::RunOnMainThread(base::OnceClosure closure) {
+  if (input_event_queue_) {
+    input_event_queue_->QueueClosure(std::move(closure));
+  } else {
+    std::move(closure).Run();
+  }
+}
+
+void FrameInputHitTestImpl::HitTestFrameAt(const gfx::Point& point,
+                                           HitTestFrameAtCallback callback) {
+  if (!main_thread_task_runner_->BelongsToCurrentThread()) {
+    RunOnMainThread(base::BindOnce(&FrameInputHitTestImpl::HitTestOnMainThread,
+                                   weak_this_, point, std::move(callback)));
+    return;
+  }
+  if (!render_frame_)
+    return;
+  HitTestOnMainThread(point, std::move(callback));
+}
+
+void FrameInputHitTestImpl::HitTestOnMainThread(
+    const gfx::Point& point,
+    HitTestFrameAtCallback callback) {
+  std::move(callback).Run(
+      render_frame_->GetRenderWidget()->HitTestFrameAt(point));
+}
+
+void FrameInputHitTestImpl::Release() {
+  if (!main_thread_task_runner_->BelongsToCurrentThread()) {
+    // Close the binding on the compositor thread first before telling the main
+    // thread to delete this object.
+    binding_.Close();
+    main_thread_task_runner_->PostTask(
+        FROM_HERE, base::Bind(&FrameInputHitTestImpl::Release, weak_this_));
+    return;
+  }
+  delete this;
+}
+
+void FrameInputHitTestImpl::BindNow(
+    viz::mojom::FrameInputHitTestRequest request) {
+  binding_.Bind(std::move(request));
+  binding_.set_connection_error_handler(
+      base::Bind(&FrameInputHitTestImpl::Release, base::Unretained(this)));
+}
+
+}  // namespace content