summaryrefslogtreecommitdiffstats
path: root/base/sequence_checker_impl.cc
diff options
context:
space:
mode:
Diffstat (limited to 'base/sequence_checker_impl.cc')
-rw-r--r--base/sequence_checker_impl.cc39
1 files changed, 27 insertions, 12 deletions
diff --git a/base/sequence_checker_impl.cc b/base/sequence_checker_impl.cc
index 24d9ed9..e95b8ee 100644
--- a/base/sequence_checker_impl.cc
+++ b/base/sequence_checker_impl.cc
@@ -4,28 +4,43 @@
#include "base/sequence_checker_impl.h"
-#include "base/sequenced_task_runner.h"
-
namespace base {
-SequenceCheckerImpl::SequenceCheckerImpl(
- const scoped_refptr<SequencedTaskRunner>& sequenced_task_runner)
- : sequenced_task_runner_(sequenced_task_runner) {}
+SequenceCheckerImpl::SequenceCheckerImpl()
+ : sequence_token_assigned_(false) {
+ AutoLock auto_lock(lock_);
+ EnsureSequenceTokenAssigned();
+}
SequenceCheckerImpl::~SequenceCheckerImpl() {}
-bool SequenceCheckerImpl::CalledOnValidSequence() const {
+bool SequenceCheckerImpl::CalledOnValidSequencedThread() const {
AutoLock auto_lock(lock_);
- return sequenced_task_runner_.get() ?
- sequenced_task_runner_->RunsTasksOnCurrentThread() :
- thread_checker_.CalledOnValidThread();
+ EnsureSequenceTokenAssigned();
+
+ // If this thread is not associated with a SequencedWorkerPool,
+ // SequenceChecker behaves as a ThreadChecker. See header for details.
+ if (!sequence_token_.IsValid())
+ return thread_checker_.CalledOnValidThread();
+
+ return sequence_token_.Equals(
+ SequencedWorkerPool::GetSequenceTokenForCurrentThread());
}
-void SequenceCheckerImpl::ChangeSequence(
- const scoped_refptr<SequencedTaskRunner>& sequenced_task_runner) {
+void SequenceCheckerImpl::DetachFromSequence() {
AutoLock auto_lock(lock_);
- sequenced_task_runner_ = sequenced_task_runner;
thread_checker_.DetachFromThread();
+ sequence_token_assigned_ = false;
+ sequence_token_ = SequencedWorkerPool::SequenceToken();
+}
+
+void SequenceCheckerImpl::EnsureSequenceTokenAssigned() const {
+ lock_.AssertAcquired();
+ if (sequence_token_assigned_)
+ return;
+
+ sequence_token_assigned_ = true;
+ sequence_token_ = SequencedWorkerPool::GetSequenceTokenForCurrentThread();
}
} // namespace base