| Index: content/public/android/java/src/org/chromium/content/browser/AppWebMessagePort.java
|
| diff --git a/android_webview/java/src/org/chromium/android_webview/AwMessagePort.java b/content/public/android/java/src/org/chromium/content/browser/AppWebMessagePort.java
|
| similarity index 91%
|
| rename from android_webview/java/src/org/chromium/android_webview/AwMessagePort.java
|
| rename to content/public/android/java/src/org/chromium/content/browser/AppWebMessagePort.java
|
| index 97e4d4951c2c0a7ff41abf09e657fc7a216a71c1..8eb6a7032f8f0b9750726a37a8c999a843eddecb 100644
|
| --- a/android_webview/java/src/org/chromium/android_webview/AwMessagePort.java
|
| +++ b/content/public/android/java/src/org/chromium/content/browser/AppWebMessagePort.java
|
| @@ -2,12 +2,13 @@
|
| // 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;
|
| +package org.chromium.content.browser;
|
|
|
| import android.os.Handler;
|
| import android.os.Looper;
|
| import android.os.Message;
|
| -import android.util.Log;
|
| +
|
| +import org.chromium.base.Log;
|
|
|
| /**
|
| * Represents the MessageChannel MessagePort object. Inspired from
|
| @@ -69,14 +70,14 @@ import android.util.Log;
|
| * transferring data. As a return, it simplifies implementation and prevents hard
|
| * to debug, racy corner cases while receiving/sending data.
|
| */
|
| -public class AwMessagePort implements PostMessageSender.PostMessageSenderDelegate {
|
| +public class AppWebMessagePort implements PostMessageSender.PostMessageSenderDelegate {
|
|
|
| /**
|
| * The message callback for receiving messages. Called on UI thread or if
|
| * provided, on the handler that is provided.
|
| */
|
| public abstract static class MessageCallback {
|
| - public abstract void onMessage(String message, AwMessagePort[] sentPorts);
|
| + public abstract void onMessage(String message, AppWebMessagePort[] sentPorts);
|
| }
|
|
|
| private static final String TAG = "MessagePort";
|
| @@ -86,11 +87,12 @@ public class AwMessagePort implements PostMessageSender.PostMessageSenderDelegat
|
| private static final int POST_MESSAGE = 1;
|
|
|
| private static class PostMessageFromWeb {
|
| - public AwMessagePort port;
|
| + public AppWebMessagePort port;
|
| public String message;
|
| - public AwMessagePort[] sentPorts;
|
| + public AppWebMessagePort[] sentPorts;
|
|
|
| - public PostMessageFromWeb(AwMessagePort port, String message, AwMessagePort[] sentPorts) {
|
| + public PostMessageFromWeb(
|
| + AppWebMessagePort port, String message, AppWebMessagePort[] sentPorts) {
|
| this.port = port;
|
| this.message = message;
|
| this.sentPorts = sentPorts;
|
| @@ -120,7 +122,7 @@ public class AwMessagePort implements PostMessageSender.PostMessageSenderDelegat
|
|
|
| private int mPortId = PENDING;
|
| private MessageCallback mMessageCallback;
|
| - private AwMessagePortService mMessagePortService;
|
| + private AppWebMessagePortService mMessagePortService;
|
| private boolean mClosed;
|
| private boolean mTransferred;
|
| private boolean mStarted;
|
| @@ -129,7 +131,7 @@ public class AwMessagePort implements PostMessageSender.PostMessageSenderDelegat
|
| private MessageHandler mHandler;
|
| private final Object mLock = new Object();
|
|
|
| - public AwMessagePort(AwMessagePortService messagePortService) {
|
| + public AppWebMessagePort(AppWebMessagePortService messagePortService) {
|
| mMessagePortService = messagePortService;
|
| mPostMessageSender = new PostMessageSender(this, mMessagePortService);
|
| mMessagePortService.addObserver(mPostMessageSender);
|
| @@ -194,7 +196,7 @@ public class AwMessagePort implements PostMessageSender.PostMessageSenderDelegat
|
| }
|
|
|
| // Only called on IO thread.
|
| - public void onReceivedMessage(String message, AwMessagePort[] sentPorts) {
|
| + public void onReceivedMessage(String message, AppWebMessagePort[] sentPorts) {
|
| synchronized (mLock) {
|
| PostMessageFromWeb m = new PostMessageFromWeb(this, message, sentPorts);
|
| Handler handler = mHandler != null ? mHandler : sDefaultHandler;
|
| @@ -212,7 +214,7 @@ public class AwMessagePort implements PostMessageSender.PostMessageSenderDelegat
|
| }
|
|
|
| // This method may be called on a different thread than UI thread.
|
| - public void onMessage(String message, AwMessagePort[] ports) {
|
| + public void onMessage(String message, AppWebMessagePort[] ports) {
|
| synchronized (mLock) {
|
| if (isClosed()) {
|
| Log.w(TAG, "Port [" + mPortId + "] received message in closed state");
|
| @@ -227,13 +229,13 @@ public class AwMessagePort implements PostMessageSender.PostMessageSenderDelegat
|
| }
|
| }
|
|
|
| - public void postMessage(String message, AwMessagePort[] sentPorts)
|
| + public void postMessage(String message, AppWebMessagePort[] sentPorts)
|
| throws IllegalStateException {
|
| if (isClosed() || isTransferred()) {
|
| throw new IllegalStateException("Port is already closed or transferred");
|
| }
|
| if (sentPorts != null) {
|
| - for (AwMessagePort port : sentPorts) {
|
| + for (AppWebMessagePort port : sentPorts) {
|
| if (port.equals(this)) {
|
| throw new IllegalStateException("Source port cannot be transferred");
|
| }
|
|
|