Implement receiving transferred ports from JS

android_webview/native/aw_message_port_service_impl.cc

 // 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.
 
 #include "android_webview/native/aw_message_port_service_impl.h"
 
 #include "android_webview/browser/aw_browser_context.h"
 #include "android_webview/browser/aw_message_port_message_filter.h"
 #include "android_webview/native/aw_contents.h"
 #include "base/android/jni_array.h"
@@ skipping 78 matching lines @@
     LOG(WARNING) << "Converting post message to a string failed for port "
         << message_port_id;
     return;
   }
 
   if (message.GetSize() != 1) {
     NOTREACHED();
     return;
   }
 
+  // Add the ports to AwMessagePortService.
+  for (const auto& iter : sent_message_port_ids) {
+    AddPort(iter, ports_[message_port_id]);
+  }
+
   ScopedJavaLocalRef<jstring> jmsg = ConvertUTF16ToJavaString(env, value);
   ScopedJavaLocalRef<jintArray> jports =
       ToJavaIntArray(env, sent_message_port_ids);
   Java_AwMessagePortService_onReceivedMessage(env,
                                               jobj.obj(),
                                               message_port_id,
                                               jmsg.obj(),
                                               jports.obj());
 }
 
@@ skipping 94 matching lines @@
     int* port2) {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
   JNIEnv* env = AttachCurrentThread();
   ScopedJavaLocalRef<jobject> obj = java_ref_.get(env);
   if (obj.is_null())
     return;
   Java_AwMessagePortService_onMessageChannelCreated(env, obj.obj(), *port1,
       *port2, ports->obj());
 }
 
+// Adds a new port to the message port service.
 void AwMessagePortServiceImpl::AddPort(int message_port_id,
                                        AwMessagePortMessageFilter* filter) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
   if (ports_.count(message_port_id)) {
     NOTREACHED();
     return;
   }
   ports_[message_port_id] = filter;
 }
 
 bool RegisterAwMessagePortService(JNIEnv* env) {
   return RegisterNativesImpl(env);
 }
 
 // static
 jlong InitAwMessagePortService(JNIEnv* env, jobject obj) {
   AwMessagePortServiceImpl* service = AwMessagePortServiceImpl::GetInstance();
   service->Init(env, obj);
   return reinterpret_cast<intptr_t>(service);
 }
 
 }  // namespace android_webview