Introduces DevToolsManagerDelegate.

content/browser/service_worker/service_worker_context_wrapper.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_context_wrapper.h"
 
 #include "base/files/file_path.h"
 #include "content/browser/service_worker/service_worker_context_core.h"
 #include "content/browser/service_worker/service_worker_context_observer.h"
 #include "content/public/browser/browser_thread.h"
 #include "webkit/browser/quota/quota_manager_proxy.h"
 
 namespace content {
 
 ServiceWorkerContextWrapper::ServiceWorkerContextWrapper()
     : observer_list_(
-          new ObserverListThreadSafe<ServiceWorkerContextObserver>()) {}
+          new ObserverListThreadSafe<ServiceWorkerContextObserver>()),
+      callback_proxy_(new CallbackProxy()) {
+  observer_list_->AddObserver(callback_proxy_);
+}
 
 ServiceWorkerContextWrapper::~ServiceWorkerContextWrapper() {

[michaeln, 2014/04/25 22:09:14]

I think you have to observer_list_->RemoveObserver(xxx) here since the list
might outlive |this|.

[horo, 2014/04/26 08:00:45]

Done.

 }
 
 void ServiceWorkerContextWrapper::Init(
     const base::FilePath& user_data_directory,
     quota::QuotaManagerProxy* quota_manager_proxy) {
   if (!BrowserThread::CurrentlyOn(BrowserThread::IO)) {
     BrowserThread::PostTask(
         BrowserThread::IO, FROM_HERE,
         base::Bind(&ServiceWorkerContextWrapper::Init, this,
                    user_data_directory,
@@ skipping 84 matching lines @@
     return;
   }
 
   context()->UnregisterServiceWorker(
       pattern,
       source_process_id,
       NULL /* provider_host */,
       base::Bind(&FinishUnregistrationOnIO, continuation));
 }
 
+scoped_ptr<base::CallbackList<void(void)>::Subscription>
+ServiceWorkerContextWrapper::RegisterStatusChangeCallback(
+    const base::Callback<void(void)>& callback) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  return callback_proxy_->Add(callback);
+}
+
 void ServiceWorkerContextWrapper::AddObserver(
     ServiceWorkerContextObserver* observer) {
   observer_list_->AddObserver(observer);
 }
 
 void ServiceWorkerContextWrapper::RemoveObserver(
     ServiceWorkerContextObserver* observer) {
   observer_list_->RemoveObserver(observer);
 }
 
+void ServiceWorkerContextWrapper::GetRunningServiceWorkerInfo(
+    const GetRunningServiceWorkerInfoCallback& callback) {
+  // TODO(horo): Implement this.
+}
+
+scoped_ptr<base::CallbackList<void(void)>::Subscription>
+ServiceWorkerContextWrapper::CallbackProxy::Add(
+    const base::Callback<void(void)>& callback) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  return status_change_callback_list_.Add(callback);
+}
+
+void ServiceWorkerContextWrapper::CallbackProxy::OnWorkerStarted(
+    int64 version_id,
+    int process_id,
+    int thread_id) {
+  BrowserThread::PostTask(BrowserThread::UI,

[michaeln, 2014/04/25 22:09:14]

If I understand ObserverListThreadSafe properly, since callbackproxy is added to
the observerlist on the UI thread, this method should be getting called on the
UI thread. So i think you can call status_change_callback_list_.Notify() right
here.

[horo, 2014/04/26 08:00:45]

Done.

+                          FROM_HERE,
+                          base::Bind(&CallbackProxy::onStatusChanged, this));
+}
+
+void ServiceWorkerContextWrapper::CallbackProxy::OnWorkerStopped(
+    int64 version_id,
+    int process_id,
+    int thread_id) {
+  BrowserThread::PostTask(BrowserThread::UI,
+                          FROM_HERE,
+                          base::Bind(&CallbackProxy::onStatusChanged, this));
+}
+
+void ServiceWorkerContextWrapper::CallbackProxy::OnVersionStateChanged(
+    int64 version_id) {
+  BrowserThread::PostTask(BrowserThread::UI,
+                          FROM_HERE,
+                          base::Bind(&CallbackProxy::onStatusChanged, this));
+}
+
+void ServiceWorkerContextWrapper::CallbackProxy::onStatusChanged() {
+  status_change_callback_list_.Notify();
+}
+
 }  // namespace content