Index: components/invalidation/impl/registration_manager.cc |
diff --git a/components/invalidation/impl/registration_manager.cc b/components/invalidation/impl/registration_manager.cc |
index 504986b00baae683d82e55abfc98ae104a34d2fc..a379d92626d879858e0ababdd790af1585c8b4a4 100644 |
--- a/components/invalidation/impl/registration_manager.cc |
+++ b/components/invalidation/impl/registration_manager.cc |
@@ -65,11 +65,11 @@ RegistrationManager::RegistrationManager( |
} |
RegistrationManager::~RegistrationManager() { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
} |
ObjectIdSet RegistrationManager::UpdateRegisteredIds(const ObjectIdSet& ids) { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
const ObjectIdSet& old_ids = GetRegisteredIds(); |
const ObjectIdSet& to_register = ids; |
@@ -100,7 +100,7 @@ ObjectIdSet RegistrationManager::UpdateRegisteredIds(const ObjectIdSet& ids) { |
void RegistrationManager::MarkRegistrationLost( |
const invalidation::ObjectId& id) { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
auto it = registration_statuses_.find(id); |
if (it == registration_statuses_.end()) { |
DVLOG(1) << "Attempt to mark non-existent registration for " |
@@ -116,7 +116,7 @@ void RegistrationManager::MarkRegistrationLost( |
} |
void RegistrationManager::MarkAllRegistrationsLost() { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
for (auto it = registration_statuses_.begin(); |
it != registration_statuses_.end(); ++it) { |
if (IsIdRegistered(it->first)) { |
@@ -126,7 +126,7 @@ void RegistrationManager::MarkAllRegistrationsLost() { |
} |
void RegistrationManager::DisableId(const invalidation::ObjectId& id) { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
auto it = registration_statuses_.find(id); |
if (it == registration_statuses_.end()) { |
DVLOG(1) << "Attempt to disable non-existent registration for " |
@@ -161,7 +161,7 @@ ObjectIdSet RegistrationManager::GetRegisteredIdsForTest() const { |
RegistrationManager::PendingRegistrationMap |
RegistrationManager::GetPendingRegistrationsForTest() const { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
PendingRegistrationMap pending_registrations; |
for (const auto& status_pair : registration_statuses_) { |
const invalidation::ObjectId& id = status_pair.first; |
@@ -180,7 +180,7 @@ RegistrationManager::PendingRegistrationMap |
} |
void RegistrationManager::FirePendingRegistrationsForTest() { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
for (const auto& status_pair : registration_statuses_) { |
if (status_pair.second->registration_timer.IsRunning()) { |
status_pair.second->DoRegister(); |
@@ -198,7 +198,7 @@ double RegistrationManager::GetJitter() { |
void RegistrationManager::TryRegisterId(const invalidation::ObjectId& id, |
bool is_retry) { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
auto it = registration_statuses_.find(id); |
if (it == registration_statuses_.end()) { |
NOTREACHED() << "TryRegisterId called on " << ObjectIdToString(id) |
@@ -251,7 +251,7 @@ void RegistrationManager::TryRegisterId(const invalidation::ObjectId& id, |
} |
void RegistrationManager::DoRegisterId(const invalidation::ObjectId& id) { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
invalidation_client_->Register(id); |
auto it = registration_statuses_.find(id); |
if (it == registration_statuses_.end()) { |
@@ -264,7 +264,7 @@ void RegistrationManager::DoRegisterId(const invalidation::ObjectId& id) { |
} |
void RegistrationManager::UnregisterId(const invalidation::ObjectId& id) { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
invalidation_client_->Unregister(id); |
auto it = registration_statuses_.find(id); |
if (it == registration_statuses_.end()) { |
@@ -277,7 +277,7 @@ void RegistrationManager::UnregisterId(const invalidation::ObjectId& id) { |
ObjectIdSet RegistrationManager::GetRegisteredIds() const { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
ObjectIdSet ids; |
for (const auto& status_pair : registration_statuses_) { |
if (IsIdRegistered(status_pair.first)) { |
@@ -289,7 +289,7 @@ ObjectIdSet RegistrationManager::GetRegisteredIds() const { |
bool RegistrationManager::IsIdRegistered( |
const invalidation::ObjectId& id) const { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
auto it = registration_statuses_.find(id); |
return it != registration_statuses_.end() && |
it->second->state == invalidation::InvalidationListener::REGISTERED; |