| Index: webkit/browser/quota/quota_manager.cc
|
| diff --git a/webkit/browser/quota/quota_manager.cc b/webkit/browser/quota/quota_manager.cc
|
| index 0663935a214a90756c9bc761b55034e3a873894e..bc94ff7fcae78df74bfedfb09b12e1cb4d5a76f6 100644
|
| --- a/webkit/browser/quota/quota_manager.cc
|
| +++ b/webkit/browser/quota/quota_manager.cc
|
| @@ -24,6 +24,7 @@
|
| #include "base/time/time.h"
|
| #include "net/base/net_util.h"
|
| #include "webkit/browser/quota/quota_database.h"
|
| +#include "webkit/browser/quota/quota_manager_proxy.h"
|
| #include "webkit/browser/quota/quota_temporary_storage_evictor.h"
|
| #include "webkit/browser/quota/usage_tracker.h"
|
| #include "webkit/common/quota/quota_types.h"
|
| @@ -43,21 +44,6 @@ const int kMinutesInMilliSeconds = 60 * 1000;
|
| const int64 kReportHistogramInterval = 60 * 60 * 1000; // 1 hour
|
| const double kTemporaryQuotaRatioToAvail = 1.0 / 3.0; // 33%
|
|
|
| -void DidGetUsageAndQuota(
|
| - base::SequencedTaskRunner* original_task_runner,
|
| - const QuotaManagerProxy::GetUsageAndQuotaCallback& callback,
|
| - QuotaStatusCode status, int64 usage, int64 quota) {
|
| - if (!original_task_runner->RunsTasksOnCurrentThread()) {
|
| - original_task_runner->PostTask(
|
| - FROM_HERE,
|
| - base::Bind(&DidGetUsageAndQuota,
|
| - make_scoped_refptr(original_task_runner),
|
| - callback, status, usage, quota));
|
| - return;
|
| - }
|
| - callback.Run(status, usage, quota);
|
| -}
|
| -
|
| } // namespace
|
|
|
| // Arbitrary for now, but must be reasonably small so that
|
| @@ -1605,130 +1591,4 @@ void QuotaManager::PostTaskAndReplyWithResultForDBThread(
|
| reply);
|
| }
|
|
|
| -// QuotaManagerProxy ----------------------------------------------------------
|
| -
|
| -void QuotaManagerProxy::RegisterClient(QuotaClient* client) {
|
| - if (!io_thread_->BelongsToCurrentThread() &&
|
| - io_thread_->PostTask(
|
| - FROM_HERE,
|
| - base::Bind(&QuotaManagerProxy::RegisterClient, this, client))) {
|
| - return;
|
| - }
|
| -
|
| - if (manager_)
|
| - manager_->RegisterClient(client);
|
| - else
|
| - client->OnQuotaManagerDestroyed();
|
| -}
|
| -
|
| -void QuotaManagerProxy::NotifyStorageAccessed(
|
| - QuotaClient::ID client_id,
|
| - const GURL& origin,
|
| - StorageType type) {
|
| - if (!io_thread_->BelongsToCurrentThread()) {
|
| - io_thread_->PostTask(
|
| - FROM_HERE,
|
| - base::Bind(&QuotaManagerProxy::NotifyStorageAccessed, this, client_id,
|
| - origin, type));
|
| - return;
|
| - }
|
| -
|
| - if (manager_)
|
| - manager_->NotifyStorageAccessed(client_id, origin, type);
|
| -}
|
| -
|
| -void QuotaManagerProxy::NotifyStorageModified(
|
| - QuotaClient::ID client_id,
|
| - const GURL& origin,
|
| - StorageType type,
|
| - int64 delta) {
|
| - if (!io_thread_->BelongsToCurrentThread()) {
|
| - io_thread_->PostTask(
|
| - FROM_HERE,
|
| - base::Bind(&QuotaManagerProxy::NotifyStorageModified, this, client_id,
|
| - origin, type, delta));
|
| - return;
|
| - }
|
| -
|
| - if (manager_)
|
| - manager_->NotifyStorageModified(client_id, origin, type, delta);
|
| -}
|
| -
|
| -void QuotaManagerProxy::NotifyOriginInUse(
|
| - const GURL& origin) {
|
| - if (!io_thread_->BelongsToCurrentThread()) {
|
| - io_thread_->PostTask(
|
| - FROM_HERE,
|
| - base::Bind(&QuotaManagerProxy::NotifyOriginInUse, this, origin));
|
| - return;
|
| - }
|
| -
|
| - if (manager_)
|
| - manager_->NotifyOriginInUse(origin);
|
| -}
|
| -
|
| -void QuotaManagerProxy::NotifyOriginNoLongerInUse(
|
| - const GURL& origin) {
|
| - if (!io_thread_->BelongsToCurrentThread()) {
|
| - io_thread_->PostTask(
|
| - FROM_HERE,
|
| - base::Bind(&QuotaManagerProxy::NotifyOriginNoLongerInUse, this,
|
| - origin));
|
| - return;
|
| - }
|
| - if (manager_)
|
| - manager_->NotifyOriginNoLongerInUse(origin);
|
| -}
|
| -
|
| -void QuotaManagerProxy::SetUsageCacheEnabled(QuotaClient::ID client_id,
|
| - const GURL& origin,
|
| - StorageType type,
|
| - bool enabled) {
|
| - if (!io_thread_->BelongsToCurrentThread()) {
|
| - io_thread_->PostTask(
|
| - FROM_HERE,
|
| - base::Bind(&QuotaManagerProxy::SetUsageCacheEnabled, this,
|
| - client_id, origin, type, enabled));
|
| - return;
|
| - }
|
| - if (manager_)
|
| - manager_->SetUsageCacheEnabled(client_id, origin, type, enabled);
|
| -}
|
| -
|
| -void QuotaManagerProxy::GetUsageAndQuota(
|
| - base::SequencedTaskRunner* original_task_runner,
|
| - const GURL& origin,
|
| - StorageType type,
|
| - const GetUsageAndQuotaCallback& callback) {
|
| - if (!io_thread_->BelongsToCurrentThread()) {
|
| - io_thread_->PostTask(
|
| - FROM_HERE,
|
| - base::Bind(&QuotaManagerProxy::GetUsageAndQuota, this,
|
| - make_scoped_refptr(original_task_runner),
|
| - origin, type, callback));
|
| - return;
|
| - }
|
| - if (!manager_) {
|
| - DidGetUsageAndQuota(original_task_runner, callback, kQuotaErrorAbort, 0, 0);
|
| - return;
|
| - }
|
| - manager_->GetUsageAndQuota(
|
| - origin, type,
|
| - base::Bind(&DidGetUsageAndQuota,
|
| - make_scoped_refptr(original_task_runner), callback));
|
| -}
|
| -
|
| -QuotaManager* QuotaManagerProxy::quota_manager() const {
|
| - DCHECK(!io_thread_.get() || io_thread_->BelongsToCurrentThread());
|
| - return manager_;
|
| -}
|
| -
|
| -QuotaManagerProxy::QuotaManagerProxy(
|
| - QuotaManager* manager, base::SingleThreadTaskRunner* io_thread)
|
| - : manager_(manager), io_thread_(io_thread) {
|
| -}
|
| -
|
| -QuotaManagerProxy::~QuotaManagerProxy() {
|
| -}
|
| -
|
| } // namespace quota
|
|
|