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 #ifndef CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_STORAGE_H_ | 5 #ifndef CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_STORAGE_H_ |
6 #define CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_STORAGE_H_ | 6 #define CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_STORAGE_H_ |
7 | 7 |
8 #include <algorithm> | |
8 #include <deque> | 9 #include <deque> |
9 #include <map> | 10 #include <map> |
10 #include <set> | 11 #include <set> |
11 #include <vector> | 12 #include <vector> |
12 | 13 |
13 #include "base/bind.h" | 14 #include "base/bind.h" |
14 #include "base/files/file_path.h" | 15 #include "base/files/file_path.h" |
15 #include "base/gtest_prod_util.h" | 16 #include "base/gtest_prod_util.h" |
16 #include "base/memory/scoped_vector.h" | 17 #include "base/memory/scoped_vector.h" |
17 #include "base/memory/weak_ptr.h" | 18 #include "base/memory/weak_ptr.h" |
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
50 typedef base::Callback<void(ServiceWorkerStatusCode status)> StatusCallback; | 51 typedef base::Callback<void(ServiceWorkerStatusCode status)> StatusCallback; |
51 typedef base::Callback<void(ServiceWorkerStatusCode status, | 52 typedef base::Callback<void(ServiceWorkerStatusCode status, |
52 const scoped_refptr<ServiceWorkerRegistration>& | 53 const scoped_refptr<ServiceWorkerRegistration>& |
53 registration)> FindRegistrationCallback; | 54 registration)> FindRegistrationCallback; |
54 typedef base::Callback< | 55 typedef base::Callback< |
55 void(const std::vector<ServiceWorkerRegistrationInfo>& registrations)> | 56 void(const std::vector<ServiceWorkerRegistrationInfo>& registrations)> |
56 GetAllRegistrationInfosCallback; | 57 GetAllRegistrationInfosCallback; |
57 typedef base::Callback< | 58 typedef base::Callback< |
58 void(ServiceWorkerStatusCode status, bool are_equal)> | 59 void(ServiceWorkerStatusCode status, bool are_equal)> |
59 CompareCallback; | 60 CompareCallback; |
61 typedef base::Callback<void(const std::map<GURL, int64>& origin_usage)> | |
62 OriginUsageCallback; | |
60 | 63 |
61 ~ServiceWorkerStorage() override; | 64 ~ServiceWorkerStorage() override; |
62 | 65 |
63 static scoped_ptr<ServiceWorkerStorage> Create( | 66 static scoped_ptr<ServiceWorkerStorage> Create( |
64 const base::FilePath& path, | 67 const base::FilePath& path, |
65 base::WeakPtr<ServiceWorkerContextCore> context, | 68 base::WeakPtr<ServiceWorkerContextCore> context, |
66 scoped_ptr<ServiceWorkerDatabaseTaskManager> database_task_manager, | 69 scoped_ptr<ServiceWorkerDatabaseTaskManager> database_task_manager, |
67 const scoped_refptr<base::SingleThreadTaskRunner>& disk_cache_thread, | 70 const scoped_refptr<base::SingleThreadTaskRunner>& disk_cache_thread, |
68 storage::QuotaManagerProxy* quota_manager_proxy, | 71 storage::QuotaManagerProxy* quota_manager_proxy, |
69 storage::SpecialStoragePolicy* special_storage_policy); | 72 storage::SpecialStoragePolicy* special_storage_policy); |
(...skipping 18 matching lines...) Expand all Loading... | |
88 const FindRegistrationCallback& callback); | 91 const FindRegistrationCallback& callback); |
89 void FindRegistrationForId(int64 registration_id, | 92 void FindRegistrationForId(int64 registration_id, |
90 const GURL& origin, | 93 const GURL& origin, |
91 const FindRegistrationCallback& callback); | 94 const FindRegistrationCallback& callback); |
92 | 95 |
93 ServiceWorkerRegistration* GetUninstallingRegistration(const GURL& scope); | 96 ServiceWorkerRegistration* GetUninstallingRegistration(const GURL& scope); |
94 | 97 |
95 // Returns info about all stored and initially installing registrations. | 98 // Returns info about all stored and initially installing registrations. |
96 void GetAllRegistrations(const GetAllRegistrationInfosCallback& callback); | 99 void GetAllRegistrations(const GetAllRegistrationInfosCallback& callback); |
97 | 100 |
101 void GetAllUsageByOrigin(const OriginUsageCallback& callback); | |
102 | |
98 // Commits |registration| with the installed but not activated |version| | 103 // Commits |registration| with the installed but not activated |version| |
99 // to storage, overwritting any pre-existing registration data for the scope. | 104 // to storage, overwritting any pre-existing registration data for the scope. |
100 // A pre-existing version's script resources remain available if that version | 105 // A pre-existing version's script resources remain available if that version |
101 // is live. PurgeResources should be called when it's OK to delete them. | 106 // is live. PurgeResources should be called when it's OK to delete them. |
102 void StoreRegistration( | 107 void StoreRegistration(ServiceWorkerRegistration* registration, |
103 ServiceWorkerRegistration* registration, | 108 ServiceWorkerVersion* version, |
104 ServiceWorkerVersion* version, | 109 const StatusCallback& callback); |
105 const StatusCallback& callback); | |
106 | 110 |
107 // Updates the state of the registration's stored version to active. | 111 // Updates the state of the registration's stored version to active. |
108 void UpdateToActiveState( | 112 void UpdateToActiveState( |
109 ServiceWorkerRegistration* registration, | 113 ServiceWorkerRegistration* registration, |
110 const StatusCallback& callback); | 114 const StatusCallback& callback); |
111 | 115 |
112 // Updates the stored time to match the value of | 116 // Updates the stored time to match the value of |
113 // registration->last_update_check(). | 117 // registration->last_update_check(). |
114 void UpdateLastUpdateCheckTime(ServiceWorkerRegistration* registration); | 118 void UpdateLastUpdateCheckTime(ServiceWorkerRegistration* registration); |
115 | 119 |
(...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
201 DidDeleteRegistrationParams(); | 205 DidDeleteRegistrationParams(); |
202 ~DidDeleteRegistrationParams(); | 206 ~DidDeleteRegistrationParams(); |
203 }; | 207 }; |
204 | 208 |
205 typedef std::vector<ServiceWorkerDatabase::RegistrationData> RegistrationList; | 209 typedef std::vector<ServiceWorkerDatabase::RegistrationData> RegistrationList; |
206 typedef std::map<int64, scoped_refptr<ServiceWorkerRegistration> > | 210 typedef std::map<int64, scoped_refptr<ServiceWorkerRegistration> > |
207 RegistrationRefsById; | 211 RegistrationRefsById; |
208 typedef base::Callback<void( | 212 typedef base::Callback<void( |
209 InitialData* data, | 213 InitialData* data, |
210 ServiceWorkerDatabase::Status status)> InitializeCallback; | 214 ServiceWorkerDatabase::Status status)> InitializeCallback; |
211 typedef base::Callback< | 215 // The registration data is owned by the callback. |
212 void(const GURL& origin, | 216 typedef base::Callback<void( |
213 int64 deleted_version_id, | 217 const GURL& origin, |
214 const std::vector<int64>& newly_purgeable_resources, | 218 ServiceWorkerDatabase::RegistrationData* deleted_version_data, |
215 ServiceWorkerDatabase::Status status)> WriteRegistrationCallback; | 219 const std::vector<int64>& newly_purgeable_resources, |
216 typedef base::Callback< | 220 ServiceWorkerDatabase::Status status)> WriteRegistrationCallback; |
217 void(bool origin_is_deletable, | 221 // The registration data is owned by the callback. |
218 int64 version_id, | 222 typedef base::Callback<void( |
219 const std::vector<int64>& newly_purgeable_resources, | 223 bool origin_is_deletable, |
220 ServiceWorkerDatabase::Status status)> DeleteRegistrationCallback; | 224 ServiceWorkerDatabase::RegistrationData* deleted_version_data, |
225 const std::vector<int64>& newly_purgeable_resources, | |
226 ServiceWorkerDatabase::Status status)> DeleteRegistrationCallback; | |
221 typedef base::Callback<void( | 227 typedef base::Callback<void( |
222 const ServiceWorkerDatabase::RegistrationData& data, | 228 const ServiceWorkerDatabase::RegistrationData& data, |
223 const ResourceList& resources, | 229 const ResourceList& resources, |
224 ServiceWorkerDatabase::Status status)> FindInDBCallback; | 230 ServiceWorkerDatabase::Status status)> FindInDBCallback; |
225 typedef base::Callback<void(const std::vector<int64>& resource_ids, | 231 typedef base::Callback<void(const std::vector<int64>& resource_ids, |
226 ServiceWorkerDatabase::Status status)> | 232 ServiceWorkerDatabase::Status status)> |
227 GetResourcesCallback; | 233 GetResourcesCallback; |
228 | 234 |
229 ServiceWorkerStorage( | 235 ServiceWorkerStorage( |
230 const base::FilePath& path, | 236 const base::FilePath& path, |
(...skipping 26 matching lines...) Expand all Loading... | |
257 ServiceWorkerDatabase::Status status); | 263 ServiceWorkerDatabase::Status status); |
258 void DidFindRegistrationForId( | 264 void DidFindRegistrationForId( |
259 const FindRegistrationCallback& callback, | 265 const FindRegistrationCallback& callback, |
260 const ServiceWorkerDatabase::RegistrationData& data, | 266 const ServiceWorkerDatabase::RegistrationData& data, |
261 const ResourceList& resources, | 267 const ResourceList& resources, |
262 ServiceWorkerDatabase::Status status); | 268 ServiceWorkerDatabase::Status status); |
263 void DidGetAllRegistrations( | 269 void DidGetAllRegistrations( |
264 const GetAllRegistrationInfosCallback& callback, | 270 const GetAllRegistrationInfosCallback& callback, |
265 RegistrationList* registrations, | 271 RegistrationList* registrations, |
266 ServiceWorkerDatabase::Status status); | 272 ServiceWorkerDatabase::Status status); |
267 void DidStoreRegistration(const StatusCallback& callback, | 273 void DidGetRegistrationsForUsage(const OriginUsageCallback& callback, |
268 const GURL& origin, | 274 RegistrationList* registrations, |
269 int64 deleted_version_id, | 275 ServiceWorkerDatabase::Status status); |
270 const std::vector<int64>& newly_purgeable_resources, | 276 void DidStoreRegistration( |
271 ServiceWorkerDatabase::Status status); | 277 const StatusCallback& callback, |
278 const ServiceWorkerDatabase::RegistrationData& new_version, | |
279 const GURL& origin, | |
280 ServiceWorkerDatabase::RegistrationData* deleted_version, | |
michaeln
2014/10/28 22:00:40
or maybe use a const T& for this arg to simplify t
dmurph
2014/10/29 22:18:25
Done.
| |
281 const std::vector<int64>& newly_purgeable_resources, | |
282 ServiceWorkerDatabase::Status status); | |
272 void DidUpdateToActiveState( | 283 void DidUpdateToActiveState( |
273 const StatusCallback& callback, | 284 const StatusCallback& callback, |
274 ServiceWorkerDatabase::Status status); | 285 ServiceWorkerDatabase::Status status); |
275 void DidDeleteRegistration( | 286 void DidDeleteRegistration( |
276 const DidDeleteRegistrationParams& params, | 287 const DidDeleteRegistrationParams& params, |
277 bool origin_is_deletable, | 288 bool origin_is_deletable, |
278 int64 version_id, | 289 ServiceWorkerDatabase::RegistrationData* version, |
279 const std::vector<int64>& newly_purgeable_resources, | 290 const std::vector<int64>& newly_purgeable_resources, |
280 ServiceWorkerDatabase::Status status); | 291 ServiceWorkerDatabase::Status status); |
281 void ReturnFoundRegistration( | 292 void ReturnFoundRegistration( |
282 const FindRegistrationCallback& callback, | 293 const FindRegistrationCallback& callback, |
283 const ServiceWorkerDatabase::RegistrationData& data, | 294 const ServiceWorkerDatabase::RegistrationData& data, |
284 const ResourceList& resources); | 295 const ResourceList& resources); |
285 | 296 |
286 scoped_refptr<ServiceWorkerRegistration> GetOrCreateRegistration( | 297 scoped_refptr<ServiceWorkerRegistration> GetOrCreateRegistration( |
287 const ServiceWorkerDatabase::RegistrationData& data, | 298 const ServiceWorkerDatabase::RegistrationData& data, |
288 const ResourceList& resources); | 299 const ResourceList& resources); |
(...skipping 111 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
400 std::set<int64> pending_deletions_; | 411 std::set<int64> pending_deletions_; |
401 | 412 |
402 base::WeakPtrFactory<ServiceWorkerStorage> weak_factory_; | 413 base::WeakPtrFactory<ServiceWorkerStorage> weak_factory_; |
403 | 414 |
404 DISALLOW_COPY_AND_ASSIGN(ServiceWorkerStorage); | 415 DISALLOW_COPY_AND_ASSIGN(ServiceWorkerStorage); |
405 }; | 416 }; |
406 | 417 |
407 } // namespace content | 418 } // namespace content |
408 | 419 |
409 #endif // CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_STORAGE_H_ | 420 #endif // CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_STORAGE_H_ |
OLD | NEW |