Wire provider_id into scriptable API provider to start listening events

content/child/service_worker/service_worker_dispatcher.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/child/service_worker/service_worker_dispatcher.h"
 
 #include "base/lazy_instance.h"
 #include "base/threading/thread_local.h"
 #include "content/child/service_worker/web_service_worker_impl.h"
 #include "content/child/thread_safe_sender.h"
@@ skipping 15 matching lines @@
     reinterpret_cast<ServiceWorkerDispatcher*>(0x1);
 
 int CurrentWorkerId() {
   return WorkerTaskRunner::Instance()->CurrentWorkerId();
 }
 
 }  // namespace
 
 ServiceWorkerDispatcher::ServiceWorkerDispatcher(
     ThreadSafeSender* thread_safe_sender)
-    : thread_safe_sender_(thread_safe_sender) {
+    : thread_safe_sender_(thread_safe_sender),
+      client_(NULL) {
   g_dispatcher_tls.Pointer()->Set(this);
 }
 
 ServiceWorkerDispatcher::~ServiceWorkerDispatcher() {
   g_dispatcher_tls.Pointer()->Set(kHasBeenDeleted);
 }
 
 void ServiceWorkerDispatcher::OnMessageReceived(const IPC::Message& msg) {
   bool handled = true;
   IPC_BEGIN_MESSAGE_MAP(ServiceWorkerDispatcher, msg)
@@ skipping 23 matching lines @@
 
 void ServiceWorkerDispatcher::UnregisterServiceWorker(
     const GURL& pattern,
     WebServiceWorkerProvider::WebServiceWorkerCallbacks* callbacks) {
   DCHECK(callbacks);
   int request_id = pending_callbacks_.Add(callbacks);
   thread_safe_sender_->Send(new ServiceWorkerHostMsg_UnregisterServiceWorker(
       CurrentWorkerId(), request_id, pattern));
 }
 
+void ServiceWorkerDispatcher::SetScriptClient(
+    int provider_id,
+    blink::WebServiceWorkerProviderClient* client) {
+  if (client) {
+    DCHECK(!client_);
+    thread_safe_sender_->Send(new ServiceWorkerHostMsg_AddScriptClient(
+        CurrentWorkerId(), provider_id));
+  } else {
+    DCHECK(client_);
+    thread_safe_sender_->Send(new ServiceWorkerHostMsg_RemoveScriptClient(
+        CurrentWorkerId(), provider_id));
+  }
+  client_ = client;

[michaeln, 2014/03/07 01:26:23]

This class is used on the main thread where we'll have multiple script clients
for different documents so a singular client_ doesn't look right.

[kinuko, 2014/03/07 02:02:17]

Oops, that's right, I have focused too much on worker cases. Fixed.

+}
+
 ServiceWorkerDispatcher* ServiceWorkerDispatcher::ThreadSpecificInstance(
     ThreadSafeSender* thread_safe_sender) {
   if (g_dispatcher_tls.Pointer()->Get() == kHasBeenDeleted) {
     NOTREACHED() << "Re-instantiating TLS ServiceWorkerDispatcher.";
     g_dispatcher_tls.Pointer()->Set(NULL);
   }
   if (g_dispatcher_tls.Pointer()->Get())
     return g_dispatcher_tls.Pointer()->Get();
 
   ServiceWorkerDispatcher* dispatcher =
@@ skipping 50 matching lines @@
 
   scoped_ptr<WebServiceWorkerError>  error(
       new WebServiceWorkerError(error_type, message));
   callbacks->onError(error.release());
   pending_callbacks_.Remove(request_id);
 }
 
 void ServiceWorkerDispatcher::OnWorkerRunLoopStopped() { delete this; }
 
 }  // namespace content