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

Side by Side Diff: content/browser/indexed_db/indexed_db_active_blob_registry.cc

Issue 2873333004: Rename TaskRunner::RunsTasksOnCurrentThread() in //content (Closed)
Patch Set: Created 3 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 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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 "base/bind.h" 5 #include "base/bind.h"
6 #include "base/location.h" 6 #include "base/location.h"
7 #include "base/stl_util.h" 7 #include "base/stl_util.h"
8 #include "base/task_runner.h" 8 #include "base/task_runner.h"
9 #include "content/browser/indexed_db/indexed_db_active_blob_registry.h" 9 #include "content/browser/indexed_db/indexed_db_active_blob_registry.h"
10 #include "content/browser/indexed_db/indexed_db_backing_store.h" 10 #include "content/browser/indexed_db/indexed_db_backing_store.h"
11 #include "content/browser/indexed_db/indexed_db_factory.h" 11 #include "content/browser/indexed_db/indexed_db_factory.h"
12 #include "content/browser/indexed_db/indexed_db_leveldb_coding.h" 12 #include "content/browser/indexed_db/indexed_db_leveldb_coding.h"
13 13
14 namespace content { 14 namespace content {
15 15
16 IndexedDBActiveBlobRegistry::IndexedDBActiveBlobRegistry( 16 IndexedDBActiveBlobRegistry::IndexedDBActiveBlobRegistry(
17 IndexedDBBackingStore* backing_store) 17 IndexedDBBackingStore* backing_store)
18 : backing_store_(backing_store), weak_factory_(this) {} 18 : backing_store_(backing_store), weak_factory_(this) {}
19 19
20 IndexedDBActiveBlobRegistry::~IndexedDBActiveBlobRegistry() { 20 IndexedDBActiveBlobRegistry::~IndexedDBActiveBlobRegistry() {
21 } 21 }
22 22
23 void IndexedDBActiveBlobRegistry::AddBlobRef(int64_t database_id, 23 void IndexedDBActiveBlobRegistry::AddBlobRef(int64_t database_id,
24 int64_t blob_key) { 24 int64_t blob_key) {
25 DCHECK(backing_store_); 25 DCHECK(backing_store_);
26 DCHECK(backing_store_->task_runner()->RunsTasksOnCurrentThread()); 26 DCHECK(backing_store_->task_runner()->RunsTasksInCurrentSequence());
27 DCHECK(KeyPrefix::IsValidDatabaseId(database_id)); 27 DCHECK(KeyPrefix::IsValidDatabaseId(database_id));
28 DCHECK(DatabaseMetaDataKey::IsValidBlobKey(blob_key)); 28 DCHECK(DatabaseMetaDataKey::IsValidBlobKey(blob_key));
29 DCHECK(!base::ContainsKey(deleted_dbs_, database_id)); 29 DCHECK(!base::ContainsKey(deleted_dbs_, database_id));
30 bool need_ref = use_tracker_.empty(); 30 bool need_ref = use_tracker_.empty();
31 SingleDBMap& single_db_map = use_tracker_[database_id]; 31 SingleDBMap& single_db_map = use_tracker_[database_id];
32 SingleDBMap::iterator iter = single_db_map.find(blob_key); 32 SingleDBMap::iterator iter = single_db_map.find(blob_key);
33 if (iter == single_db_map.end()) { 33 if (iter == single_db_map.end()) {
34 single_db_map[blob_key] = false; 34 single_db_map[blob_key] = false;
35 if (need_ref) { 35 if (need_ref) {
36 backing_store_->factory()->ReportOutstandingBlobs( 36 backing_store_->factory()->ReportOutstandingBlobs(
37 backing_store_->origin(), true); 37 backing_store_->origin(), true);
38 } 38 }
39 } else { 39 } else {
40 DCHECK(!need_ref); 40 DCHECK(!need_ref);
41 DCHECK(!iter->second); // You can't add a reference once it's been deleted. 41 DCHECK(!iter->second); // You can't add a reference once it's been deleted.
42 } 42 }
43 } 43 }
44 44
45 void IndexedDBActiveBlobRegistry::ReleaseBlobRef(int64_t database_id, 45 void IndexedDBActiveBlobRegistry::ReleaseBlobRef(int64_t database_id,
46 int64_t blob_key) { 46 int64_t blob_key) {
47 DCHECK(backing_store_); 47 DCHECK(backing_store_);
48 DCHECK(backing_store_->task_runner()->RunsTasksOnCurrentThread()); 48 DCHECK(backing_store_->task_runner()->RunsTasksInCurrentSequence());
49 DCHECK(KeyPrefix::IsValidDatabaseId(database_id)); 49 DCHECK(KeyPrefix::IsValidDatabaseId(database_id));
50 DCHECK(DatabaseMetaDataKey::IsValidBlobKey(blob_key)); 50 DCHECK(DatabaseMetaDataKey::IsValidBlobKey(blob_key));
51 const auto& db_pair = use_tracker_.find(database_id); 51 const auto& db_pair = use_tracker_.find(database_id);
52 if (db_pair == use_tracker_.end()) { 52 if (db_pair == use_tracker_.end()) {
53 NOTREACHED(); 53 NOTREACHED();
54 return; 54 return;
55 } 55 }
56 SingleDBMap& single_db = db_pair->second; 56 SingleDBMap& single_db = db_pair->second;
57 SingleDBMap::iterator blob_pair = single_db.find(blob_key); 57 SingleDBMap::iterator blob_pair = single_db.find(blob_key);
58 if (blob_pair == single_db.end()) { 58 if (blob_pair == single_db.end()) {
(...skipping 19 matching lines...) Expand all
78 backing_store_->ReportBlobUnused(database_id, blob_key); 78 backing_store_->ReportBlobUnused(database_id, blob_key);
79 if (use_tracker_.empty()) { 79 if (use_tracker_.empty()) {
80 backing_store_->factory()->ReportOutstandingBlobs(backing_store_->origin(), 80 backing_store_->factory()->ReportOutstandingBlobs(backing_store_->origin(),
81 false); 81 false);
82 } 82 }
83 } 83 }
84 84
85 bool IndexedDBActiveBlobRegistry::MarkDeletedCheckIfUsed(int64_t database_id, 85 bool IndexedDBActiveBlobRegistry::MarkDeletedCheckIfUsed(int64_t database_id,
86 int64_t blob_key) { 86 int64_t blob_key) {
87 DCHECK(backing_store_); 87 DCHECK(backing_store_);
88 DCHECK(backing_store_->task_runner()->RunsTasksOnCurrentThread()); 88 DCHECK(backing_store_->task_runner()->RunsTasksInCurrentSequence());
89 DCHECK(KeyPrefix::IsValidDatabaseId(database_id)); 89 DCHECK(KeyPrefix::IsValidDatabaseId(database_id));
90 const auto& db_pair = use_tracker_.find(database_id); 90 const auto& db_pair = use_tracker_.find(database_id);
91 if (db_pair == use_tracker_.end()) 91 if (db_pair == use_tracker_.end())
92 return false; 92 return false;
93 93
94 if (blob_key == DatabaseMetaDataKey::kAllBlobsKey) { 94 if (blob_key == DatabaseMetaDataKey::kAllBlobsKey) {
95 deleted_dbs_.insert(database_id); 95 deleted_dbs_.insert(database_id);
96 return true; 96 return true;
97 } 97 }
98 98
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after
138 blob_key); 138 blob_key);
139 } 139 }
140 140
141 void IndexedDBActiveBlobRegistry::ForceShutdown() { 141 void IndexedDBActiveBlobRegistry::ForceShutdown() {
142 weak_factory_.InvalidateWeakPtrs(); 142 weak_factory_.InvalidateWeakPtrs();
143 use_tracker_.clear(); 143 use_tracker_.clear();
144 backing_store_ = NULL; 144 backing_store_ = NULL;
145 } 145 }
146 146
147 } // namespace content 147 } // namespace content
OLDNEW
« no previous file with comments | « content/browser/fileapi/browser_file_system_helper.cc ('k') | content/browser/indexed_db/indexed_db_backing_store.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698