| OLD | NEW |
| 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 "webkit/browser/database/database_quota_client.h" | 5 #include "webkit/browser/database/database_quota_client.h" |
| 6 | 6 |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/bind_helpers.h" | 10 #include "base/bind_helpers.h" |
| (...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 94 | 94 |
| 95 } // namespace | 95 } // namespace |
| 96 | 96 |
| 97 DatabaseQuotaClient::DatabaseQuotaClient( | 97 DatabaseQuotaClient::DatabaseQuotaClient( |
| 98 base::MessageLoopProxy* db_tracker_thread, | 98 base::MessageLoopProxy* db_tracker_thread, |
| 99 DatabaseTracker* db_tracker) | 99 DatabaseTracker* db_tracker) |
| 100 : db_tracker_thread_(db_tracker_thread), db_tracker_(db_tracker) { | 100 : db_tracker_thread_(db_tracker_thread), db_tracker_(db_tracker) { |
| 101 } | 101 } |
| 102 | 102 |
| 103 DatabaseQuotaClient::~DatabaseQuotaClient() { | 103 DatabaseQuotaClient::~DatabaseQuotaClient() { |
| 104 if (db_tracker_thread_ && | 104 if (db_tracker_thread_.get() && |
| 105 !db_tracker_thread_->RunsTasksOnCurrentThread() && | 105 !db_tracker_thread_->RunsTasksOnCurrentThread() && db_tracker_.get()) { |
| 106 db_tracker_) { | 106 DatabaseTracker* tracker = db_tracker_.get(); |
| 107 DatabaseTracker* tracker = db_tracker_; | |
| 108 tracker->AddRef(); | 107 tracker->AddRef(); |
| 109 db_tracker_ = NULL; | 108 db_tracker_ = NULL; |
| 110 if (!db_tracker_thread_->ReleaseSoon(FROM_HERE, tracker)) | 109 if (!db_tracker_thread_->ReleaseSoon(FROM_HERE, tracker)) |
| 111 tracker->Release(); | 110 tracker->Release(); |
| 112 } | 111 } |
| 113 } | 112 } |
| 114 | 113 |
| 115 QuotaClient::ID DatabaseQuotaClient::id() const { | 114 QuotaClient::ID DatabaseQuotaClient::id() const { |
| 116 return kDatabase; | 115 return kDatabase; |
| 117 } | 116 } |
| 118 | 117 |
| 119 void DatabaseQuotaClient::OnQuotaManagerDestroyed() { | 118 void DatabaseQuotaClient::OnQuotaManagerDestroyed() { |
| 120 delete this; | 119 delete this; |
| 121 } | 120 } |
| 122 | 121 |
| 123 void DatabaseQuotaClient::GetOriginUsage( | 122 void DatabaseQuotaClient::GetOriginUsage( |
| 124 const GURL& origin_url, | 123 const GURL& origin_url, |
| 125 quota::StorageType type, | 124 quota::StorageType type, |
| 126 const GetUsageCallback& callback) { | 125 const GetUsageCallback& callback) { |
| 127 DCHECK(!callback.is_null()); | 126 DCHECK(!callback.is_null()); |
| 128 DCHECK(db_tracker_.get()); | 127 DCHECK(db_tracker_.get()); |
| 129 | 128 |
| 130 // All databases are in the temp namespace for now. | 129 // All databases are in the temp namespace for now. |
| 131 if (type != quota::kStorageTypeTemporary) { | 130 if (type != quota::kStorageTypeTemporary) { |
| 132 callback.Run(0); | 131 callback.Run(0); |
| 133 return; | 132 return; |
| 134 } | 133 } |
| 135 | 134 |
| 136 base::PostTaskAndReplyWithResult( | 135 base::PostTaskAndReplyWithResult( |
| 137 db_tracker_thread_, | 136 db_tracker_thread_.get(), |
| 138 FROM_HERE, | 137 FROM_HERE, |
| 139 base::Bind(&GetOriginUsageOnDBThread, | 138 base::Bind(&GetOriginUsageOnDBThread, db_tracker_, origin_url), |
| 140 db_tracker_, | |
| 141 origin_url), | |
| 142 callback); | 139 callback); |
| 143 } | 140 } |
| 144 | 141 |
| 145 void DatabaseQuotaClient::GetOriginsForType( | 142 void DatabaseQuotaClient::GetOriginsForType( |
| 146 quota::StorageType type, | 143 quota::StorageType type, |
| 147 const GetOriginsCallback& callback) { | 144 const GetOriginsCallback& callback) { |
| 148 DCHECK(!callback.is_null()); | 145 DCHECK(!callback.is_null()); |
| 149 DCHECK(db_tracker_.get()); | 146 DCHECK(db_tracker_.get()); |
| 150 | 147 |
| 151 // All databases are in the temp namespace for now. | 148 // All databases are in the temp namespace for now. |
| (...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 202 callback.Run(quota::kQuotaStatusOk); | 199 callback.Run(quota::kQuotaStatusOk); |
| 203 return; | 200 return; |
| 204 } | 201 } |
| 205 | 202 |
| 206 base::Callback<void(int)> delete_callback = | 203 base::Callback<void(int)> delete_callback = |
| 207 base::Bind(&DidDeleteOriginData, | 204 base::Bind(&DidDeleteOriginData, |
| 208 base::MessageLoopProxy::current(), | 205 base::MessageLoopProxy::current(), |
| 209 callback); | 206 callback); |
| 210 | 207 |
| 211 PostTaskAndReplyWithResult( | 208 PostTaskAndReplyWithResult( |
| 212 db_tracker_thread_, | 209 db_tracker_thread_.get(), |
| 213 FROM_HERE, | 210 FROM_HERE, |
| 214 base::Bind(&DatabaseTracker::DeleteDataForOrigin, | 211 base::Bind(&DatabaseTracker::DeleteDataForOrigin, |
| 215 db_tracker_, | 212 db_tracker_, |
| 216 webkit_base::GetOriginIdentifierFromURL(origin), | 213 webkit_base::GetOriginIdentifierFromURL(origin), |
| 217 delete_callback), | 214 delete_callback), |
| 218 delete_callback); | 215 delete_callback); |
| 219 } | 216 } |
| 220 | 217 |
| 221 } // namespace webkit_database | 218 } // namespace webkit_database |
| OLD | NEW |