Chromium Code Reviews| 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 |