Populate .current when navigator.serviceWorker is accessed

content/browser/service_worker/service_worker_provider_host.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_provider_host.h"
 
 #include "base/stl_util.h"
 #include "content/browser/service_worker/service_worker_context_core.h"
 #include "content/browser/service_worker/service_worker_context_request_handler.h"
 #include "content/browser/service_worker/service_worker_controllee_request_handler.h"
 #include "content/browser/service_worker/service_worker_dispatcher_host.h"
 #include "content/browser/service_worker/service_worker_handle.h"
 #include "content/browser/service_worker/service_worker_utils.h"
 #include "content/browser/service_worker/service_worker_version.h"
 #include "content/common/service_worker/service_worker_messages.h"
 
 namespace content {
 
+static const int kDocumentMainThreadId = 0;
+
 ServiceWorkerProviderHost::ServiceWorkerProviderHost(
     int process_id, int provider_id,
     base::WeakPtr<ServiceWorkerContextCore> context,
     ServiceWorkerDispatcherHost* dispatcher_host)
     : process_id_(process_id),
       provider_id_(provider_id),
       context_(context),
       dispatcher_host_(dispatcher_host) {
 }
 
 ServiceWorkerProviderHost::~ServiceWorkerProviderHost() {
   if (active_version_)
     active_version_->RemoveControllee(this);
   if (pending_version_)
     pending_version_->RemovePendingControllee(this);
 }
 
-void ServiceWorkerProviderHost::AddScriptClient(int thread_id) {
-  DCHECK(!ContainsKey(script_client_thread_ids_, thread_id));
-  script_client_thread_ids_.insert(thread_id);
-}
-
-void ServiceWorkerProviderHost::RemoveScriptClient(int thread_id) {
-  DCHECK(ContainsKey(script_client_thread_ids_, thread_id));
-  script_client_thread_ids_.erase(thread_id);
-}
-
 void ServiceWorkerProviderHost::SetActiveVersion(
     ServiceWorkerVersion* version) {
   if (version == active_version_)
     return;
   scoped_refptr<ServiceWorkerVersion> previous_version = active_version_;
   active_version_ = version;
   if (version)
     version->AddControllee(this);
   if (previous_version)
     previous_version->RemoveControllee(this);
 
   if (!dispatcher_host_)
     return;  // Could be NULL in some tests.
 
-  for (std::set<int>::iterator it = script_client_thread_ids_.begin();
-       it != script_client_thread_ids_.end();
-       ++it) {
-    ServiceWorkerObjectInfo info;
-    if (context_ && version) {
-      scoped_ptr<ServiceWorkerHandle> handle =
-          ServiceWorkerHandle::Create(context_, dispatcher_host_, *it, version);
-      info = handle->GetObjectInfo();
-      dispatcher_host_->RegisterServiceWorkerHandle(handle.Pass());
-    }
-    dispatcher_host_->Send(
-        new ServiceWorkerMsg_SetCurrentServiceWorker(*it, provider_id(), info));
+  ServiceWorkerObjectInfo info;
+  if (context_ && version) {
+    scoped_ptr<ServiceWorkerHandle> handle =
+        ServiceWorkerHandle::Create(context_, dispatcher_host_,
+                                    kDocumentMainThreadId, version);
+    info = handle->GetObjectInfo();
+    dispatcher_host_->RegisterServiceWorkerHandle(handle.Pass());
   }
+  dispatcher_host_->Send(
+      new ServiceWorkerMsg_SetCurrentServiceWorker(
+          kDocumentMainThreadId, provider_id(), info));
 }
 
 void ServiceWorkerProviderHost::SetPendingVersion(
     ServiceWorkerVersion* version) {
   if (version == pending_version_)
     return;
   scoped_refptr<ServiceWorkerVersion> previous_version = pending_version_;
   pending_version_ = version;
   if (version)
     version->AddPendingControllee(this);
   if (previous_version)
     previous_version->RemovePendingControllee(this);
 
   if (!dispatcher_host_)
     return;  // Could be NULL in some tests.
 
-  for (std::set<int>::iterator it = script_client_thread_ids_.begin();
-       it != script_client_thread_ids_.end();
-       ++it) {
-    // TODO(kinuko): dispatch pendingchange event to the script clients.
-  }
+  // TODO(kinuko): dispatch pendingchange event to the document.
 }
 
 bool ServiceWorkerProviderHost::SetHostedVersionId(int64 version_id) {
   if (!context_)
     return true;  // System is shutting down.
   if (active_version_)
     return false;  // Unexpected bad message.
 
   ServiceWorkerVersion* live_version = context_->GetLiveVersion(version_id);
   if (!live_version)
@@ skipping 22 matching lines @@
   if (ServiceWorkerUtils::IsMainResourceType(resource_type) ||
       active_version()) {
     return scoped_ptr<ServiceWorkerRequestHandler>(
         new ServiceWorkerControlleeRequestHandler(
             context_, AsWeakPtr(), resource_type));
   }
   return scoped_ptr<ServiceWorkerRequestHandler>();
 }
 
 }  // namespace content