OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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/in_process_webkit/indexed_db_quota_client.h" | 5 #include "content/browser/in_process_webkit/indexed_db_quota_client.h" |
6 | 6 |
7 #include <vector> | 7 #include <vector> |
8 | 8 |
9 #include "base/file_util.h" | 9 #include "base/file_util.h" |
10 #include "base/message_loop_proxy.h" | 10 #include "base/message_loop_proxy.h" |
(...skipping 66 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
77 } | 77 } |
78 } | 78 } |
79 | 79 |
80 std::set<GURL> origins_; | 80 std::set<GURL> origins_; |
81 }; | 81 }; |
82 | 82 |
83 class IndexedDBQuotaClient::GetAllOriginsTask : public GetOriginsTaskBase { | 83 class IndexedDBQuotaClient::GetAllOriginsTask : public GetOriginsTaskBase { |
84 public: | 84 public: |
85 GetAllOriginsTask( | 85 GetAllOriginsTask( |
86 IndexedDBQuotaClient* client, | 86 IndexedDBQuotaClient* client, |
87 base::MessageLoopProxy* webkit_thread_message_loop) | 87 base::MessageLoopProxy* webkit_thread_message_loop, |
88 : GetOriginsTaskBase(client, webkit_thread_message_loop) { | 88 quota::StorageType type) |
| 89 : GetOriginsTaskBase(client, webkit_thread_message_loop), |
| 90 type_(type) { |
89 } | 91 } |
90 | 92 |
91 protected: | 93 protected: |
92 virtual bool ShouldAddOrigin(const GURL& origin) OVERRIDE { | 94 virtual bool ShouldAddOrigin(const GURL& origin) OVERRIDE { |
93 return true; | 95 return true; |
94 } | 96 } |
95 virtual void Completed() OVERRIDE { | 97 virtual void Completed() OVERRIDE { |
96 client_->DidGetAllOrigins(origins_); | 98 client_->DidGetAllOrigins(origins_, type_); |
97 } | 99 } |
| 100 |
| 101 private: |
| 102 quota::StorageType type_; |
98 }; | 103 }; |
99 | 104 |
100 class IndexedDBQuotaClient::GetOriginsForHostTask : public GetOriginsTaskBase { | 105 class IndexedDBQuotaClient::GetOriginsForHostTask : public GetOriginsTaskBase { |
101 public: | 106 public: |
102 GetOriginsForHostTask( | 107 GetOriginsForHostTask( |
103 IndexedDBQuotaClient* client, | 108 IndexedDBQuotaClient* client, |
104 base::MessageLoopProxy* webkit_thread_message_loop, | 109 base::MessageLoopProxy* webkit_thread_message_loop, |
105 const std::string& host) | 110 const std::string& host, |
| 111 quota::StorageType type) |
106 : GetOriginsTaskBase(client, webkit_thread_message_loop), | 112 : GetOriginsTaskBase(client, webkit_thread_message_loop), |
107 host_(host) { | 113 host_(host), |
| 114 type_(type) { |
108 } | 115 } |
109 | 116 |
110 private: | 117 private: |
111 virtual bool ShouldAddOrigin(const GURL& origin) OVERRIDE { | 118 virtual bool ShouldAddOrigin(const GURL& origin) OVERRIDE { |
112 return host_ == net::GetHostOrSpecFromURL(origin); | 119 return host_ == net::GetHostOrSpecFromURL(origin); |
113 } | 120 } |
114 virtual void Completed() OVERRIDE { | 121 virtual void Completed() OVERRIDE { |
115 client_->DidGetOriginsForHost(host_, origins_); | 122 client_->DidGetOriginsForHost(host_, origins_, type_); |
116 } | 123 } |
117 std::string host_; | 124 std::string host_; |
| 125 quota::StorageType type_; |
118 }; | 126 }; |
119 | 127 |
120 // IndexedDBQuotaClient -------------------------------------------------------- | 128 // IndexedDBQuotaClient -------------------------------------------------------- |
121 | 129 |
122 IndexedDBQuotaClient::IndexedDBQuotaClient( | 130 IndexedDBQuotaClient::IndexedDBQuotaClient( |
123 base::MessageLoopProxy* webkit_thread_message_loop, | 131 base::MessageLoopProxy* webkit_thread_message_loop, |
124 IndexedDBContext* indexed_db_context) | 132 IndexedDBContext* indexed_db_context) |
125 : webkit_thread_message_loop_(webkit_thread_message_loop), | 133 : webkit_thread_message_loop_(webkit_thread_message_loop), |
126 indexed_db_context_(indexed_db_context) { | 134 indexed_db_context_(indexed_db_context) { |
127 } | 135 } |
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
160 | 168 |
161 void IndexedDBQuotaClient::GetOriginsForType( | 169 void IndexedDBQuotaClient::GetOriginsForType( |
162 quota::StorageType type, | 170 quota::StorageType type, |
163 GetOriginsCallback* callback_ptr) { | 171 GetOriginsCallback* callback_ptr) { |
164 DCHECK(callback_ptr); | 172 DCHECK(callback_ptr); |
165 DCHECK(indexed_db_context_.get()); | 173 DCHECK(indexed_db_context_.get()); |
166 scoped_ptr<GetOriginsCallback> callback(callback_ptr); | 174 scoped_ptr<GetOriginsCallback> callback(callback_ptr); |
167 | 175 |
168 // All databases are in the temp namespace for now. | 176 // All databases are in the temp namespace for now. |
169 if (type != quota::kStorageTypeTemporary) { | 177 if (type != quota::kStorageTypeTemporary) { |
170 callback->Run(std::set<GURL>()); | 178 callback->Run(std::set<GURL>(), type); |
171 return; | 179 return; |
172 } | 180 } |
173 | 181 |
174 if (origins_for_type_callbacks_.Add(callback.release())) { | 182 if (origins_for_type_callbacks_.Add(callback.release())) { |
175 scoped_refptr<GetAllOriginsTask> task( | 183 scoped_refptr<GetAllOriginsTask> task( |
176 new GetAllOriginsTask(this, webkit_thread_message_loop_)); | 184 new GetAllOriginsTask(this, webkit_thread_message_loop_, type)); |
177 task->Start(); | 185 task->Start(); |
178 } | 186 } |
179 } | 187 } |
180 | 188 |
181 void IndexedDBQuotaClient::GetOriginsForHost( | 189 void IndexedDBQuotaClient::GetOriginsForHost( |
182 quota::StorageType type, | 190 quota::StorageType type, |
183 const std::string& host, | 191 const std::string& host, |
184 GetOriginsCallback* callback_ptr) { | 192 GetOriginsCallback* callback_ptr) { |
185 DCHECK(callback_ptr); | 193 DCHECK(callback_ptr); |
186 DCHECK(indexed_db_context_.get()); | 194 DCHECK(indexed_db_context_.get()); |
187 scoped_ptr<GetOriginsCallback> callback(callback_ptr); | 195 scoped_ptr<GetOriginsCallback> callback(callback_ptr); |
188 | 196 |
189 // All databases are in the temp namespace for now. | 197 // All databases are in the temp namespace for now. |
190 if (type != quota::kStorageTypeTemporary) { | 198 if (type != quota::kStorageTypeTemporary) { |
191 callback->Run(std::set<GURL>()); | 199 callback->Run(std::set<GURL>(), type); |
192 return; | 200 return; |
193 } | 201 } |
194 | 202 |
195 if (origins_for_host_callbacks_.Add(host, callback.release())) { | 203 if (origins_for_host_callbacks_.Add(host, callback.release())) { |
196 scoped_refptr<GetOriginsForHostTask> task( | 204 scoped_refptr<GetOriginsForHostTask> task( |
197 new GetOriginsForHostTask(this, webkit_thread_message_loop_, host)); | 205 new GetOriginsForHostTask( |
| 206 this, webkit_thread_message_loop_, host, type)); |
198 task->Start(); | 207 task->Start(); |
199 } | 208 } |
200 } | 209 } |
201 | 210 |
202 void IndexedDBQuotaClient::DeleteOriginData(const GURL& origin, | 211 void IndexedDBQuotaClient::DeleteOriginData(const GURL& origin, |
203 quota::StorageType type, | 212 quota::StorageType type, |
204 DeletionCallback* callback) { | 213 DeletionCallback* callback) { |
205 // TODO(tzik): implement me | 214 // TODO(tzik): implement me |
206 callback->Run(quota::kQuotaErrorNotSupported); | 215 callback->Run(quota::kQuotaErrorNotSupported); |
207 delete callback; | 216 delete callback; |
208 } | 217 } |
209 | 218 |
210 void IndexedDBQuotaClient::DidGetOriginUsage( | 219 void IndexedDBQuotaClient::DidGetOriginUsage( |
211 const GURL& origin_url, int64 usage) { | 220 const GURL& origin_url, int64 usage) { |
212 DCHECK(usage_for_origin_callbacks_.HasCallbacks(origin_url)); | 221 DCHECK(usage_for_origin_callbacks_.HasCallbacks(origin_url)); |
213 usage_for_origin_callbacks_.Run(origin_url, usage); | 222 usage_for_origin_callbacks_.Run(origin_url, usage); |
214 } | 223 } |
215 | 224 |
216 void IndexedDBQuotaClient::DidGetAllOrigins(const std::set<GURL>& origins) { | 225 void IndexedDBQuotaClient::DidGetAllOrigins(const std::set<GURL>& origins, |
| 226 quota::StorageType type) { |
217 DCHECK(origins_for_type_callbacks_.HasCallbacks()); | 227 DCHECK(origins_for_type_callbacks_.HasCallbacks()); |
218 origins_for_type_callbacks_.Run(origins); | 228 origins_for_type_callbacks_.Run(origins, type); |
219 } | 229 } |
220 | 230 |
221 void IndexedDBQuotaClient::DidGetOriginsForHost( | 231 void IndexedDBQuotaClient::DidGetOriginsForHost( |
222 const std::string& host, const std::set<GURL>& origins) { | 232 const std::string& host, const std::set<GURL>& origins, |
| 233 quota::StorageType type) { |
223 DCHECK(origins_for_host_callbacks_.HasCallbacks(host)); | 234 DCHECK(origins_for_host_callbacks_.HasCallbacks(host)); |
224 origins_for_host_callbacks_.Run(host, origins); | 235 origins_for_host_callbacks_.Run(host, origins, type); |
225 } | 236 } |
OLD | NEW |