Index: content/browser/dom_storage/dom_storage_task_runner.cc |
diff --git a/content/browser/dom_storage/dom_storage_task_runner.cc b/content/browser/dom_storage/dom_storage_task_runner.cc |
index ba2842802d4318a6f5a4d4099d756c3d7b41a1bc..c0d00d55d6e5f29342a512d6197e8b8e893e6e06 100644 |
--- a/content/browser/dom_storage/dom_storage_task_runner.cc |
+++ b/content/browser/dom_storage/dom_storage_task_runner.cc |
@@ -7,16 +7,11 @@ |
#include "base/bind.h" |
#include "base/bind_helpers.h" |
#include "base/location.h" |
+#include "base/logging.h" |
#include "base/tracked_objects.h" |
namespace content { |
-// DOMStorageTaskRunner |
- |
-bool DOMStorageTaskRunner::RunsTasksOnCurrentThread() const { |
- return IsRunningOnSequence(PRIMARY_SEQUENCE); |
-} |
- |
// DOMStorageWorkerPoolTaskRunner |
DOMStorageWorkerPoolTaskRunner::DOMStorageWorkerPoolTaskRunner( |
@@ -28,11 +23,18 @@ DOMStorageWorkerPoolTaskRunner::DOMStorageWorkerPoolTaskRunner( |
sequenced_worker_pool_(sequenced_worker_pool), |
primary_sequence_token_(primary_sequence_token), |
commit_sequence_token_(commit_sequence_token) { |
+ primary_sequence_checker_.DetachFromSequence(); |
+ commit_sequence_checker_.DetachFromSequence(); |
} |
DOMStorageWorkerPoolTaskRunner::~DOMStorageWorkerPoolTaskRunner() { |
} |
+bool DOMStorageWorkerPoolTaskRunner::RunsTasksOnCurrentThread() const { |
+ // It is valid for an implementation to always return true. |
+ return true; |
+} |
+ |
bool DOMStorageWorkerPoolTaskRunner::PostDelayedTask( |
const tracked_objects::Location& from_here, |
const base::Closure& task, |
@@ -62,10 +64,12 @@ bool DOMStorageWorkerPoolTaskRunner::PostShutdownBlockingTask( |
base::SequencedWorkerPool::BLOCK_SHUTDOWN); |
} |
-bool DOMStorageWorkerPoolTaskRunner::IsRunningOnSequence( |
- SequenceID sequence_id) const { |
- return sequenced_worker_pool_->IsRunningSequenceOnCurrentThread( |
- IDtoToken(sequence_id)); |
+void DOMStorageWorkerPoolTaskRunner::AssertIsRunningOnPrimarySequence() const { |
+ DCHECK(primary_sequence_checker_.CalledOnValidSequence()); |
+} |
+ |
+void DOMStorageWorkerPoolTaskRunner::AssertIsRunningOnCommitSequence() const { |
+ DCHECK(commit_sequence_checker_.CalledOnValidSequence()); |
} |
scoped_refptr<base::SequencedTaskRunner> |
@@ -91,6 +95,10 @@ MockDOMStorageTaskRunner::MockDOMStorageTaskRunner( |
MockDOMStorageTaskRunner::~MockDOMStorageTaskRunner() { |
} |
+bool MockDOMStorageTaskRunner::RunsTasksOnCurrentThread() const { |
+ return task_runner_->RunsTasksOnCurrentThread(); |
+} |
+ |
bool MockDOMStorageTaskRunner::PostDelayedTask( |
const tracked_objects::Location& from_here, |
const base::Closure& task, |
@@ -105,8 +113,12 @@ bool MockDOMStorageTaskRunner::PostShutdownBlockingTask( |
return task_runner_->PostTask(from_here, task); |
} |
-bool MockDOMStorageTaskRunner::IsRunningOnSequence(SequenceID) const { |
- return task_runner_->RunsTasksOnCurrentThread(); |
+void MockDOMStorageTaskRunner::AssertIsRunningOnPrimarySequence() const { |
+ DCHECK(RunsTasksOnCurrentThread()); |
+} |
+ |
+void MockDOMStorageTaskRunner::AssertIsRunningOnCommitSequence() const { |
+ DCHECK(RunsTasksOnCurrentThread()); |
} |
scoped_refptr<base::SequencedTaskRunner> |