Index: content/browser/service_worker/service_worker_context_wrapper.cc |
diff --git a/content/browser/service_worker/service_worker_context_wrapper.cc b/content/browser/service_worker/service_worker_context_wrapper.cc |
index 2ccffa1f2202225b0791495d26f3a831ecd685e0..976c3dd895fb45febae403d5de3d75e4cefdc02c 100644 |
--- a/content/browser/service_worker/service_worker_context_wrapper.cc |
+++ b/content/browser/service_worker/service_worker_context_wrapper.cc |
@@ -14,9 +14,12 @@ namespace content { |
ServiceWorkerContextWrapper::ServiceWorkerContextWrapper() |
: observer_list_( |
- new ObserverListThreadSafe<ServiceWorkerContextObserver>()) {} |
+ new ObserverListThreadSafe<ServiceWorkerContextObserver>()) { |
+ observer_list_->AddObserver(this); |
+} |
ServiceWorkerContextWrapper::~ServiceWorkerContextWrapper() { |
+ observer_list_->RemoveObserver(this); |
} |
void ServiceWorkerContextWrapper::Init( |
@@ -121,6 +124,26 @@ void ServiceWorkerContextWrapper::UnregisterServiceWorker( |
base::Bind(&FinishUnregistrationOnIO, continuation)); |
} |
+void ServiceWorkerContextWrapper::AddStatusChangeCallback( |
+ const base::Callback<void(void)>& callback) { |
+ DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ return status_change_callbacks_.push_back(callback); |
+} |
+ |
+void ServiceWorkerContextWrapper::RemoveStatusChangeCallback( |
+ const base::Callback<void(void)>& callback) { |
+ DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ for (std::vector<base::Callback<void(void)> >::iterator it = |
+ status_change_callbacks_.begin(); |
+ it != status_change_callbacks_.end();) { |
+ if (it->Equals(callback)) { |
+ it = status_change_callbacks_.erase(it); |
+ } else { |
+ ++it; |
+ } |
+ } |
+} |
+ |
void ServiceWorkerContextWrapper::AddObserver( |
ServiceWorkerContextObserver* observer) { |
observer_list_->AddObserver(observer); |
@@ -131,4 +154,33 @@ void ServiceWorkerContextWrapper::RemoveObserver( |
observer_list_->RemoveObserver(observer); |
} |
+void ServiceWorkerContextWrapper::GetRunningServiceWorkerInfo( |
+ const GetRunningServiceWorkerInfoCallback& callback) { |
+ // TODO(horo): Implement this. |
+ NOTIMPLEMENTED(); |
+} |
+ |
+void ServiceWorkerContextWrapper::OnWorkerStarted(int64 version_id, |
+ int process_id, |
+ int thread_id) { |
+ CallStatusChangeCallback(); |
+} |
+ |
+void ServiceWorkerContextWrapper::OnWorkerStopped(int64 version_id, |
+ int process_id, |
+ int thread_id) { |
+ CallStatusChangeCallback(); |
+} |
+ |
+void ServiceWorkerContextWrapper::OnVersionStateChanged(int64 version_id) { |
+ CallStatusChangeCallback(); |
+} |
+ |
+void ServiceWorkerContextWrapper::CallStatusChangeCallback() { |
+ DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ for (size_t i = 0; i < status_change_callbacks_.size(); ++i) { |
+ status_change_callbacks_[i].Run(); |
michaeln
2014/05/01 02:52:07
callbacks could be removed or added while running
horo
2014/05/01 04:52:32
Done.
Changed to use FOR_EACH_OBSERVER.
|
+ } |
+} |
+ |
} // namespace content |