ServiceWorker: Make "ready" fetches registration from browser process(2/3).

content/browser/service_worker/service_worker_registration.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/service_worker_registration.h"
 
 #include "content/browser/service_worker/service_worker_context_core.h"
 #include "content/browser/service_worker/service_worker_info.h"
 #include "content/browser/service_worker/service_worker_register_job.h"
 #include "content/browser/service_worker/service_worker_utils.h"
@@ skipping 254 matching lines @@
     exiting_version->StopWorker(
         base::Bind(&ServiceWorkerUtils::NoOpStatusCallback));
     // "3. Run the [[UpdateState]] algorithm passing exitingWorker and
     // "redundant" as the arguments."
     exiting_version->SetStatus(ServiceWorkerVersion::REDUNDANT);
   }
 
   // "6. Set serviceWorkerRegistration.activeWorker to activatingWorker."
   // "7. Set serviceWorkerRegistration.waitingWorker to null."
   SetActiveVersion(activating_version.get());
+  FOR_EACH_OBSERVER(Listener, listeners_, OnActivateVersion(this));
 
   // "8. Run the [[UpdateState]] algorithm passing registration.activeWorker and
   // "activating" as arguments."
   activating_version->SetStatus(ServiceWorkerVersion::ACTIVATING);
   // "9. Fire a simple event named controllerchange..."
   if (activating_version->skip_waiting())
     FOR_EACH_OBSERVER(Listener, listeners_, OnSkippedWaiting(this));
 
   // "10. Queue a task to fire an event named activate..."
   activating_version->DispatchActivateEvent(
@@ skipping 11 matching lines @@
   if (status != SERVICE_WORKER_OK) {
     // "11. If activateFailed is true, then:..."
     UnsetVersion(activating_version);
     activating_version->Doom();
     if (!waiting_version()) {
       // Delete the records from the db.
       context_->storage()->DeleteRegistration(
           id(), pattern().GetOrigin(),
           base::Bind(&ServiceWorkerRegistration::OnDeleteFinished, this));
       // But not from memory if there is a version in the pipeline.
-      if (installing_version())
+      if (installing_version()) {
         is_deleted_ = false;
-      else
+      } else {
         is_uninstalled_ = true;
+        FOR_EACH_OBSERVER(Listener, listeners_, OnRegistrationFailed(this));
+      }
     }
     return;
   }
 
   // "12. Run the [[UpdateState]] algorithm passing registration.activeWorker
   // and "activated" as the arguments."
   activating_version->SetStatus(ServiceWorkerVersion::ACTIVATED);
   if (context_) {
     context_->storage()->UpdateToActiveState(
         this,
@@ skipping 28 matching lines @@
     active_version_->Doom();
     active_version_->RemoveListener(this);
     active_version_ = NULL;
     mask.add(ChangedVersionAttributesMask::ACTIVE_VERSION);
   }
   if (mask.changed()) {
     ServiceWorkerRegistrationInfo info = GetInfo();
     FOR_EACH_OBSERVER(Listener, listeners_,
                       OnVersionAttributesChanged(this, mask, info));
   }
+
+  FOR_EACH_OBSERVER(
+      Listener, listeners_, OnRegistrationFinishedUninstalling(this));
 }
 
 void ServiceWorkerRegistration::OnRestoreFinished(
     const StatusCallback& callback,
     scoped_refptr<ServiceWorkerVersion> version,
     ServiceWorkerStatusCode status) {
   if (!context_) {
     callback.Run(SERVICE_WORKER_ERROR_ABORT);
     return;
   }
@@ skipping 42 matching lines @@
     if (registration &&
         (registration->is_uninstalling() || registration->is_uninstalled()))
       continue;
     if (matcher.MatchLongest(info.pattern))
       return false;
   }
   return true;
 }
 
 }  // namespace content