Index: content/browser/indexed_db/indexed_db_quota_client.cc |
diff --git a/content/browser/indexed_db/indexed_db_quota_client.cc b/content/browser/indexed_db/indexed_db_quota_client.cc |
index eedd3226e7e70ba042c0d672e014547f9f06135f..dac82bc4d3ebeb86c92e853f866c18f6548f6fa5 100644 |
--- a/content/browser/indexed_db/indexed_db_quota_client.cc |
+++ b/content/browser/indexed_db/indexed_db_quota_client.cc |
@@ -7,7 +7,6 @@ |
#include <vector> |
#include "base/logging.h" |
-#include "base/message_loop/message_loop_proxy.h" |
#include "content/browser/indexed_db/indexed_db_context_impl.h" |
#include "content/public/browser/browser_thread.h" |
#include "net/base/net_util.h" |
@@ -19,22 +18,22 @@ using webkit_database::DatabaseUtil; |
namespace content { |
namespace { |
-quota::QuotaStatusCode DeleteOriginDataOnWebKitThread( |
+quota::QuotaStatusCode DeleteOriginDataOnIndexedDBThread( |
IndexedDBContextImpl* context, |
const GURL& origin) { |
context->DeleteForOrigin(origin); |
return quota::kQuotaStatusOk; |
} |
-int64 GetOriginUsageOnWebKitThread(IndexedDBContextImpl* context, |
+int64 GetOriginUsageOnIndexedDBThread(IndexedDBContextImpl* context, |
const GURL& origin) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT_DEPRECATED)); |
+ DCHECK(context->OnIndexedDBThread()); |
return context->GetOriginDiskUsage(origin); |
} |
-void GetAllOriginsOnWebKitThread(IndexedDBContextImpl* context, |
+void GetAllOriginsOnIndexedDBThread(IndexedDBContextImpl* context, |
std::set<GURL>* origins_to_return) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT_DEPRECATED)); |
+ DCHECK(context->OnIndexedDBThread()); |
std::vector<GURL> all_origins = context->GetAllOrigins(); |
origins_to_return->insert(all_origins.begin(), all_origins.end()); |
} |
@@ -45,10 +44,10 @@ void DidGetOrigins(const IndexedDBQuotaClient::GetOriginsCallback& callback, |
callback.Run(*origins); |
} |
-void GetOriginsForHostOnWebKitThread(IndexedDBContextImpl* context, |
+void GetOriginsForHostOnIndexedDBThread(IndexedDBContextImpl* context, |
const std::string& host, |
std::set<GURL>* origins_to_return) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT_DEPRECATED)); |
+ DCHECK(context->OnIndexedDBThread()); |
std::vector<GURL> all_origins = context->GetAllOrigins(); |
for (std::vector<GURL>::const_iterator iter = all_origins.begin(); |
iter != all_origins.end(); |
@@ -63,10 +62,8 @@ void GetOriginsForHostOnWebKitThread(IndexedDBContextImpl* context, |
// IndexedDBQuotaClient -------------------------------------------------------- |
IndexedDBQuotaClient::IndexedDBQuotaClient( |
- base::MessageLoopProxy* webkit_thread_message_loop, |
IndexedDBContextImpl* indexed_db_context) |
- : webkit_thread_message_loop_(webkit_thread_message_loop), |
- indexed_db_context_(indexed_db_context) {} |
+ : indexed_db_context_(indexed_db_context) {} |
IndexedDBQuotaClient::~IndexedDBQuotaClient() {} |
@@ -87,10 +84,10 @@ void IndexedDBQuotaClient::GetOriginUsage(const GURL& origin_url, |
} |
base::PostTaskAndReplyWithResult( |
- webkit_thread_message_loop_.get(), |
+ indexed_db_context_->TaskRunner(), |
FROM_HERE, |
base::Bind( |
- &GetOriginUsageOnWebKitThread, indexed_db_context_, origin_url), |
+ &GetOriginUsageOnIndexedDBThread, indexed_db_context_, origin_url), |
callback); |
} |
@@ -107,9 +104,9 @@ void IndexedDBQuotaClient::GetOriginsForType( |
} |
std::set<GURL>* origins_to_return = new std::set<GURL>(); |
- webkit_thread_message_loop_->PostTaskAndReply( |
+ indexed_db_context_->TaskRunner()->PostTaskAndReply( |
FROM_HERE, |
- base::Bind(&GetAllOriginsOnWebKitThread, |
+ base::Bind(&GetAllOriginsOnIndexedDBThread, |
indexed_db_context_, |
base::Unretained(origins_to_return)), |
base::Bind(&DidGetOrigins, callback, base::Owned(origins_to_return))); |
@@ -129,9 +126,9 @@ void IndexedDBQuotaClient::GetOriginsForHost( |
} |
std::set<GURL>* origins_to_return = new std::set<GURL>(); |
- webkit_thread_message_loop_->PostTaskAndReply( |
+ indexed_db_context_->TaskRunner()->PostTaskAndReply( |
FROM_HERE, |
- base::Bind(&GetOriginsForHostOnWebKitThread, |
+ base::Bind(&GetOriginsForHostOnIndexedDBThread, |
indexed_db_context_, |
host, |
base::Unretained(origins_to_return)), |
@@ -147,9 +144,10 @@ void IndexedDBQuotaClient::DeleteOriginData(const GURL& origin, |
} |
base::PostTaskAndReplyWithResult( |
- webkit_thread_message_loop_.get(), |
+ indexed_db_context_->TaskRunner(), |
FROM_HERE, |
- base::Bind(&DeleteOriginDataOnWebKitThread, indexed_db_context_, origin), |
+ base::Bind( |
+ &DeleteOriginDataOnIndexedDBThread, indexed_db_context_, origin), |
callback); |
} |