Call EmbeddedWorkerDevToolsManager::ServiceWorkerCreated, WorkerContextStarted and WorkerDestroyed.

content/browser/service_worker/service_worker_process_manager.cc

 // Copyright 2014 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/browser/service_worker/service_worker_process_manager.h"
 
+#include "content/browser/devtools/embedded_worker_devtools_manager.h"
 #include "content/browser/renderer_host/render_process_host_impl.h"
 #include "content/browser/service_worker/service_worker_context_wrapper.h"
 #include "content/public/browser/browser_thread.h"
 #include "content/public/browser/site_instance.h"
 #include "url/gurl.h"
 
 namespace content {
 
+namespace {
+
+void GetRoutingIDAndNotifyWorkerCreated(RenderProcessHost* rph,
+                                        const base::FilePath& path,
+                                        const GURL& scope,
+                                        int* route_id,
+                                        bool* pause_on_start) {
+  if (!rph) {
+    // |rph| may NULL in unit tests.

[kinuko, 2014/05/02 11:12:45]

nit: may -> may be

[horo, 2014/05/07 08:34:44]

Done.

+    *route_id = MSG_ROUTING_NONE;
+    *pause_on_start = false;
+    return;
+  }
+  *route_id = rph->GetNextRoutingID();
+  *pause_on_start =
+      EmbeddedWorkerDevToolsManager::GetInstance()->ServiceWorkerCreated(
+          rph->GetID(), *route_id, path, scope);
+}
+
+}  // namespace
+
 ServiceWorkerProcessManager::ServiceWorkerProcessManager(
     ServiceWorkerContextWrapper* context_wrapper)
     : context_wrapper_(context_wrapper),
       weak_this_factory_(this),
       weak_this_(weak_this_factory_.GetWeakPtr()) {
 }
 
 ServiceWorkerProcessManager::~ServiceWorkerProcessManager() {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
 }
 
 void ServiceWorkerProcessManager::AllocateWorkerProcess(
     const std::vector<int>& process_ids,
+    const base::FilePath& path,
+    const GURL& scope,
     const GURL& script_url,
-    const base::Callback<void(ServiceWorkerStatusCode, int process_id)>&
-        callback) const {
+    const base::Callback<void(ServiceWorkerStatusCode,
+                              int process_id,
+                              int worker_devtools_agent_route_id,
+                              bool pause_on_start)>& callback) const {
   if (!BrowserThread::CurrentlyOn(BrowserThread::UI)) {
     BrowserThread::PostTask(
         BrowserThread::UI,
         FROM_HERE,
         base::Bind(&ServiceWorkerProcessManager::AllocateWorkerProcess,
                    weak_this_,
                    process_ids,
+                   path,
+                   scope,
                    script_url,
                    callback));
     return;
   }
-
+  int route_id = MSG_ROUTING_NONE;
+  bool pause_on_start = false;
   for (std::vector<int>::const_iterator it = process_ids.begin();
        it != process_ids.end();
        ++it) {
     if (IncrementWorkerRefcountByPid(*it)) {
-      BrowserThread::PostTask(BrowserThread::IO,
-                              FROM_HERE,
-                              base::Bind(callback, SERVICE_WORKER_OK, *it));
+      GetRoutingIDAndNotifyWorkerCreated(RenderProcessHost::FromID(*it),
+                                         path,
+                                         scope,
+                                         &route_id,
+                                         &pause_on_start);
+      BrowserThread::PostTask(
+          BrowserThread::IO,
+          FROM_HERE,
+          base::Bind(
+              callback, SERVICE_WORKER_OK, *it, route_id, pause_on_start));
       return;
     }
   }
 
   if (!context_wrapper_->browser_context_) {
     // Shutdown has started.
-    BrowserThread::PostTask(
-        BrowserThread::IO,
-        FROM_HERE,
-        base::Bind(callback, SERVICE_WORKER_ERROR_START_WORKER_FAILED, -1));
+    BrowserThread::PostTask(BrowserThread::IO,
+                            FROM_HERE,
+                            base::Bind(callback,
+                                       SERVICE_WORKER_ERROR_START_WORKER_FAILED,
+                                       -1,
+                                       route_id,
+                                       pause_on_start));
     return;
   }
   // No existing processes available; start a new one.
   scoped_refptr<SiteInstance> site_instance = SiteInstance::CreateForURL(
       context_wrapper_->browser_context_, script_url);
   RenderProcessHost* rph = site_instance->GetProcess();
   // This Init() call posts a task to the IO thread that adds the RPH's
   // ServiceWorkerDispatcherHost to the
   // EmbeddedWorkerRegistry::process_sender_map_.
   if (!rph->Init()) {
     LOG(ERROR) << "Couldn't start a new process!";
-    BrowserThread::PostTask(
-        BrowserThread::IO,
-        FROM_HERE,
-        base::Bind(callback, SERVICE_WORKER_ERROR_START_WORKER_FAILED, -1));
+    BrowserThread::PostTask(BrowserThread::IO,
+                            FROM_HERE,
+                            base::Bind(callback,
+                                       SERVICE_WORKER_ERROR_START_WORKER_FAILED,
+                                       -1,
+                                       route_id,
+                                       pause_on_start));
     return;
   }
 
   static_cast<RenderProcessHostImpl*>(rph)->IncrementWorkerRefCount();
+  GetRoutingIDAndNotifyWorkerCreated(
+      rph, path, scope, &route_id, &pause_on_start);
   BrowserThread::PostTask(
       BrowserThread::IO,
       FROM_HERE,
-      base::Bind(callback, SERVICE_WORKER_OK, rph->GetID()));
+      base::Bind(
+          callback, SERVICE_WORKER_OK, rph->GetID(), route_id, pause_on_start));
 }
 
 void ServiceWorkerProcessManager::ReleaseWorkerProcess(int process_id) {
   if (!BrowserThread::CurrentlyOn(BrowserThread::UI)) {
     BrowserThread::PostTask(
         BrowserThread::UI,
         FROM_HERE,
         base::Bind(&ServiceWorkerProcessManager::ReleaseWorkerProcess,
                    weak_this_,
                    process_id));
@@ skipping 43 matching lines @@
 namespace base {
 // Destroying ServiceWorkerProcessManagers only on the UI thread allows the
 // member WeakPtr to safely guard the object's lifetime when used on that
 // thread.
 void DefaultDeleter<content::ServiceWorkerProcessManager>::operator()(
     content::ServiceWorkerProcessManager* ptr) const {
   content::BrowserThread::DeleteSoon(
       content::BrowserThread::UI, FROM_HERE, ptr);
 }
 }  // namespace base