Index: content/browser/dom_storage/dom_storage_context_impl_new.cc |
=================================================================== |
--- content/browser/dom_storage/dom_storage_context_impl_new.cc (revision 127736) |
+++ content/browser/dom_storage/dom_storage_context_impl_new.cc (working copy) |
@@ -21,6 +21,7 @@ |
using content::DOMStorageContext; |
using dom_storage::DomStorageArea; |
using dom_storage::DomStorageContext; |
+using dom_storage::DomStorageTaskRunner; |
using dom_storage::DomStorageWorkerPoolTaskRunner; |
using webkit_database::DatabaseUtil; |
@@ -85,7 +86,8 @@ |
special_storage_policy, |
new DomStorageWorkerPoolTaskRunner( |
worker_pool, |
- worker_pool->GetNamedSequenceToken("dom_storage"), |
+ worker_pool->GetNamedSequenceToken("dom_storage_primary"), |
+ worker_pool->GetNamedSequenceToken("dom_storage_commit"), |
BrowserThread::GetMessageLoopProxyForThread(BrowserThread::IO))); |
} |
@@ -95,8 +97,9 @@ |
void DOMStorageContextImpl::GetAllStorageFiles( |
const GetAllStorageFilesCallback& callback) { |
DCHECK(context_); |
- context_->task_runner()->PostTask( |
+ context_->task_runner()->PostShutdownBlockingTask( |
FROM_HERE, |
+ DomStorageTaskRunner::PRIMARY_SEQUENCE, |
base::Bind(&GetAllStorageFilesHelper, |
base::MessageLoopProxy::current(), |
context_, callback)); |
@@ -109,54 +112,61 @@ |
void DOMStorageContextImpl::DeleteForOrigin(const string16& origin_id) { |
DCHECK(context_); |
- context_->task_runner()->PostTask( |
+ context_->task_runner()->PostShutdownBlockingTask( |
FROM_HERE, |
+ DomStorageTaskRunner::PRIMARY_SEQUENCE, |
base::Bind(&DomStorageContext::DeleteOrigin, context_, |
OriginIdToGURL(origin_id))); |
} |
void DOMStorageContextImpl::DeleteLocalStorageFile(const FilePath& file_path) { |
DCHECK(context_); |
- context_->task_runner()->PostTask( |
+ context_->task_runner()->PostShutdownBlockingTask( |
FROM_HERE, |
+ DomStorageTaskRunner::PRIMARY_SEQUENCE, |
base::Bind(&DomStorageContext::DeleteOrigin, context_, |
FilePathToOrigin(file_path))); |
} |
void DOMStorageContextImpl::DeleteDataModifiedSince(const base::Time& cutoff) { |
DCHECK(context_); |
- context_->task_runner()->PostTask( |
+ context_->task_runner()->PostShutdownBlockingTask( |
FROM_HERE, |
+ DomStorageTaskRunner::PRIMARY_SEQUENCE, |
base::Bind(&DomStorageContext::DeleteDataModifiedSince, context_, |
cutoff)); |
} |
void DOMStorageContextImpl::PurgeMemory() { |
DCHECK(context_); |
- context_->task_runner()->PostTask( |
+ context_->task_runner()->PostShutdownBlockingTask( |
FROM_HERE, |
+ DomStorageTaskRunner::PRIMARY_SEQUENCE, |
base::Bind(&DomStorageContext::PurgeMemory, context_)); |
} |
void DOMStorageContextImpl::SetClearLocalState(bool clear_local_state) { |
DCHECK(context_); |
- context_->task_runner()->PostTask( |
+ context_->task_runner()->PostShutdownBlockingTask( |
FROM_HERE, |
+ DomStorageTaskRunner::PRIMARY_SEQUENCE, |
base::Bind(&DomStorageContext::SetClearLocalState, context_, |
clear_local_state)); |
} |
void DOMStorageContextImpl::SaveSessionState() { |
DCHECK(context_); |
- context_->task_runner()->PostTask( |
+ context_->task_runner()->PostShutdownBlockingTask( |
FROM_HERE, |
+ DomStorageTaskRunner::PRIMARY_SEQUENCE, |
base::Bind(&DomStorageContext::SaveSessionState, context_)); |
} |
void DOMStorageContextImpl::Shutdown() { |
DCHECK(context_); |
- context_->task_runner()->PostTask( |
+ context_->task_runner()->PostShutdownBlockingTask( |
FROM_HERE, |
+ DomStorageTaskRunner::PRIMARY_SEQUENCE, |
base::Bind(&DomStorageContext::Shutdown, context_)); |
} |