Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(86)

Side by Side Diff: content/browser/service_worker/service_worker_context_wrapper.cc

Issue 251653003: Introduces DevToolsManagerDelegate. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Stop using CallbackList Created 6 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2013 The Chromium Authors. All rights reserved. 1 // Copyright 2013 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "content/browser/service_worker/service_worker_context_wrapper.h" 5 #include "content/browser/service_worker/service_worker_context_wrapper.h"
6 6
7 #include "base/files/file_path.h" 7 #include "base/files/file_path.h"
8 #include "content/browser/service_worker/service_worker_context_core.h" 8 #include "content/browser/service_worker/service_worker_context_core.h"
9 #include "content/browser/service_worker/service_worker_context_observer.h" 9 #include "content/browser/service_worker/service_worker_context_observer.h"
10 #include "content/public/browser/browser_thread.h" 10 #include "content/public/browser/browser_thread.h"
11 #include "webkit/browser/quota/quota_manager_proxy.h" 11 #include "webkit/browser/quota/quota_manager_proxy.h"
12 12
13 namespace content { 13 namespace content {
14 14
15 ServiceWorkerContextWrapper::ServiceWorkerContextWrapper() 15 ServiceWorkerContextWrapper::ServiceWorkerContextWrapper()
16 : observer_list_( 16 : observer_list_(
17 new ObserverListThreadSafe<ServiceWorkerContextObserver>()) {} 17 new ObserverListThreadSafe<ServiceWorkerContextObserver>()) {
18 observer_list_->AddObserver(this);
19 }
18 20
19 ServiceWorkerContextWrapper::~ServiceWorkerContextWrapper() { 21 ServiceWorkerContextWrapper::~ServiceWorkerContextWrapper() {
22 observer_list_->RemoveObserver(this);
20 } 23 }
21 24
22 void ServiceWorkerContextWrapper::Init( 25 void ServiceWorkerContextWrapper::Init(
23 const base::FilePath& user_data_directory, 26 const base::FilePath& user_data_directory,
24 quota::QuotaManagerProxy* quota_manager_proxy) { 27 quota::QuotaManagerProxy* quota_manager_proxy) {
25 if (!BrowserThread::CurrentlyOn(BrowserThread::IO)) { 28 if (!BrowserThread::CurrentlyOn(BrowserThread::IO)) {
26 BrowserThread::PostTask( 29 BrowserThread::PostTask(
27 BrowserThread::IO, FROM_HERE, 30 BrowserThread::IO, FROM_HERE,
28 base::Bind(&ServiceWorkerContextWrapper::Init, this, 31 base::Bind(&ServiceWorkerContextWrapper::Init, this,
29 user_data_directory, 32 user_data_directory,
(...skipping 84 matching lines...) Expand 10 before | Expand all | Expand 10 after
114 return; 117 return;
115 } 118 }
116 119
117 context()->UnregisterServiceWorker( 120 context()->UnregisterServiceWorker(
118 pattern, 121 pattern,
119 source_process_id, 122 source_process_id,
120 NULL /* provider_host */, 123 NULL /* provider_host */,
121 base::Bind(&FinishUnregistrationOnIO, continuation)); 124 base::Bind(&FinishUnregistrationOnIO, continuation));
122 } 125 }
123 126
127 void ServiceWorkerContextWrapper::AddStatusChangeCallback(
128 const base::Callback<void(void)>& callback) {
129 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
130 return status_change_callbacks_.push_back(callback);
131 }
132
133 void ServiceWorkerContextWrapper::RemoveStatusChangeCallback(
134 const base::Callback<void(void)>& callback) {
135 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
136 for (std::vector<base::Callback<void(void)> >::iterator it =
137 status_change_callbacks_.begin();
138 it != status_change_callbacks_.end();) {
139 if (it->Equals(callback)) {
140 it = status_change_callbacks_.erase(it);
141 } else {
142 ++it;
143 }
144 }
145 }
146
124 void ServiceWorkerContextWrapper::AddObserver( 147 void ServiceWorkerContextWrapper::AddObserver(
125 ServiceWorkerContextObserver* observer) { 148 ServiceWorkerContextObserver* observer) {
126 observer_list_->AddObserver(observer); 149 observer_list_->AddObserver(observer);
127 } 150 }
128 151
129 void ServiceWorkerContextWrapper::RemoveObserver( 152 void ServiceWorkerContextWrapper::RemoveObserver(
130 ServiceWorkerContextObserver* observer) { 153 ServiceWorkerContextObserver* observer) {
131 observer_list_->RemoveObserver(observer); 154 observer_list_->RemoveObserver(observer);
132 } 155 }
133 156
157 void ServiceWorkerContextWrapper::GetRunningServiceWorkerInfo(
158 const GetRunningServiceWorkerInfoCallback& callback) {
159 // TODO(horo): Implement this.
160 NOTIMPLEMENTED();
161 }
162
163 void ServiceWorkerContextWrapper::OnWorkerStarted(int64 version_id,
164 int process_id,
165 int thread_id) {
166 CallStatusChangeCallback();
167 }
168
169 void ServiceWorkerContextWrapper::OnWorkerStopped(int64 version_id,
170 int process_id,
171 int thread_id) {
172 CallStatusChangeCallback();
173 }
174
175 void ServiceWorkerContextWrapper::OnVersionStateChanged(int64 version_id) {
176 CallStatusChangeCallback();
177 }
178
179 void ServiceWorkerContextWrapper::CallStatusChangeCallback() {
180 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
181 for (size_t i = 0; i < status_change_callbacks_.size(); ++i) {
182 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.
183 }
184 }
185
134 } // namespace content 186 } // namespace content
OLDNEW
« no previous file with comments | « content/browser/service_worker/service_worker_context_wrapper.h ('k') | content/public/browser/service_worker_context.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698