Implement ServiceWorker::postMessage() [Chromium]

content/child/webmessageportchannel_impl.h

 // Copyright (c) 2012 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.
 
 #ifndef CONTENT_CHILD_WEBMESSAGEPORTCHANNEL_IMPL_H_
 #define CONTENT_CHILD_WEBMESSAGEPORTCHANNEL_IMPL_H_
 
 #include <queue>
 #include <vector>
 
@@ skipping 15 matching lines @@
 class WebMessagePortChannelImpl
     : public blink::WebMessagePortChannel,
       public IPC::Listener,
       public base::RefCountedThreadSafe<WebMessagePortChannelImpl> {
  public:
   explicit WebMessagePortChannelImpl(base::MessageLoopProxy* child_thread_loop);
   WebMessagePortChannelImpl(int route_id,
                             int message_port_id,
                             base::MessageLoopProxy* child_thread_loop);
 
+  static void ExtractMessagePortIDs(blink::WebMessagePortChannelArray* channels,
+                                    std::vector<int>* message_port_ids);

[jam, 2014/03/19 21:08:48]

nit: why not have the return value be the struct since you dcheck that it's
empty initially? also, please add a comment

[jsbell, 2014/03/19 23:52:39]

Ah yes, much cleaner. Done and done.

+
   // Queues received and incoming messages until there are no more in-flight
   // messages, then sends all of them to the browser process.
   void QueueMessages();
   int message_port_id() const { return message_port_id_; }
 
  private:
   friend class base::RefCountedThreadSafe<WebMessagePortChannelImpl>;
   virtual ~WebMessagePortChannelImpl();
 
   // WebMessagePortChannel implementation.
@@ skipping 36 matching lines @@
   int route_id_;  // The routing id for this object.
   int message_port_id_;  // A globally unique identifier for this message port.
   scoped_refptr<base::MessageLoopProxy> child_thread_loop_;
 
   DISALLOW_COPY_AND_ASSIGN(WebMessagePortChannelImpl);
 };
 
 }  // namespace content
 
 #endif  // CONTENT_CHILD_WEBMESSAGEPORTCHANNEL_IMPL_H_