Implement ServiceWorker::postMessage() [Chromium]

content/renderer/service_worker/service_worker_script_context.cc

Index: content/renderer/service_worker/service_worker_script_context.cc
diff --git a/content/renderer/service_worker/service_worker_script_context.cc b/content/renderer/service_worker/service_worker_script_context.cc
index 6afe0036528cfde4c185125f27cc68775d643657..b48f98b2975e419955bff79f95bbfbba4160da38 100644
--- a/content/renderer/service_worker/service_worker_script_context.cc
+++ b/content/renderer/service_worker/service_worker_script_context.cc
@@ -5,6 +5,7 @@
 #include "content/renderer/service_worker/service_worker_script_context.h"
 
 #include "base/logging.h"
+#include "content/child/webmessageportchannel_impl.h"
 #include "content/common/service_worker/service_worker_messages.h"
 #include "content/renderer/service_worker/embedded_worker_context_client.h"
 #include "ipc/ipc_message.h"
@@ -31,6 +32,7 @@ void ServiceWorkerScriptContext::OnMessageReceived(
   IPC_BEGIN_MESSAGE_MAP(ServiceWorkerScriptContext, message)
     IPC_MESSAGE_HANDLER(ServiceWorkerMsg_InstallEvent, OnInstallEvent)
     IPC_MESSAGE_HANDLER(ServiceWorkerMsg_FetchEvent, OnFetchEvent)
+    IPC_MESSAGE_HANDLER(ServiceWorkerMsg_Message, OnMessage)
     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP()
   DCHECK(handled);
@@ -65,4 +67,22 @@ void ServiceWorkerScriptContext::OnFetchEvent(
       200, "OK", "GET", std::map<std::string, std::string>()));
 }
 
+void ServiceWorkerScriptContext::OnMessage(
+    base::string16 message,
+    std::vector<int> sent_message_port_ids,
+    std::vector<int> new_routing_ids) {

[michaeln, 2014/03/11 23:17:34]

const refs

[jsbell, 2014/03/12 18:16:16]

Done.

+
+  std::vector<WebMessagePortChannelImpl*> ports;
+  if (!sent_message_port_ids.empty()) {
+    base::MessageLoopProxy* loop_proxy = embedded_context_->main_thread_proxy();
+    ports.resize(sent_message_port_ids.size());
+    for (size_t i = 0; i < sent_message_port_ids.size(); ++i) {
+      ports[i] = new WebMessagePortChannelImpl(

[kinuko, 2014/03/12 08:19:05]

(It's a bit sad that WebMessagePortChannelImpl relays all methods to the main
thread... but it's not our issue for now)

+          new_routing_ids[i], sent_message_port_ids[i], loop_proxy);
+    }
+  }
+
+  proxy_->dispatchMessageEvent(message, ports);
+}
+
 }  // namespace content