Updating Worker.postMessage(), DOMWindow.postMessage(), and...

chrome/browser/worker_host/worker_process_host.cc

 // Copyright (c) 2009 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 "chrome/browser/worker_host/worker_process_host.h"
 
 #include <set>
+#include <vector>
 
 #include "base/command_line.h"
 #include "base/debug_util.h"
 #if defined(OS_POSIX)
 #include "base/global_descriptors_posix.h"
 #endif
 #include "base/message_loop.h"
 #include "base/path_service.h"
 #include "base/process_util.h"
 #include "base/string_util.h"
@@ skipping 207 matching lines @@
 void WorkerProcessHost::RelayMessage(
     const IPC::Message& message,
     IPC::Message::Sender* sender,
     int route_id,
     CallbackWithReturnValue<int>::Type* next_route_id) {
   IPC::Message* new_message;
   if (message.type() == WorkerMsg_PostMessage::ID) {
     // We want to send the receiver a routing id for the new channel, so
     // crack the message first.
     string16 msg;
-    int sent_message_port_id = MSG_ROUTING_NONE;
-    int new_routing_id = MSG_ROUTING_NONE;
+    std::vector<int> sent_message_port_ids;
+    std::vector<int> new_routing_ids;
     if (!WorkerMsg_PostMessage::Read(
-            &message, &msg, &sent_message_port_id, &new_routing_id)) {
+            &message, &msg, &sent_message_port_ids, &new_routing_ids)) {
       return;
     }
+    DCHECK(sent_message_port_ids.size() == new_routing_ids.size());
 
-    if (sent_message_port_id != MSG_ROUTING_NONE) {
-      new_routing_id = next_route_id->Run();
+    for (size_t i = 0; i < sent_message_port_ids.size(); ++i) {
+      new_routing_ids[i] = next_route_id->Run();
       MessagePortDispatcher::GetInstance()->UpdateMessagePort(
-          sent_message_port_id, sender, new_routing_id, next_route_id);
+          sent_message_port_ids[i], sender, new_routing_ids[i], next_route_id);
     }
 
     new_message = new WorkerMsg_PostMessage(
-        route_id, msg, sent_message_port_id, new_routing_id);
+        route_id, msg, sent_message_port_ids, new_routing_ids);
   } else {
     new_message = new IPC::Message(message);
     new_message->set_routing_id(route_id);
   }
 
   sender->Send(new_message);
 }
 
 void WorkerProcessHost::SenderShutdown(IPC::Message::Sender* sender) {
   for (Instances::iterator i = instances_.begin(); i != instances_.end();) {
@@ skipping 42 matching lines @@
 }
 
 void WorkerProcessHost::OnCancelCreateDedicatedWorker(int route_id) {
   WorkerService::GetInstance()->CancelCreateDedicatedWorker(
       GetProcessId(), route_id);
 }
 
 void WorkerProcessHost::OnForwardToWorker(const IPC::Message& message) {
   WorkerService::GetInstance()->ForwardMessage(message, GetProcessId());
 }