[Android] Move content/browser/{renderer_host => android}/java/*

content/browser/renderer_host/java/gin_java_bridge_dispatcher_host.cc

Index: content/browser/renderer_host/java/gin_java_bridge_dispatcher_host.cc
diff --git a/content/browser/renderer_host/java/gin_java_bridge_dispatcher_host.cc b/content/browser/renderer_host/java/gin_java_bridge_dispatcher_host.cc
deleted file mode 100644
index 6c6e86b75e0867c75e355655d21e553230dd1c24..0000000000000000000000000000000000000000
--- a/content/browser/renderer_host/java/gin_java_bridge_dispatcher_host.cc
+++ /dev/null
@@ -1,497 +0,0 @@
-// Copyright 2014 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/java/gin_java_bridge_dispatcher_host.h"
-
-#include "base/android/java_handler_thread.h"
-#include "base/android/jni_android.h"
-#include "base/android/scoped_java_ref.h"
-#include "base/lazy_instance.h"
-#include "base/strings/string_number_conversions.h"
-#include "base/strings/utf_string_conversions.h"
-#include "base/task_runner_util.h"
-#include "content/browser/renderer_host/java/gin_java_bound_object_delegate.h"
-#include "content/browser/renderer_host/java/jni_helper.h"
-#include "content/common/android/gin_java_bridge_value.h"
-#include "content/common/android/hash_set.h"
-#include "content/common/gin_java_bridge_messages.h"
-#include "content/public/browser/browser_thread.h"
-#include "content/public/browser/render_frame_host.h"
-#include "ipc/ipc_message_utils.h"
-
-#if !defined(OS_ANDROID)
-#error "JavaBridge only supports OS_ANDROID"
-#endif
-
-namespace content {
-
-namespace {
-// The JavaBridge needs to use a Java thread so the callback
-// will happen on a thread with a prepared Looper.
-class JavaBridgeThread : public base::android::JavaHandlerThread {
- public:
-  JavaBridgeThread() : base::android::JavaHandlerThread("JavaBridge") {
-    Start();
-  }
-  virtual ~JavaBridgeThread() {
-    Stop();
-  }
-};
-
-base::LazyInstance<JavaBridgeThread> g_background_thread =
-    LAZY_INSTANCE_INITIALIZER;
-
-}  // namespace
-
-GinJavaBridgeDispatcherHost::GinJavaBridgeDispatcherHost(
-    WebContents* web_contents,
-    jobject retained_object_set)
-    : WebContentsObserver(web_contents),
-      retained_object_set_(base::android::AttachCurrentThread(),
-                           retained_object_set),
-      allow_object_contents_inspection_(true) {
-  DCHECK(retained_object_set);
-}
-
-GinJavaBridgeDispatcherHost::~GinJavaBridgeDispatcherHost() {
-}
-
-void GinJavaBridgeDispatcherHost::RenderFrameCreated(
-    RenderFrameHost* render_frame_host) {
-  renderers_.insert(render_frame_host);
-  for (NamedObjectMap::const_iterator iter = named_objects_.begin();
-       iter != named_objects_.end();
-       ++iter) {
-    render_frame_host->Send(new GinJavaBridgeMsg_AddNamedObject(
-        render_frame_host->GetRoutingID(), iter->first, iter->second));
-  }
-}
-
-void GinJavaBridgeDispatcherHost::RenderFrameDeleted(
-    RenderFrameHost* render_frame_host) {
-  renderers_.erase(render_frame_host);
-  RemoveHolder(render_frame_host,
-               GinJavaBoundObject::ObjectMap::iterator(&objects_),
-               objects_.size());
-}
-
-GinJavaBoundObject::ObjectID GinJavaBridgeDispatcherHost::AddObject(
-    const base::android::JavaRef<jobject>& object,
-    const base::android::JavaRef<jclass>& safe_annotation_clazz,
-    bool is_named,
-    RenderFrameHost* holder) {
-  DCHECK(is_named || holder);
-  GinJavaBoundObject::ObjectID object_id;
-  JNIEnv* env = base::android::AttachCurrentThread();
-  JavaObjectWeakGlobalRef ref(env, object.obj());
-  if (is_named) {
-    object_id = objects_.Add(new scoped_refptr<GinJavaBoundObject>(
-        GinJavaBoundObject::CreateNamed(ref, safe_annotation_clazz)));
-  } else {
-    object_id = objects_.Add(new scoped_refptr<GinJavaBoundObject>(
-        GinJavaBoundObject::CreateTransient(
-            ref, safe_annotation_clazz, holder)));
-  }
-#if DCHECK_IS_ON
-  {
-    GinJavaBoundObject::ObjectID added_object_id;
-    DCHECK(FindObjectId(object, &added_object_id));
-    DCHECK_EQ(object_id, added_object_id);
-  }
-#endif  // DCHECK_IS_ON
-  base::android::ScopedJavaLocalRef<jobject> retained_object_set =
-        retained_object_set_.get(env);
-  if (!retained_object_set.is_null()) {
-    JNI_Java_HashSet_add(env, retained_object_set, object);
-  }
-  return object_id;
-}
-
-bool GinJavaBridgeDispatcherHost::FindObjectId(
-    const base::android::JavaRef<jobject>& object,
-    GinJavaBoundObject::ObjectID* object_id) {
-  JNIEnv* env = base::android::AttachCurrentThread();
-  for (GinJavaBoundObject::ObjectMap::iterator it(&objects_); !it.IsAtEnd();
-       it.Advance()) {
-    if (env->IsSameObject(
-            object.obj(),
-            it.GetCurrentValue()->get()->GetLocalRef(env).obj())) {
-      *object_id = it.GetCurrentKey();
-      return true;
-    }
-  }
-  return false;
-}
-
-JavaObjectWeakGlobalRef GinJavaBridgeDispatcherHost::GetObjectWeakRef(
-    GinJavaBoundObject::ObjectID object_id) {
-  scoped_refptr<GinJavaBoundObject>* result = objects_.Lookup(object_id);
-  scoped_refptr<GinJavaBoundObject> object(result ? *result : NULL);
-  if (object.get())
-    return object->GetWeakRef();
-  else
-    return JavaObjectWeakGlobalRef();
-}
-
-void GinJavaBridgeDispatcherHost::RemoveHolder(
-    RenderFrameHost* holder,
-    const GinJavaBoundObject::ObjectMap::iterator& from,
-    size_t count) {
-  JNIEnv* env = base::android::AttachCurrentThread();
-  base::android::ScopedJavaLocalRef<jobject> retained_object_set =
-      retained_object_set_.get(env);
-  size_t i = 0;
-  for (GinJavaBoundObject::ObjectMap::iterator it(from);
-       !it.IsAtEnd() && i < count;
-       it.Advance(), ++i) {
-    scoped_refptr<GinJavaBoundObject> object(*it.GetCurrentValue());
-    if (object->IsNamed())
-      continue;
-    object->RemoveHolder(holder);
-    if (!object->HasHolders()) {
-      if (!retained_object_set.is_null()) {
-        JNI_Java_HashSet_remove(
-            env, retained_object_set, object->GetLocalRef(env));
-      }
-      objects_.Remove(it.GetCurrentKey());
-    }
-  }
-}
-
-void GinJavaBridgeDispatcherHost::AddNamedObject(
-    const std::string& name,
-    const base::android::JavaRef<jobject>& object,
-    const base::android::JavaRef<jclass>& safe_annotation_clazz) {
-  DCHECK_CURRENTLY_ON(BrowserThread::UI);
-  GinJavaBoundObject::ObjectID object_id;
-  NamedObjectMap::iterator iter = named_objects_.find(name);
-  bool existing_object = FindObjectId(object, &object_id);
-  if (existing_object && iter != named_objects_.end() &&
-      iter->second == object_id) {
-    // Nothing to do.
-    return;
-  }
-  if (iter != named_objects_.end()) {
-    RemoveNamedObject(iter->first);
-  }
-  if (existing_object) {
-    (*objects_.Lookup(object_id))->AddName();
-  } else {
-    object_id = AddObject(object, safe_annotation_clazz, true, NULL);
-  }
-  named_objects_[name] = object_id;
-
-  for (RendererSet::iterator iter = renderers_.begin();
-      iter != renderers_.end(); ++iter) {
-    (*iter)->Send(new GinJavaBridgeMsg_AddNamedObject(
-        (*iter)->GetRoutingID(), name, object_id));
-  }
-}
-
-void GinJavaBridgeDispatcherHost::RemoveNamedObject(
-    const std::string& name) {
-  DCHECK_CURRENTLY_ON(BrowserThread::UI);
-  NamedObjectMap::iterator iter = named_objects_.find(name);
-  if (iter == named_objects_.end())
-    return;
-
-  scoped_refptr<GinJavaBoundObject> object(*objects_.Lookup(iter->second));
-  named_objects_.erase(iter);
-  object->RemoveName();
-
-  // Not erasing from the objects map, as we can still receive method
-  // invocation requests for this object, and they should work until the
-  // java object is gone.
-  if (!object->IsNamed()) {
-    JNIEnv* env = base::android::AttachCurrentThread();
-    base::android::ScopedJavaLocalRef<jobject> retained_object_set =
-        retained_object_set_.get(env);
-    if (!retained_object_set.is_null()) {
-      JNI_Java_HashSet_remove(
-          env, retained_object_set, object->GetLocalRef(env));
-    }
-  }
-
-  for (RendererSet::iterator iter = renderers_.begin();
-      iter != renderers_.end(); ++iter) {
-    (*iter)->Send(new GinJavaBridgeMsg_RemoveNamedObject(
-        (*iter)->GetRoutingID(), name));
-  }
-}
-
-void GinJavaBridgeDispatcherHost::SetAllowObjectContentsInspection(bool allow) {
-  allow_object_contents_inspection_ = allow;
-}
-
-void GinJavaBridgeDispatcherHost::DocumentAvailableInMainFrame() {
-  DCHECK_CURRENTLY_ON(BrowserThread::UI);
-  // Called when the window object has been cleared in the main frame.
-  // That means, all sub-frames have also been cleared, so only named
-  // objects survived.
-  JNIEnv* env = base::android::AttachCurrentThread();
-  base::android::ScopedJavaLocalRef<jobject> retained_object_set =
-      retained_object_set_.get(env);
-  if (!retained_object_set.is_null()) {
-    JNI_Java_HashSet_clear(env, retained_object_set);
-  }
-
-  // We also need to add back the named objects we have so far as they
-  // should survive navigations.
-  for (GinJavaBoundObject::ObjectMap::iterator it(&objects_); !it.IsAtEnd();
-       it.Advance()) {
-    scoped_refptr<GinJavaBoundObject> object(*it.GetCurrentValue());
-    if (object->IsNamed()) {
-      if (!retained_object_set.is_null()) {
-        JNI_Java_HashSet_add(
-            env, retained_object_set, object->GetLocalRef(env));
-      }
-    } else {
-      objects_.Remove(it.GetCurrentKey());
-    }
-  }
-}
-
-namespace {
-
-// TODO(mnaganov): Implement passing of a parameter into sync message handlers.
-class MessageForwarder : public IPC::Sender {
- public:
-  MessageForwarder(GinJavaBridgeDispatcherHost* gjbdh,
-                   RenderFrameHost* render_frame_host)
-      : gjbdh_(gjbdh), render_frame_host_(render_frame_host) {}
-  void OnGetMethods(GinJavaBoundObject::ObjectID object_id,
-                    IPC::Message* reply_msg) {
-    gjbdh_->OnGetMethods(render_frame_host_,
-                         object_id,
-                         reply_msg);
-  }
-  void OnHasMethod(GinJavaBoundObject::ObjectID object_id,
-                   const std::string& method_name,
-                   IPC::Message* reply_msg) {
-    gjbdh_->OnHasMethod(render_frame_host_,
-                        object_id,
-                        method_name,
-                        reply_msg);
-  }
-  void OnInvokeMethod(GinJavaBoundObject::ObjectID object_id,
-                      const std::string& method_name,
-                      const base::ListValue& arguments,
-                      IPC::Message* reply_msg) {
-    gjbdh_->OnInvokeMethod(render_frame_host_,
-                           object_id,
-                           method_name,
-                           arguments,
-                           reply_msg);
-  }
-  virtual bool Send(IPC::Message* msg) OVERRIDE {
-    NOTREACHED();
-    return false;
-  }
- private:
-  GinJavaBridgeDispatcherHost* gjbdh_;
-  RenderFrameHost* render_frame_host_;
-};
-
-}
-
-bool GinJavaBridgeDispatcherHost::OnMessageReceived(
-    const IPC::Message& message,
-    RenderFrameHost* render_frame_host) {
-  DCHECK(render_frame_host);
-  bool handled = true;
-  MessageForwarder forwarder(this, render_frame_host);
-  IPC_BEGIN_MESSAGE_MAP_WITH_PARAM(GinJavaBridgeDispatcherHost, message,
-                                   render_frame_host)
-    IPC_MESSAGE_FORWARD_DELAY_REPLY(GinJavaBridgeHostMsg_GetMethods,
-                                    &forwarder,
-                                    MessageForwarder::OnGetMethods)
-    IPC_MESSAGE_FORWARD_DELAY_REPLY(GinJavaBridgeHostMsg_HasMethod,
-                                    &forwarder,
-                                    MessageForwarder::OnHasMethod)
-    IPC_MESSAGE_FORWARD_DELAY_REPLY(GinJavaBridgeHostMsg_InvokeMethod,
-                                    &forwarder,
-                                    MessageForwarder::OnInvokeMethod)
-    IPC_MESSAGE_HANDLER(GinJavaBridgeHostMsg_ObjectWrapperDeleted,
-                        OnObjectWrapperDeleted)
-    IPC_MESSAGE_UNHANDLED(handled = false)
-  IPC_END_MESSAGE_MAP()
-  return handled;
-}
-
-void GinJavaBridgeDispatcherHost::SendReply(
-    RenderFrameHost* render_frame_host,
-    IPC::Message* reply_msg) {
-  DCHECK_CURRENTLY_ON(BrowserThread::UI);
-  if (renderers_.find(render_frame_host) != renderers_.end()) {
-    render_frame_host->Send(reply_msg);
-  } else {
-    delete reply_msg;
-  }
-}
-
-void GinJavaBridgeDispatcherHost::OnGetMethods(
-    RenderFrameHost* render_frame_host,
-    GinJavaBoundObject::ObjectID object_id,
-    IPC::Message* reply_msg) {
-  DCHECK_CURRENTLY_ON(BrowserThread::UI);
-  DCHECK(render_frame_host);
-  if (!allow_object_contents_inspection_) {
-    IPC::WriteParam(reply_msg, std::set<std::string>());
-    render_frame_host->Send(reply_msg);
-    return;
-  }
-  scoped_refptr<GinJavaBoundObject> object(*objects_.Lookup(object_id));
-  if (!object) {
-    LOG(ERROR) << "WebView: Unknown object: " << object_id;
-    IPC::WriteParam(reply_msg, std::set<std::string>());
-    render_frame_host->Send(reply_msg);
-    return;
-  }
-  base::PostTaskAndReplyWithResult(
-      g_background_thread.Get().message_loop()->message_loop_proxy(),
-      FROM_HERE,
-      base::Bind(&GinJavaBoundObject::GetMethodNames, object),
-      base::Bind(&GinJavaBridgeDispatcherHost::SendMethods,
-                 AsWeakPtr(),
-                 render_frame_host,
-                 reply_msg));
-}
-
-void GinJavaBridgeDispatcherHost::SendMethods(
-    RenderFrameHost* render_frame_host,
-    IPC::Message* reply_msg,
-    const std::set<std::string>& method_names) {
-  IPC::WriteParam(reply_msg, method_names);
-  SendReply(render_frame_host, reply_msg);
-}
-
-void GinJavaBridgeDispatcherHost::OnHasMethod(
-    RenderFrameHost* render_frame_host,
-    GinJavaBoundObject::ObjectID object_id,
-    const std::string& method_name,
-    IPC::Message* reply_msg) {
-  DCHECK_CURRENTLY_ON(BrowserThread::UI);
-  DCHECK(render_frame_host);
-  scoped_refptr<GinJavaBoundObject> object(*objects_.Lookup(object_id));
-  if (!object) {
-    LOG(ERROR) << "WebView: Unknown object: " << object_id;
-    IPC::WriteParam(reply_msg, false);
-    render_frame_host->Send(reply_msg);
-    return;
-  }
-  base::PostTaskAndReplyWithResult(
-      g_background_thread.Get().message_loop()->message_loop_proxy(),
-      FROM_HERE,
-      base::Bind(&GinJavaBoundObject::HasMethod, object, method_name),
-      base::Bind(&GinJavaBridgeDispatcherHost::SendHasMethodReply,
-                 AsWeakPtr(),
-                 render_frame_host,
-                 reply_msg));
-}
-
-void GinJavaBridgeDispatcherHost::SendHasMethodReply(
-    RenderFrameHost* render_frame_host,
-    IPC::Message* reply_msg,
-    bool result) {
-  IPC::WriteParam(reply_msg, result);
-  SendReply(render_frame_host, reply_msg);
-}
-
-void GinJavaBridgeDispatcherHost::OnInvokeMethod(
-    RenderFrameHost* render_frame_host,
-    GinJavaBoundObject::ObjectID object_id,
-    const std::string& method_name,
-    const base::ListValue& arguments,
-    IPC::Message* reply_msg) {
-  DCHECK_CURRENTLY_ON(BrowserThread::UI);
-  DCHECK(render_frame_host);
-  scoped_refptr<GinJavaBoundObject> object(*objects_.Lookup(object_id));
-  if (!object) {
-    LOG(ERROR) << "WebView: Unknown object: " << object_id;
-    base::ListValue result;
-    result.Append(base::Value::CreateNullValue());
-    IPC::WriteParam(reply_msg, result);
-    IPC::WriteParam(reply_msg, kGinJavaBridgeUnknownObjectId);
-    render_frame_host->Send(reply_msg);
-    return;
-  }
-  scoped_refptr<GinJavaMethodInvocationHelper> result =
-      new GinJavaMethodInvocationHelper(
-          make_scoped_ptr(new GinJavaBoundObjectDelegate(object))
-              .PassAs<GinJavaMethodInvocationHelper::ObjectDelegate>(),
-          method_name,
-          arguments);
-  result->Init(this);
-  g_background_thread.Get()
-      .message_loop()
-      ->message_loop_proxy()
-      ->PostTaskAndReply(
-          FROM_HERE,
-          base::Bind(&GinJavaMethodInvocationHelper::Invoke, result),
-          base::Bind(
-              &GinJavaBridgeDispatcherHost::ProcessMethodInvocationResult,
-              AsWeakPtr(),
-              render_frame_host,
-              reply_msg,
-              result));
-}
-
-void GinJavaBridgeDispatcherHost::ProcessMethodInvocationResult(
-    RenderFrameHost* render_frame_host,
-    IPC::Message* reply_msg,
-    scoped_refptr<GinJavaMethodInvocationHelper> result) {
-  if (result->HoldsPrimitiveResult()) {
-    IPC::WriteParam(reply_msg, result->GetPrimitiveResult());
-    IPC::WriteParam(reply_msg, result->GetInvocationError());
-    SendReply(render_frame_host, reply_msg);
-  } else {
-    ProcessMethodInvocationObjectResult(render_frame_host, reply_msg, result);
-  }
-}
-
-void GinJavaBridgeDispatcherHost::ProcessMethodInvocationObjectResult(
-    RenderFrameHost* render_frame_host,
-    IPC::Message* reply_msg,
-    scoped_refptr<GinJavaMethodInvocationHelper> result) {
-  DCHECK_CURRENTLY_ON(BrowserThread::UI);
-  if (renderers_.find(render_frame_host) == renderers_.end()) {
-    delete reply_msg;
-    return;
-  }
-  base::ListValue wrapped_result;
-  if (!result->GetObjectResult().is_null()) {
-    GinJavaBoundObject::ObjectID returned_object_id;
-    if (FindObjectId(result->GetObjectResult(), &returned_object_id)) {
-      (*objects_.Lookup(returned_object_id))->AddHolder(render_frame_host);
-    } else {
-      returned_object_id = AddObject(result->GetObjectResult(),
-                                     result->GetSafeAnnotationClass(),
-                                     false,
-                                     render_frame_host);
-    }
-    wrapped_result.Append(
-        GinJavaBridgeValue::CreateObjectIDValue(returned_object_id).release());
-  } else {
-    wrapped_result.Append(base::Value::CreateNullValue());
-  }
-  IPC::WriteParam(reply_msg, wrapped_result);
-  IPC::WriteParam(reply_msg, result->GetInvocationError());
-  render_frame_host->Send(reply_msg);
-}
-
-void GinJavaBridgeDispatcherHost::OnObjectWrapperDeleted(
-    RenderFrameHost* render_frame_host,
-    GinJavaBoundObject::ObjectID object_id) {
-  DCHECK_CURRENTLY_ON(BrowserThread::UI);
-  DCHECK(render_frame_host);
-  if (objects_.Lookup(object_id)) {
-    GinJavaBoundObject::ObjectMap::iterator iter(&objects_);
-    while (!iter.IsAtEnd() && iter.GetCurrentKey() != object_id)
-      iter.Advance();
-    DCHECK(!iter.IsAtEnd());
-    RemoveHolder(render_frame_host, iter, 1);
-  }
-}
-
-}  // namespace content