ServiceWorker: Stop don't send a message before connection established

content/browser/service_worker/embedded_worker_instance.cc

 // Copyright 2013 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/embedded_worker_instance.h"
 
 #include <utility>
 
 #include "base/bind_helpers.h"
 #include "base/macros.h"
@@ skipping 482 matching lines @@
 }
 
 ServiceWorkerStatusCode EmbeddedWorkerInstance::Stop() {
   DCHECK(status_ == EmbeddedWorkerStatus::STARTING ||
          status_ == EmbeddedWorkerStatus::RUNNING)
       << static_cast<int>(status_);
 
   // Abort an inflight start task.
   inflight_start_task_.reset();
 
-  ServiceWorkerStatusCode status = SERVICE_WORKER_ERROR_IPC_FAILED;
   if (ServiceWorkerUtils::IsMojoForServiceWorkerEnabled()) {
-    status = SERVICE_WORKER_OK;
+    ServiceWorkerStatusCode status = SERVICE_WORKER_OK;
+    if (status_ == EmbeddedWorkerStatus::STARTING) {
+      // Handle like detach when connection hasn't been established yet.
+      switch (starting_phase()) {
+        case NOT_STARTING:
+          NOTREACHED();
+        case ALLOCATING_PROCESS:
+          status = SERVICE_WORKER_ERROR_PROCESS_NOT_FOUND;
+          OnDetached();
+          break;
+        case REGISTERING_TO_DEVTOOLS:
+          status = SERVICE_WORKER_ERROR_IPC_FAILED;
+          OnDetached();
+          break;
+        case SENT_START_WORKER:
+        case SCRIPT_DOWNLOADING:
+        case SCRIPT_READ_STARTED:
+        case SCRIPT_READ_FINISHED:
+        case SCRIPT_LOADED:
+        case THREAD_STARTED:
+        case SCRIPT_EVALUATED:
+          status = SERVICE_WORKER_OK;
+          break;
+        default:

[nhiroki, 2016/12/19 09:21:55]

Can you use "STARTING_PHASE_MAX_VALUE:" instead of "default"?

[shimazu, 2016/12/19 09:47:51]

Done.

+          NOTREACHED();
+      }
+    }
+    UMA_HISTOGRAM_ENUMERATION("ServiceWorker.SendStopWorker.Status", status,
+                              SERVICE_WORKER_ERROR_MAX_VALUE);
+    if (status != SERVICE_WORKER_OK)
+      return status;
     client_->StopWorker(base::Bind(&EmbeddedWorkerRegistry::OnWorkerStopped,
                                    base::Unretained(registry_.get()),
                                    process_id(), embedded_worker_id()));
+    status_ = EmbeddedWorkerStatus::STOPPING;
+    for (auto& observer : listener_list_)
+      observer.OnStopping();
+    return status;
   } else {
-    status = registry_->StopWorker(process_id(), embedded_worker_id_);
-  }
-  UMA_HISTOGRAM_ENUMERATION("ServiceWorker.SendStopWorker.Status", status,
-                            SERVICE_WORKER_ERROR_MAX_VALUE);
-  // StopWorker could fail if we were starting up and don't have a process yet,
-  // or we can no longer communicate with the process. So just detach.
-  if (status != SERVICE_WORKER_OK) {
-    OnDetached();
+    ServiceWorkerStatusCode status =
+        registry_->StopWorker(process_id(), embedded_worker_id_);
+    UMA_HISTOGRAM_ENUMERATION("ServiceWorker.SendStopWorker.Status", status,
+                              SERVICE_WORKER_ERROR_MAX_VALUE);
+    // StopWorker could fail if we were starting up and don't have a process
+    // yet, or we can no longer communicate with the process. So just detach.
+    if (status != SERVICE_WORKER_OK) {
+      OnDetached();
+      return status;
+    }
+    status_ = EmbeddedWorkerStatus::STOPPING;
+    for (auto& observer : listener_list_)
+      observer.OnStopping();
     return status;

[nhiroki, 2016/12/19 09:21:55]

nit: We could merge line 553-556 into 538-541 and then move them out of
if(IsMojoForServiceWorkerEnabled()).

[shimazu, 2016/12/19 09:47:51]

Done.

   }
-
-  status_ = EmbeddedWorkerStatus::STOPPING;
-  for (auto& observer : listener_list_)
-    observer.OnStopping();
-  return status;
 }
 
 void EmbeddedWorkerInstance::StopIfIdle() {
   if (devtools_attached_) {
     if (devtools_proxy_) {
       // Check ShouldNotifyWorkerStopIgnored not to show the same message
       // multiple times in DevTools.
       if (devtools_proxy_->ShouldNotifyWorkerStopIgnored()) {
         AddMessageToConsole(CONSOLE_MESSAGE_LEVEL_DEBUG,
                             kServiceWorkerTerminationCanceledMesage);
@@ skipping 407 matching lines @@
     case SCRIPT_READ_FINISHED:
       return "Script read finished";
     case STARTING_PHASE_MAX_VALUE:
       NOTREACHED();
   }
   NOTREACHED() << phase;
   return std::string();
 }
 
 }  // namespace content