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

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

Issue 1815363002: Add RetainedRef uses where needed. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 4 years, 9 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 (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 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/indexed_db/indexed_db_quota_client.h" 5 #include "content/browser/indexed_db/indexed_db_quota_client.h"
6 6
7 #include <stdint.h> 7 #include <stdint.h>
8 8
9 #include <vector> 9 #include <vector>
10 10
(...skipping 72 matching lines...) Expand 10 before | Expand all | Expand 10 after
83 return; 83 return;
84 } 84 }
85 85
86 // No task runner means unit test; no cleanup necessary. 86 // No task runner means unit test; no cleanup necessary.
87 if (!indexed_db_context_->TaskRunner()) { 87 if (!indexed_db_context_->TaskRunner()) {
88 callback.Run(0); 88 callback.Run(0);
89 return; 89 return;
90 } 90 }
91 91
92 base::PostTaskAndReplyWithResult( 92 base::PostTaskAndReplyWithResult(
93 indexed_db_context_->TaskRunner(), 93 indexed_db_context_->TaskRunner(), FROM_HERE,
94 FROM_HERE, 94 base::Bind(&GetOriginUsageOnIndexedDBThread,
95 base::Bind( 95 base::RetainedRef(indexed_db_context_), origin_url),
96 &GetOriginUsageOnIndexedDBThread, indexed_db_context_, origin_url),
97 callback); 96 callback);
98 } 97 }
99 98
100 void IndexedDBQuotaClient::GetOriginsForType( 99 void IndexedDBQuotaClient::GetOriginsForType(
101 storage::StorageType type, 100 storage::StorageType type,
102 const GetOriginsCallback& callback) { 101 const GetOriginsCallback& callback) {
103 DCHECK(!callback.is_null()); 102 DCHECK(!callback.is_null());
104 DCHECK(indexed_db_context_.get()); 103 DCHECK(indexed_db_context_.get());
105 104
106 // All databases are in the temp namespace for now. 105 // All databases are in the temp namespace for now.
107 if (type != storage::kStorageTypeTemporary) { 106 if (type != storage::kStorageTypeTemporary) {
108 callback.Run(std::set<GURL>()); 107 callback.Run(std::set<GURL>());
109 return; 108 return;
110 } 109 }
111 110
112 // No task runner means unit test; no cleanup necessary. 111 // No task runner means unit test; no cleanup necessary.
113 if (!indexed_db_context_->TaskRunner()) { 112 if (!indexed_db_context_->TaskRunner()) {
114 callback.Run(std::set<GURL>()); 113 callback.Run(std::set<GURL>());
115 return; 114 return;
116 } 115 }
117 116
118 std::set<GURL>* origins_to_return = new std::set<GURL>(); 117 std::set<GURL>* origins_to_return = new std::set<GURL>();
119 indexed_db_context_->TaskRunner()->PostTaskAndReply( 118 indexed_db_context_->TaskRunner()->PostTaskAndReply(
120 FROM_HERE, 119 FROM_HERE, base::Bind(&GetAllOriginsOnIndexedDBThread,
121 base::Bind(&GetAllOriginsOnIndexedDBThread, 120 base::RetainedRef(indexed_db_context_),
122 indexed_db_context_, 121 base::Unretained(origins_to_return)),
123 base::Unretained(origins_to_return)),
124 base::Bind(&DidGetOrigins, callback, base::Owned(origins_to_return))); 122 base::Bind(&DidGetOrigins, callback, base::Owned(origins_to_return)));
125 } 123 }
126 124
127 void IndexedDBQuotaClient::GetOriginsForHost( 125 void IndexedDBQuotaClient::GetOriginsForHost(
128 storage::StorageType type, 126 storage::StorageType type,
129 const std::string& host, 127 const std::string& host,
130 const GetOriginsCallback& callback) { 128 const GetOriginsCallback& callback) {
131 DCHECK(!callback.is_null()); 129 DCHECK(!callback.is_null());
132 DCHECK(indexed_db_context_.get()); 130 DCHECK(indexed_db_context_.get());
133 131
134 // All databases are in the temp namespace for now. 132 // All databases are in the temp namespace for now.
135 if (type != storage::kStorageTypeTemporary) { 133 if (type != storage::kStorageTypeTemporary) {
136 callback.Run(std::set<GURL>()); 134 callback.Run(std::set<GURL>());
137 return; 135 return;
138 } 136 }
139 137
140 // No task runner means unit test; no cleanup necessary. 138 // No task runner means unit test; no cleanup necessary.
141 if (!indexed_db_context_->TaskRunner()) { 139 if (!indexed_db_context_->TaskRunner()) {
142 callback.Run(std::set<GURL>()); 140 callback.Run(std::set<GURL>());
143 return; 141 return;
144 } 142 }
145 143
146 std::set<GURL>* origins_to_return = new std::set<GURL>(); 144 std::set<GURL>* origins_to_return = new std::set<GURL>();
147 indexed_db_context_->TaskRunner()->PostTaskAndReply( 145 indexed_db_context_->TaskRunner()->PostTaskAndReply(
148 FROM_HERE, 146 FROM_HERE, base::Bind(&GetOriginsForHostOnIndexedDBThread,
149 base::Bind(&GetOriginsForHostOnIndexedDBThread, 147 base::RetainedRef(indexed_db_context_), host,
150 indexed_db_context_, 148 base::Unretained(origins_to_return)),
151 host,
152 base::Unretained(origins_to_return)),
153 base::Bind(&DidGetOrigins, callback, base::Owned(origins_to_return))); 149 base::Bind(&DidGetOrigins, callback, base::Owned(origins_to_return)));
154 } 150 }
155 151
156 void IndexedDBQuotaClient::DeleteOriginData(const GURL& origin, 152 void IndexedDBQuotaClient::DeleteOriginData(const GURL& origin,
157 storage::StorageType type, 153 storage::StorageType type,
158 const DeletionCallback& callback) { 154 const DeletionCallback& callback) {
159 if (type != storage::kStorageTypeTemporary) { 155 if (type != storage::kStorageTypeTemporary) {
160 callback.Run(storage::kQuotaErrorNotSupported); 156 callback.Run(storage::kQuotaErrorNotSupported);
161 return; 157 return;
162 } 158 }
163 159
164 // No task runner means unit test; no cleanup necessary. 160 // No task runner means unit test; no cleanup necessary.
165 if (!indexed_db_context_->TaskRunner()) { 161 if (!indexed_db_context_->TaskRunner()) {
166 callback.Run(storage::kQuotaStatusOk); 162 callback.Run(storage::kQuotaStatusOk);
167 return; 163 return;
168 } 164 }
169 165
170 base::PostTaskAndReplyWithResult( 166 base::PostTaskAndReplyWithResult(
171 indexed_db_context_->TaskRunner(), 167 indexed_db_context_->TaskRunner(), FROM_HERE,
172 FROM_HERE, 168 base::Bind(&DeleteOriginDataOnIndexedDBThread,
173 base::Bind( 169 base::RetainedRef(indexed_db_context_), origin),
174 &DeleteOriginDataOnIndexedDBThread, indexed_db_context_, origin),
175 callback); 170 callback);
176 } 171 }
177 172
178 bool IndexedDBQuotaClient::DoesSupport(storage::StorageType type) const { 173 bool IndexedDBQuotaClient::DoesSupport(storage::StorageType type) const {
179 return type == storage::kStorageTypeTemporary; 174 return type == storage::kStorageTypeTemporary;
180 } 175 }
181 176
182 } // namespace content 177 } // namespace content
OLDNEW
« no previous file with comments | « content/browser/download/save_package.cc ('k') | content/browser/loader/async_revalidation_driver_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698