Post a Message from Java to JS

android_webview/java/src/org/chromium/android_webview/AwMessagePortService.java

 // Copyright 2015 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.os.Handler;
 import android.os.Looper;
 import android.os.Message;
 import android.util.SparseArray;
@@ skipping 88 matching lines @@
 
     private long mNativeMessagePortService;
     private MessagePortStorage mPortStorage = new MessagePortStorage();
     private MessageHandlerThread mMessageHandlerThread = new MessageHandlerThread();
 
     AwMessagePortService() {
         mNativeMessagePortService = nativeInitAwMessagePortService();
         mMessageHandlerThread.start();
     }
 
+    public void postMessage(int senderId, String message, int[] sentPorts) {
+        // verify that webview still owns the port (not transferred)
+        if (mPortStorage.get(senderId) == null) {
+            throw new IllegalStateException(" Cannot post to unknown port " + senderId);

[mnaganov (inactive), 2015/01/27 13:30:17]

nit: extra leading space in the message

[sgurun-gerrit only, 2015/01/29 03:06:08]

Done.

+        }
+        removeSentPorts(sentPorts);
+        if (mNativeMessagePortService == 0) return;
+        nativePostOutMessage(mNativeMessagePortService, senderId, message, sentPorts);
+    }
+
+    public void removeSentPorts(int[] sentPorts) {
+        // verify that webview owns all the ports that are transferred
+        if (sentPorts != null) {
+            for (int port : sentPorts) {
+                MessagePort p = mPortStorage.get(port);
+                if (p == null) {
+                    throw new IllegalStateException("Cannot transfer unknown port " + port);
+                }
+                p.close();
+                // close the port so users can get feedback if they use in future.
+                mPortStorage.put(port, null);
+            }
+        }
+    }
+
     private MessagePort addPort(int portId) {
         if (mPortStorage.get(portId) != null) {
             throw new IllegalStateException("Port already exists");
         }
-        MessagePort m = new MessagePort(portId);
+        MessagePort m = new MessagePort(portId, this);
         mPortStorage.put(portId, m);
         return m;
     }
 
     @CalledByNative
     private void onMessageChannelCreated(int portId1, int portId2,
             ValueCallback<MessageChannel> callback) {
         callback.onReceiveValue(new MessageChannel(addPort(portId1), addPort(portId2)));
     }
 
     // Called on IO thread.
     @CalledByNative
     private void onPostMessage(int portId, String message, int[] ports) {
         PostMessage m = new PostMessage(mPortStorage.get(portId), message);
         Handler handler = mMessageHandlerThread.getHandler();
         Message msg = handler.obtainMessage(POST_MESSAGE, m);
         handler.sendMessage(msg);
     }
 
     @CalledByNative
     private void unregisterNativeAwMessagePortService() {
         mNativeMessagePortService = 0;
     }
 
     private native long nativeInitAwMessagePortService();
+    private native void nativePostOutMessage(long nativeAwMessagePortServiceImpl,
+            int senderId, String message, int[] portIds);
 }