| OLD | NEW |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "content/browser/android/service_registry_android_impl.h" | 5 #include "content/browser/android/service_registry_android_impl.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/android/jni_android.h" | 9 #include "base/android/jni_android.h" |
| 10 #include "base/android/jni_string.h" | 10 #include "base/android/jni_string.h" |
| 11 #include "base/callback.h" | 11 #include "base/callback.h" |
| 12 #include "base/memory/ptr_util.h" | 12 #include "base/memory/ptr_util.h" |
| 13 #include "content/public/common/service_registry.h" | 13 #include "content/public/common/service_registry.h" |
| 14 #include "jni/ServiceRegistry_jni.h" | 14 #include "jni/ServiceRegistry_jni.h" |
| 15 #include "mojo/public/cpp/system/message_pipe.h" | 15 #include "mojo/public/cpp/system/message_pipe.h" |
| 16 #include "services/shell/public/cpp/interface_provider.h" |
| 17 #include "services/shell/public/cpp/interface_registry.h" |
| 16 | 18 |
| 17 using base::android::AttachCurrentThread; | 19 using base::android::AttachCurrentThread; |
| 18 using base::android::ConvertJavaStringToUTF8; | 20 using base::android::ConvertJavaStringToUTF8; |
| 19 using base::android::ScopedJavaGlobalRef; | 21 using base::android::ScopedJavaGlobalRef; |
| 20 | 22 |
| 21 namespace content { | 23 namespace content { |
| 22 | 24 |
| 23 namespace { | 25 namespace { |
| 24 | 26 |
| 25 // Callback passed to the wrapped ServiceRegistry upon AddService(). The | 27 // Callback passed to the wrapped ServiceRegistry upon AddService(). The |
| 26 // ServiceRegistry will call it to create a registered Java service | 28 // ServiceRegistry will call it to create a registered Java service |
| 27 void CreateImplAndAttach( | 29 void CreateImplAndAttach( |
| 28 const ScopedJavaGlobalRef<jobject>& j_scoped_service_registry, | 30 const ScopedJavaGlobalRef<jobject>& j_scoped_service_registry, |
| 29 const ScopedJavaGlobalRef<jobject>& j_scoped_manager, | 31 const ScopedJavaGlobalRef<jobject>& j_scoped_manager, |
| 30 const ScopedJavaGlobalRef<jobject>& j_scoped_factory, | 32 const ScopedJavaGlobalRef<jobject>& j_scoped_factory, |
| 31 mojo::ScopedMessagePipeHandle handle) { | 33 mojo::ScopedMessagePipeHandle handle) { |
| 32 JNIEnv* env = AttachCurrentThread(); | 34 JNIEnv* env = AttachCurrentThread(); |
| 33 Java_ServiceRegistry_createImplAndAttach( | 35 Java_ServiceRegistry_createImplAndAttach( |
| 34 env, j_scoped_service_registry.obj(), handle.release().value(), | 36 env, j_scoped_service_registry.obj(), handle.release().value(), |
| 35 j_scoped_manager.obj(), j_scoped_factory.obj()); | 37 j_scoped_manager.obj(), j_scoped_factory.obj()); |
| 36 } | 38 } |
| 37 | 39 |
| 38 } // namespace | 40 } // namespace |
| 39 | 41 |
| 40 // static | 42 // static |
| 41 std::unique_ptr<ServiceRegistryAndroid> ServiceRegistryAndroid::Create( | 43 std::unique_ptr<ServiceRegistryAndroid> ServiceRegistryAndroid::Create( |
| 42 ServiceRegistry* registry) { | 44 shell::InterfaceRegistry* interface_registry, |
| 43 return base::WrapUnique(new ServiceRegistryAndroidImpl(registry)); | 45 shell::InterfaceProvider* remote_interfaces) { |
| 46 return base::WrapUnique(new ServiceRegistryAndroidImpl( |
| 47 interface_registry, remote_interfaces)); |
| 44 } | 48 } |
| 45 | 49 |
| 46 // static | 50 // static |
| 51 std::unique_ptr<ServiceRegistryAndroid> ServiceRegistryAndroid::Create( |
| 52 ServiceRegistry* service_registry) { |
| 53 return base::WrapUnique(new ServiceRegistryAndroidImpl(service_registry)); |
| 54 } |
| 55 |
| 56 // static |
| 47 bool ServiceRegistryAndroidImpl::Register(JNIEnv* env) { | 57 bool ServiceRegistryAndroidImpl::Register(JNIEnv* env) { |
| 48 return RegisterNativesImpl(env); | 58 return RegisterNativesImpl(env); |
| 49 } | 59 } |
| 50 | 60 |
| 51 ServiceRegistryAndroidImpl::~ServiceRegistryAndroidImpl() { | 61 ServiceRegistryAndroidImpl::~ServiceRegistryAndroidImpl() { |
| 52 Java_ServiceRegistry_destroy(AttachCurrentThread(), obj_.obj()); | 62 Java_ServiceRegistry_destroy(AttachCurrentThread(), obj_.obj()); |
| 53 } | 63 } |
| 54 | 64 |
| 55 // Constructor and destructor call into Java. | 65 // Constructor and destructor call into Java. |
| 56 ServiceRegistryAndroidImpl::ServiceRegistryAndroidImpl( | 66 ServiceRegistryAndroidImpl::ServiceRegistryAndroidImpl( |
| 67 shell::InterfaceRegistry* interface_registry, |
| 68 shell::InterfaceProvider* remote_interfaces) |
| 69 : interface_registry_(interface_registry), |
| 70 remote_interfaces_(remote_interfaces) { |
| 71 JNIEnv* env = AttachCurrentThread(); |
| 72 obj_.Reset( |
| 73 env, |
| 74 Java_ServiceRegistry_create(env, reinterpret_cast<intptr_t>(this)).obj()); |
| 75 } |
| 76 |
| 77 ServiceRegistryAndroidImpl::ServiceRegistryAndroidImpl( |
| 57 ServiceRegistry* service_registry) | 78 ServiceRegistry* service_registry) |
| 58 : service_registry_(service_registry) { | 79 : service_registry_(service_registry) { |
| 59 JNIEnv* env = AttachCurrentThread(); | 80 JNIEnv* env = AttachCurrentThread(); |
| 60 obj_.Reset( | 81 obj_.Reset( |
| 61 env, | 82 env, |
| 62 Java_ServiceRegistry_create(env, reinterpret_cast<intptr_t>(this)).obj()); | 83 Java_ServiceRegistry_create(env, reinterpret_cast<intptr_t>(this)).obj()); |
| 63 } | 84 } |
| 64 | 85 |
| 86 |
| 65 const base::android::ScopedJavaGlobalRef<jobject>& | 87 const base::android::ScopedJavaGlobalRef<jobject>& |
| 66 ServiceRegistryAndroidImpl::GetObj() { | 88 ServiceRegistryAndroidImpl::GetObj() { |
| 67 return obj_; | 89 return obj_; |
| 68 } | 90 } |
| 69 | 91 |
| 70 // Methods called from Java. | 92 // Methods called from Java. |
| 71 void ServiceRegistryAndroidImpl::AddService( | 93 void ServiceRegistryAndroidImpl::AddService( |
| 72 JNIEnv* env, | 94 JNIEnv* env, |
| 73 const JavaParamRef<jobject>& j_service_registry, | 95 const JavaParamRef<jobject>& j_service_registry, |
| 74 const JavaParamRef<jobject>& j_manager, | 96 const JavaParamRef<jobject>& j_manager, |
| 75 const JavaParamRef<jobject>& j_factory, | 97 const JavaParamRef<jobject>& j_factory, |
| 76 const JavaParamRef<jstring>& j_name) { | 98 const JavaParamRef<jstring>& j_name) { |
| 77 std::string name(ConvertJavaStringToUTF8(env, j_name)); | 99 std::string name(ConvertJavaStringToUTF8(env, j_name)); |
| 78 | 100 |
| 79 ScopedJavaGlobalRef<jobject> j_scoped_service_registry; | 101 ScopedJavaGlobalRef<jobject> j_scoped_service_registry; |
| 80 j_scoped_service_registry.Reset(env, j_service_registry); | 102 j_scoped_service_registry.Reset(env, j_service_registry); |
| 81 | 103 |
| 82 ScopedJavaGlobalRef<jobject> j_scoped_manager; | 104 ScopedJavaGlobalRef<jobject> j_scoped_manager; |
| 83 j_scoped_manager.Reset(env, j_manager); | 105 j_scoped_manager.Reset(env, j_manager); |
| 84 | 106 |
| 85 ScopedJavaGlobalRef<jobject> j_scoped_factory; | 107 ScopedJavaGlobalRef<jobject> j_scoped_factory; |
| 86 j_scoped_factory.Reset(env, j_factory); | 108 j_scoped_factory.Reset(env, j_factory); |
| 87 | 109 |
| 88 service_registry_->AddService( | 110 if (interface_registry_) { |
| 89 name, base::Bind(&CreateImplAndAttach, j_scoped_service_registry, | 111 interface_registry_->AddInterface( |
| 90 j_scoped_manager, j_scoped_factory), | 112 name, base::Bind(&CreateImplAndAttach, j_scoped_service_registry, |
| 91 nullptr); | 113 j_scoped_manager, j_scoped_factory), |
| 114 nullptr); |
| 115 } else if (service_registry_) { |
| 116 service_registry_->AddService( |
| 117 name, base::Bind(&CreateImplAndAttach, j_scoped_service_registry, |
| 118 j_scoped_manager, j_scoped_factory), |
| 119 nullptr); |
| 120 } else { |
| 121 NOTREACHED(); |
| 122 } |
| 92 } | 123 } |
| 93 | 124 |
| 94 void ServiceRegistryAndroidImpl::RemoveService( | 125 void ServiceRegistryAndroidImpl::RemoveService( |
| 95 JNIEnv* env, | 126 JNIEnv* env, |
| 96 const JavaParamRef<jobject>& j_service_registry, | 127 const JavaParamRef<jobject>& j_service_registry, |
| 97 const JavaParamRef<jstring>& j_name) { | 128 const JavaParamRef<jstring>& j_name) { |
| 98 std::string name(ConvertJavaStringToUTF8(env, j_name)); | 129 std::string name(ConvertJavaStringToUTF8(env, j_name)); |
| 99 service_registry_->RemoveService(name); | 130 if (interface_registry_) |
| 131 interface_registry_->RemoveInterface(name); |
| 132 else if (service_registry_) |
| 133 service_registry_->RemoveService(name); |
| 134 else |
| 135 NOTREACHED(); |
| 100 } | 136 } |
| 101 | 137 |
| 102 void ServiceRegistryAndroidImpl::ConnectToRemoteService( | 138 void ServiceRegistryAndroidImpl::ConnectToRemoteService( |
| 103 JNIEnv* env, | 139 JNIEnv* env, |
| 104 const JavaParamRef<jobject>& j_service_registry, | 140 const JavaParamRef<jobject>& j_service_registry, |
| 105 const JavaParamRef<jstring>& j_name, | 141 const JavaParamRef<jstring>& j_name, |
| 106 jint j_handle) { | 142 jint j_handle) { |
| 107 std::string name(ConvertJavaStringToUTF8(env, j_name)); | 143 std::string name(ConvertJavaStringToUTF8(env, j_name)); |
| 108 mojo::ScopedMessagePipeHandle handle((mojo::MessagePipeHandle(j_handle))); | 144 mojo::ScopedMessagePipeHandle handle((mojo::MessagePipeHandle(j_handle))); |
| 109 service_registry_->ConnectToRemoteService(name, std::move(handle)); | 145 if (remote_interfaces_) |
| 146 remote_interfaces_->GetInterface(name, std::move(handle)); |
| 147 else if (service_registry_) |
| 148 service_registry_->ConnectToRemoteService(name, std::move(handle)); |
| 149 else |
| 150 NOTREACHED(); |
| 110 } | 151 } |
| 111 | 152 |
| 112 } // namespace content | 153 } // namespace content |
| OLD | NEW |