| 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>();
|
| +
|
| + 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();
|
| +}
|
|
|