DevTools: devtools message plumbing between worker and page processes

content/worker/webworker_stub.cc

 // Copyright (c) 2011 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 "content/worker/webworker_stub.h"
 
 #include "base/command_line.h"
 #include "content/common/child_thread.h"
+#include "content/common/content_client.h"
 #include "content/common/file_system/file_system_dispatcher.h"
 #include "content/common/webmessageportchannel_impl.h"
 #include "content/common/worker_messages.h"
+#include "content/worker/worker_devtools_agent.h"
 #include "third_party/WebKit/Source/WebKit/chromium/public/WebString.h"
 #include "third_party/WebKit/Source/WebKit/chromium/public/WebURL.h"
 #include "third_party/WebKit/Source/WebKit/chromium/public/WebWorker.h"
 
 using WebKit::WebWorker;
 
 WebWorkerStub::WebWorkerStub(const GURL& url, int route_id,
                              const WorkerAppCacheInitInfo& appcache_init_info)
     : WebWorkerStubBase(route_id, appcache_init_info),
       ALLOW_THIS_IN_INITIALIZER_LIST(impl_(WebWorker::create(client()))),
-      url_(url) {
+      url_(url),
+      ALLOW_THIS_IN_INITIALIZER_LIST(worker_devtools_agent_(
+          new WorkerDevToolsAgent(route_id, impl_))) {
+  client()->set_devtools_agent(worker_devtools_agent_.get());
 }
 
 WebWorkerStub::~WebWorkerStub() {
   impl_->clientDestroyed();
 }
 
 void WebWorkerStub::OnChannelError() {
     OnTerminateWorkerContext();
 }
 
 const GURL& WebWorkerStub::url() const {
   return url_;
 }
 
 bool WebWorkerStub::OnMessageReceived(const IPC::Message& message) {
   if (!impl_)
     return false;
 
+  if (worker_devtools_agent_->OnMessageReceived(message))
+    return true;
+
   bool handled = true;
   IPC_BEGIN_MESSAGE_MAP(WebWorkerStub, message)
     IPC_MESSAGE_FORWARD(WorkerMsg_StartWorkerContext, impl_,
                         WebWorker::startWorkerContext)
     IPC_MESSAGE_HANDLER(WorkerMsg_TerminateWorkerContext,
                         OnTerminateWorkerContext)
     IPC_MESSAGE_HANDLER(WorkerMsg_PostMessage, OnPostMessage)
     IPC_MESSAGE_FORWARD(WorkerMsg_WorkerObjectDestroyed, impl_,
                         WebWorker::workerObjectDestroyed)
     IPC_MESSAGE_UNHANDLED(handled = false)
@@ skipping 13 matching lines @@
     const std::vector<int>& sent_message_port_ids,
     const std::vector<int>& new_routing_ids) {
   WebKit::WebMessagePortChannelArray channels(sent_message_port_ids.size());
   for (size_t i = 0; i < sent_message_port_ids.size(); i++) {
     channels[i] = new WebMessagePortChannelImpl(
         new_routing_ids[i], sent_message_port_ids[i]);
   }
 
   impl_->postMessageToWorkerContext(message, channels);
 }