OLD | NEW |
---|---|
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 Loading... | |
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 |
OLD | NEW |