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

Side by Side Diff: content/browser/service_worker/service_worker_storage.h

Issue 1152543002: ServiceWorker: Migrate the script cache backend from BlockFile to Simple (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: rebase Created 5 years, 6 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 #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 <deque> 8 #include <deque>
9 #include <map> 9 #include <map>
10 #include <set> 10 #include <set>
11 #include <string> 11 #include <string>
12 #include <vector> 12 #include <vector>
13 13
14 #include "base/bind.h" 14 #include "base/bind.h"
15 #include "base/files/file_path.h" 15 #include "base/files/file_path.h"
16 #include "base/gtest_prod_util.h" 16 #include "base/gtest_prod_util.h"
17 #include "base/memory/scoped_vector.h" 17 #include "base/memory/scoped_vector.h"
18 #include "base/memory/weak_ptr.h" 18 #include "base/memory/weak_ptr.h"
19 #include "content/browser/service_worker/service_worker_database.h" 19 #include "content/browser/service_worker/service_worker_database.h"
20 #include "content/browser/service_worker/service_worker_database_task_manager.h" 20 #include "content/browser/service_worker/service_worker_database_task_manager.h"
21 #include "content/browser/service_worker/service_worker_metrics.h"
21 #include "content/browser/service_worker/service_worker_version.h" 22 #include "content/browser/service_worker/service_worker_version.h"
22 #include "content/common/content_export.h" 23 #include "content/common/content_export.h"
23 #include "content/common/service_worker/service_worker_status_code.h" 24 #include "content/common/service_worker/service_worker_status_code.h"
24 #include "url/gurl.h" 25 #include "url/gurl.h"
25 26
26 namespace base { 27 namespace base {
27 class SequencedTaskRunner; 28 class SequencedTaskRunner;
28 class SingleThreadTaskRunner; 29 class SingleThreadTaskRunner;
29 } 30 }
30 31
31 namespace storage { 32 namespace storage {
32 class QuotaManagerProxy; 33 class QuotaManagerProxy;
33 class SpecialStoragePolicy; 34 class SpecialStoragePolicy;
34 } 35 }
35 36
36 namespace content { 37 namespace content {
37 38
38 class ServiceWorkerContextCore; 39 class ServiceWorkerContextCore;
39 class ServiceWorkerDiskCache; 40 class ServiceWorkerDiskCache;
41 class ServiceWorkerDiskCacheMigrator;
40 class ServiceWorkerRegistration; 42 class ServiceWorkerRegistration;
41 class ServiceWorkerResponseMetadataWriter; 43 class ServiceWorkerResponseMetadataWriter;
42 class ServiceWorkerResponseReader; 44 class ServiceWorkerResponseReader;
43 class ServiceWorkerResponseWriter; 45 class ServiceWorkerResponseWriter;
44 struct ServiceWorkerRegistrationInfo; 46 struct ServiceWorkerRegistrationInfo;
45 47
46 // This class provides an interface to store and retrieve ServiceWorker 48 // This class provides an interface to store and retrieve ServiceWorker
47 // registration data. 49 // registration data.
48 class CONTENT_EXPORT ServiceWorkerStorage 50 class CONTENT_EXPORT ServiceWorkerStorage
49 : NON_EXPORTED_BASE(public ServiceWorkerVersion::Listener) { 51 : NON_EXPORTED_BASE(public ServiceWorkerVersion::Listener) {
(...skipping 156 matching lines...) Expand 10 before | Expand all | Expand 10 after
206 208
207 // |resources| must already be on the purgeable list. 209 // |resources| must already be on the purgeable list.
208 void PurgeResources(const ResourceList& resources); 210 void PurgeResources(const ResourceList& resources);
209 211
210 private: 212 private:
211 friend class ServiceWorkerHandleTest; 213 friend class ServiceWorkerHandleTest;
212 friend class ServiceWorkerStorageTest; 214 friend class ServiceWorkerStorageTest;
213 friend class ServiceWorkerResourceStorageTest; 215 friend class ServiceWorkerResourceStorageTest;
214 friend class ServiceWorkerControlleeRequestHandlerTest; 216 friend class ServiceWorkerControlleeRequestHandlerTest;
215 friend class ServiceWorkerContextRequestHandlerTest; 217 friend class ServiceWorkerContextRequestHandlerTest;
218 friend class ServiceWorkerDiskCacheMigratorTest;
216 friend class ServiceWorkerRequestHandlerTest; 219 friend class ServiceWorkerRequestHandlerTest;
217 friend class ServiceWorkerURLRequestJobTest; 220 friend class ServiceWorkerURLRequestJobTest;
218 friend class ServiceWorkerVersionBrowserTest; 221 friend class ServiceWorkerVersionBrowserTest;
219 friend class ServiceWorkerVersionTest; 222 friend class ServiceWorkerVersionTest;
220 friend class ServiceWorkerWriteToCacheJobTest; 223 friend class ServiceWorkerWriteToCacheJobTest;
224 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerDiskCacheMigratorTest,
225 MigrateOnDiskCacheAccess);
226 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerDiskCacheMigratorTest,
227 NotMigrateOnDatabaseAccess);
228 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerDiskCacheMigratorTest,
229 NotMigrateForEmptyDatabase);
221 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerDispatcherHostTest, 230 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerDispatcherHostTest,
222 CleanupOnRendererCrash); 231 CleanupOnRendererCrash);
223 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerResourceStorageTest, 232 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerResourceStorageTest,
224 DeleteRegistration_NoLiveVersion); 233 DeleteRegistration_NoLiveVersion);
225 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerResourceStorageTest, 234 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerResourceStorageTest,
226 DeleteRegistration_WaitingVersion); 235 DeleteRegistration_WaitingVersion);
227 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerResourceStorageTest, 236 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerResourceStorageTest,
228 DeleteRegistration_ActiveVersion); 237 DeleteRegistration_ActiveVersion);
229 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerResourceStorageTest, 238 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerResourceStorageTest,
230 UpdateRegistration); 239 UpdateRegistration);
231 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerResourceStorageDiskTest, 240 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerResourceStorageDiskTest,
232 CleanupOnRestart); 241 CleanupOnRestart);
233 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerResourceStorageDiskTest, 242 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerResourceStorageDiskTest,
234 ClearOnExit); 243 ClearOnExit);
235 244
236 struct InitialData { 245 struct InitialData {
237 int64 next_registration_id; 246 int64 next_registration_id;
238 int64 next_version_id; 247 int64 next_version_id;
239 int64 next_resource_id; 248 int64 next_resource_id;
240 std::set<GURL> origins; 249 std::set<GURL> origins;
250 bool disk_cache_migration_needed;
251 bool old_disk_cache_deletion_needed;
241 252
242 InitialData(); 253 InitialData();
243 ~InitialData(); 254 ~InitialData();
244 }; 255 };
245 256
246 // Because there are too many params for base::Bind to wrap a closure around. 257 // Because there are too many params for base::Bind to wrap a closure around.
247 struct DidDeleteRegistrationParams { 258 struct DidDeleteRegistrationParams {
248 int64 registration_id; 259 int64 registration_id;
249 GURL origin; 260 GURL origin;
250 StatusCallback callback; 261 StatusCallback callback;
251 262
252 DidDeleteRegistrationParams(); 263 DidDeleteRegistrationParams();
253 ~DidDeleteRegistrationParams(); 264 ~DidDeleteRegistrationParams();
254 }; 265 };
255 266
256 typedef std::vector<ServiceWorkerDatabase::RegistrationData> RegistrationList; 267 typedef std::vector<ServiceWorkerDatabase::RegistrationData> RegistrationList;
257 typedef std::map<int64, scoped_refptr<ServiceWorkerRegistration> > 268 typedef std::map<int64, scoped_refptr<ServiceWorkerRegistration> >
258 RegistrationRefsById; 269 RegistrationRefsById;
259 typedef base::Callback<void( 270 typedef base::Callback<void(InitialData* data,
260 InitialData* data, 271 ServiceWorkerDatabase::Status status)>
261 ServiceWorkerDatabase::Status status)> InitializeCallback; 272 InitializeCallback;
273 typedef base::Callback<void(ServiceWorkerDatabase::Status status)>
274 DatabaseStatusCallback;
262 typedef base::Callback<void( 275 typedef base::Callback<void(
263 const GURL& origin, 276 const GURL& origin,
264 const ServiceWorkerDatabase::RegistrationData& deleted_version_data, 277 const ServiceWorkerDatabase::RegistrationData& deleted_version_data,
265 const std::vector<int64>& newly_purgeable_resources, 278 const std::vector<int64>& newly_purgeable_resources,
266 ServiceWorkerDatabase::Status status)> WriteRegistrationCallback; 279 ServiceWorkerDatabase::Status status)> WriteRegistrationCallback;
267 typedef base::Callback<void( 280 typedef base::Callback<void(
268 bool origin_is_deletable, 281 bool origin_is_deletable,
269 const ServiceWorkerDatabase::RegistrationData& deleted_version_data, 282 const ServiceWorkerDatabase::RegistrationData& deleted_version_data,
270 const std::vector<int64>& newly_purgeable_resources, 283 const std::vector<int64>& newly_purgeable_resources,
271 ServiceWorkerDatabase::Status status)> DeleteRegistrationCallback; 284 ServiceWorkerDatabase::Status status)> DeleteRegistrationCallback;
(...skipping 16 matching lines...) Expand all
288 const base::FilePath& path, 301 const base::FilePath& path,
289 base::WeakPtr<ServiceWorkerContextCore> context, 302 base::WeakPtr<ServiceWorkerContextCore> context,
290 scoped_ptr<ServiceWorkerDatabaseTaskManager> database_task_manager, 303 scoped_ptr<ServiceWorkerDatabaseTaskManager> database_task_manager,
291 const scoped_refptr<base::SingleThreadTaskRunner>& disk_cache_thread, 304 const scoped_refptr<base::SingleThreadTaskRunner>& disk_cache_thread,
292 storage::QuotaManagerProxy* quota_manager_proxy, 305 storage::QuotaManagerProxy* quota_manager_proxy,
293 storage::SpecialStoragePolicy* special_storage_policy); 306 storage::SpecialStoragePolicy* special_storage_policy);
294 307
295 base::FilePath GetDatabasePath(); 308 base::FilePath GetDatabasePath();
296 base::FilePath GetDiskCachePath(); 309 base::FilePath GetDiskCachePath();
297 310
298 // Loads the registration data from backend storage. This must be called 311 // Returns a path to an old diskcache backed with BlockFile. This is used for
299 // before any method that requires registration data. 312 // the diskcache migration (see service_worker_disk_cache_migrator.h).
313 // TODO(nhiroki): Remove this after several milestones pass
314 // (http://crbug.com/487482)
315 base::FilePath GetOldDiskCachePath();
316
300 bool LazyInitialize( 317 bool LazyInitialize(
301 const base::Closure& callback); 318 const base::Closure& callback);
302 void DidReadInitialData( 319 void DidReadInitialData(InitialData* data,
303 InitialData* data, 320 ServiceWorkerDatabase::Status status);
304 ServiceWorkerDatabase::Status status);
305 void DidFindRegistrationForDocument( 321 void DidFindRegistrationForDocument(
306 const GURL& document_url, 322 const GURL& document_url,
307 const FindRegistrationCallback& callback, 323 const FindRegistrationCallback& callback,
308 int64 callback_id, 324 int64 callback_id,
309 const ServiceWorkerDatabase::RegistrationData& data, 325 const ServiceWorkerDatabase::RegistrationData& data,
310 const ResourceList& resources, 326 const ResourceList& resources,
311 ServiceWorkerDatabase::Status status); 327 ServiceWorkerDatabase::Status status);
312 void DidFindRegistrationForPattern( 328 void DidFindRegistrationForPattern(
313 const GURL& scope, 329 const GURL& scope,
314 const FindRegistrationCallback& callback, 330 const FindRegistrationCallback& callback,
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after
369 const ResourceList& resources); 385 const ResourceList& resources);
370 ServiceWorkerRegistration* FindInstallingRegistrationForDocument( 386 ServiceWorkerRegistration* FindInstallingRegistrationForDocument(
371 const GURL& document_url); 387 const GURL& document_url);
372 ServiceWorkerRegistration* FindInstallingRegistrationForPattern( 388 ServiceWorkerRegistration* FindInstallingRegistrationForPattern(
373 const GURL& scope); 389 const GURL& scope);
374 ServiceWorkerRegistration* FindInstallingRegistrationForId( 390 ServiceWorkerRegistration* FindInstallingRegistrationForId(
375 int64 registration_id); 391 int64 registration_id);
376 392
377 // Lazy disk_cache getter. 393 // Lazy disk_cache getter.
378 ServiceWorkerDiskCache* disk_cache(); 394 ServiceWorkerDiskCache* disk_cache();
395 void MigrateDiskCache();
396 void DidMigrateDiskCache(ServiceWorkerStatusCode status);
397 void DidSetDiskCacheMigrationNotNeeded(ServiceWorkerDatabase::Status status);
398 void OnDiskCacheMigrationFailed();
399 void InitializeDiskCache();
379 void OnDiskCacheInitialized(int rv); 400 void OnDiskCacheInitialized(int rv);
380 401
381 void StartPurgingResources(const std::vector<int64>& ids); 402 void StartPurgingResources(const std::vector<int64>& ids);
382 void StartPurgingResources(const ResourceList& resources); 403 void StartPurgingResources(const ResourceList& resources);
383 void ContinuePurgingResources(); 404 void ContinuePurgingResources();
384 void PurgeResource(int64 id); 405 void PurgeResource(int64 id);
385 void OnResourcePurged(int64 id, int rv); 406 void OnResourcePurged(int64 id, int rv);
386 407
387 // Deletes purgeable and uncommitted resources left over from the previous 408 // Deletes purgeable and uncommitted resources left over from the previous
388 // browser session. This must be called once per session before any database 409 // browser session. This must be called once per session before any database
389 // operation that may mutate the purgeable or uncommitted resource lists. 410 // operation that may mutate the purgeable or uncommitted resource lists.
390 void DeleteStaleResources(); 411 void DeleteStaleResources();
391 void DidCollectStaleResources(const std::vector<int64>& stale_resource_ids, 412 void DidCollectStaleResources(const std::vector<int64>& stale_resource_ids,
392 ServiceWorkerDatabase::Status status); 413 ServiceWorkerDatabase::Status status);
393 414
394 void ClearSessionOnlyOrigins(); 415 void ClearSessionOnlyOrigins();
395 416
396 // Static cross-thread helpers. 417 // Static cross-thread helpers.
397 static void CollectStaleResourcesFromDB( 418 static void CollectStaleResourcesFromDB(
398 ServiceWorkerDatabase* database, 419 ServiceWorkerDatabase* database,
399 scoped_refptr<base::SequencedTaskRunner> original_task_runner, 420 scoped_refptr<base::SequencedTaskRunner> original_task_runner,
400 const GetResourcesCallback& callback); 421 const GetResourcesCallback& callback);
401 static void ReadInitialDataFromDB( 422 static void ReadInitialDataFromDB(
402 ServiceWorkerDatabase* database, 423 ServiceWorkerDatabase* database,
403 scoped_refptr<base::SequencedTaskRunner> original_task_runner, 424 scoped_refptr<base::SequencedTaskRunner> original_task_runner,
404 const InitializeCallback& callback); 425 const InitializeCallback& callback);
426 static void DeleteOldDiskCacheInDB(ServiceWorkerDatabase* database,
427 const base::FilePath& disk_cache_path);
405 static void DeleteRegistrationFromDB( 428 static void DeleteRegistrationFromDB(
406 ServiceWorkerDatabase* database, 429 ServiceWorkerDatabase* database,
407 scoped_refptr<base::SequencedTaskRunner> original_task_runner, 430 scoped_refptr<base::SequencedTaskRunner> original_task_runner,
408 int64 registration_id, 431 int64 registration_id,
409 const GURL& origin, 432 const GURL& origin,
410 const DeleteRegistrationCallback& callback); 433 const DeleteRegistrationCallback& callback);
411 static void WriteRegistrationInDB( 434 static void WriteRegistrationInDB(
412 ServiceWorkerDatabase* database, 435 ServiceWorkerDatabase* database,
413 scoped_refptr<base::SequencedTaskRunner> original_task_runner, 436 scoped_refptr<base::SequencedTaskRunner> original_task_runner,
414 const ServiceWorkerDatabase::RegistrationData& registration, 437 const ServiceWorkerDatabase::RegistrationData& registration,
(...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after
483 base::FilePath path_; 506 base::FilePath path_;
484 base::WeakPtr<ServiceWorkerContextCore> context_; 507 base::WeakPtr<ServiceWorkerContextCore> context_;
485 508
486 // Only accessed using |database_task_manager_|. 509 // Only accessed using |database_task_manager_|.
487 scoped_ptr<ServiceWorkerDatabase> database_; 510 scoped_ptr<ServiceWorkerDatabase> database_;
488 511
489 scoped_ptr<ServiceWorkerDatabaseTaskManager> database_task_manager_; 512 scoped_ptr<ServiceWorkerDatabaseTaskManager> database_task_manager_;
490 scoped_refptr<base::SingleThreadTaskRunner> disk_cache_thread_; 513 scoped_refptr<base::SingleThreadTaskRunner> disk_cache_thread_;
491 scoped_refptr<storage::QuotaManagerProxy> quota_manager_proxy_; 514 scoped_refptr<storage::QuotaManagerProxy> quota_manager_proxy_;
492 scoped_refptr<storage::SpecialStoragePolicy> special_storage_policy_; 515 scoped_refptr<storage::SpecialStoragePolicy> special_storage_policy_;
516
493 scoped_ptr<ServiceWorkerDiskCache> disk_cache_; 517 scoped_ptr<ServiceWorkerDiskCache> disk_cache_;
518 scoped_ptr<ServiceWorkerDiskCacheMigrator> disk_cache_migrator_;
519 bool disk_cache_migration_needed_;
520 bool old_disk_cache_deletion_needed_;
521
494 std::deque<int64> purgeable_resource_ids_; 522 std::deque<int64> purgeable_resource_ids_;
495 bool is_purge_pending_; 523 bool is_purge_pending_;
496 bool has_checked_for_stale_resources_; 524 bool has_checked_for_stale_resources_;
497 std::set<int64> pending_deletions_; 525 std::set<int64> pending_deletions_;
498 526
499 base::WeakPtrFactory<ServiceWorkerStorage> weak_factory_; 527 base::WeakPtrFactory<ServiceWorkerStorage> weak_factory_;
500 528
501 DISALLOW_COPY_AND_ASSIGN(ServiceWorkerStorage); 529 DISALLOW_COPY_AND_ASSIGN(ServiceWorkerStorage);
502 }; 530 };
503 531
504 } // namespace content 532 } // namespace content
505 533
506 #endif // CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_STORAGE_H_ 534 #endif // CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_STORAGE_H_
OLDNEW
« no previous file with comments | « content/browser/service_worker/service_worker_metrics.cc ('k') | content/browser/service_worker/service_worker_storage.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698