Chromium Code Reviews| Index: android_webview/java/src/org/chromium/android_webview/AwMessagePortService.java |
| diff --git a/android_webview/java/src/org/chromium/android_webview/AwMessagePortService.java b/android_webview/java/src/org/chromium/android_webview/AwMessagePortService.java |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..a1f9c4ba65e0682e2511b9dd8d7f5210d36aa610 |
| --- /dev/null |
| +++ b/android_webview/java/src/org/chromium/android_webview/AwMessagePortService.java |
| @@ -0,0 +1,69 @@ |
| +// 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. |
| + |
| +package org.chromium.android_webview; |
| + |
| +import android.util.SparseArray; |
| +import android.webkit.ValueCallback; |
| + |
| +import org.chromium.base.CalledByNative; |
| +import org.chromium.base.JNINamespace; |
| + |
| +/** |
| + * Provides the Message Channel functionality for Android Webview. Specifically |
| + * manages the message ports that are associated with a message channel and |
| + * handles posting/receiving messages to/from them. |
| + * See https://html.spec.whatwg.org/multipage/comms.html#messagechannel for |
| + * further information on message channels. |
| + * |
| + * The message ports have unique IDs. In Android webview implementation, |
| + * the message ports are only known by their IDs at the native side. |
| + * At the java side, the embedder deals with MessagePort objects. The mapping |
| + * from an ID to an object is in AwMessagePortService. AwMessagePortService |
| + * keeps a strong ref to MessagePort objects until they are closed. |
| + * |
| + * Ownership: The Java AwMessagePortService is owned by Java AwBrowserContext. |
| + * The native AwMessagePortService is owned by native AwBrowserContext. The |
| + * native peer maintains a weak ref to the java object and deregisters itself |
| + * before being deleted. |
| + */ |
| +@JNINamespace("android_webview") |
| +public class AwMessagePortService { |
| + |
| + private static final String TAG = "AwMessagePortService"; |
| + private long mNativeMessagePortService; |
| + private SparseArray<MessagePort> mMessagePorts = new SparseArray<MessagePort>(); |
|
mnaganov (inactive)
2015/01/07 11:43:54
This class is only used on UI thread, right? It's
sgurun-gerrit only
2015/01/10 02:36:29
yes, good point. clarified on class documentation
|
| + |
| + AwMessagePortService() { |
| + mNativeMessagePortService = nativeInitAwMessagePortService(); |
| + } |
| + |
| + private MessagePort addPort(int portId) { |
| + if (mMessagePorts.get(portId) != null) { |
| + throw new IllegalStateException("Port already exists"); |
| + } |
| + MessagePort m = new MessagePort(portId); |
| + mMessagePorts.put(portId, m); |
| + return m; |
| + } |
| + |
| + @CalledByNative |
| + private void onMessageChannelCreated(int portId1, int portId2, |
| + ValueCallback<MessageChannel> callback) { |
| + callback.onReceiveValue(new MessageChannel(addPort(portId1), addPort(portId2))); |
| + } |
| + |
| + |
| + @CalledByNative |
| + private void onPostMessage(int portId, String message, int[] ports) { |
| + mMessagePorts.get(portId).onMessage(message); |
| + } |
| + |
| + @CalledByNative |
| + private void unregisterNativeAwMessagePortService() { |
| + mNativeMessagePortService = 0; |
| + } |
| + |
| + private native long nativeInitAwMessagePortService(); |
| +} |