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..a98c431c93e07de4ed188970d0e7c5183dfd7450 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,17 @@ 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 { |
+ return sequenced_worker_pool_->RunsTasksOnCurrentThread(); |
michaeln
2016/09/12 22:49:17
i think you've changed the semantics of this metho
fdoray
2016/09/13 14:24:13
This method is part of the TaskRunner interface ht
michaeln
2016/09/14 00:35:12
The base class is too abstract to provide a full d
fdoray
2016/09/14 13:23:53
Done
|
+} |
+ |
bool DOMStorageWorkerPoolTaskRunner::PostDelayedTask( |
const tracked_objects::Location& from_here, |
const base::Closure& task, |
@@ -62,10 +63,12 @@ bool DOMStorageWorkerPoolTaskRunner::PostShutdownBlockingTask( |
base::SequencedWorkerPool::BLOCK_SHUTDOWN); |
} |
-bool DOMStorageWorkerPoolTaskRunner::IsRunningOnSequence( |
- SequenceID sequence_id) const { |
- return sequenced_worker_pool_->IsRunningSequenceOnCurrentThread( |
michaeln
2016/09/12 22:49:17
wdyt about changing the impl w/o changing the publ
fdoray
2016/09/13 14:24:13
SequenceChecker::CalledOnValidThread() always retu
michaeln
2016/09/14 00:35:12
Surprising? Ok, I agree given the lack of the actu
fdoray
2016/09/14 13:23:53
Done. I rewrote the last paragraph of the CL descr
|
- 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 +94,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 +112,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> |