Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1024)

Unified Diff: components/sync/model_impl/shared_model_type_processor.cc

Issue 2915453002: Deprecate NonThreadSafe in components/sync in favor of SequenceChecker. (Closed)
Patch Set: fix comment Created 3 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: components/sync/model_impl/shared_model_type_processor.cc
diff --git a/components/sync/model_impl/shared_model_type_processor.cc b/components/sync/model_impl/shared_model_type_processor.cc
index f7ecbdebecb2385e1fc866d53469d7fc616a8dbf..e24917d5a505b915358c3b3a1bb7f5c3e688e419 100644
--- a/components/sync/model_impl/shared_model_type_processor.cc
+++ b/components/sync/model_impl/shared_model_type_processor.cc
@@ -33,12 +33,14 @@ SharedModelTypeProcessor::SharedModelTypeProcessor(
DCHECK(bridge);
}
-SharedModelTypeProcessor::~SharedModelTypeProcessor() = default;
+SharedModelTypeProcessor::~SharedModelTypeProcessor() {
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
+}
void SharedModelTypeProcessor::OnSyncStarting(
const ModelErrorHandler& error_handler,
const StartCallback& start_callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(!IsConnected());
DCHECK(error_handler);
DCHECK(start_callback);
@@ -51,7 +53,7 @@ void SharedModelTypeProcessor::OnSyncStarting(
void SharedModelTypeProcessor::ModelReadyToSync(
std::unique_ptr<MetadataBatch> batch) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(waiting_for_metadata_);
DCHECK(entities_.empty());
@@ -117,18 +119,18 @@ void SharedModelTypeProcessor::ConnectIfReady() {
}
bool SharedModelTypeProcessor::IsAllowingChanges() const {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
// Changes can be handled correctly even before pending data is loaded.
return !waiting_for_metadata_;
}
bool SharedModelTypeProcessor::IsConnected() const {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
return !!worker_;
}
void SharedModelTypeProcessor::DisableSync() {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
std::unique_ptr<MetadataChangeList> change_list =
bridge_->CreateMetadataChangeList();
for (auto it = entities_.begin(); it != entities_.end(); ++it) {
@@ -144,7 +146,7 @@ bool SharedModelTypeProcessor::IsTrackingMetadata() {
}
void SharedModelTypeProcessor::ReportError(const ModelError& error) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
// Ignore all errors after the first.
if (model_error_)
@@ -175,7 +177,7 @@ void SharedModelTypeProcessor::ReportError(
void SharedModelTypeProcessor::ConnectSync(
std::unique_ptr<CommitQueue> worker) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DVLOG(1) << "Successfully connected " << ModelTypeToString(type_);
worker_ = std::move(worker);
@@ -184,7 +186,7 @@ void SharedModelTypeProcessor::ConnectSync(
}
void SharedModelTypeProcessor::DisconnectSync() {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(IsConnected());
DVLOG(1) << "Disconnecting sync for " << ModelTypeToString(type_);
@@ -199,7 +201,7 @@ void SharedModelTypeProcessor::DisconnectSync() {
void SharedModelTypeProcessor::Put(const std::string& storage_key,
std::unique_ptr<EntityData> data,
MetadataChangeList* metadata_change_list) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(IsAllowingChanges());
DCHECK(data);
DCHECK(!data->is_deleted());
@@ -234,7 +236,7 @@ void SharedModelTypeProcessor::Put(const std::string& storage_key,
void SharedModelTypeProcessor::Delete(
const std::string& storage_key,
MetadataChangeList* metadata_change_list) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(IsAllowingChanges());
if (!model_type_state_.initial_sync_done()) {
@@ -308,7 +310,7 @@ void SharedModelTypeProcessor::FlushPendingCommitRequests() {
void SharedModelTypeProcessor::OnCommitCompleted(
const sync_pb::ModelTypeState& type_state,
const CommitResponseDataList& response_list) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
std::unique_ptr<MetadataChangeList> change_list =
bridge_->CreateMetadataChangeList();
@@ -345,7 +347,7 @@ void SharedModelTypeProcessor::OnCommitCompleted(
void SharedModelTypeProcessor::OnUpdateReceived(
const sync_pb::ModelTypeState& model_type_state,
const UpdateResponseDataList& updates) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
if (!model_type_state_.initial_sync_done()) {
OnInitialUpdateReceived(model_type_state, updates);
return;
@@ -604,7 +606,7 @@ void SharedModelTypeProcessor::OnInitialUpdateReceived(
void SharedModelTypeProcessor::OnInitialPendingDataLoaded(
std::unique_ptr<DataBatch> data_batch) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(waiting_for_pending_data_);
// The model already experienced an error; abort;
@@ -619,7 +621,7 @@ void SharedModelTypeProcessor::OnInitialPendingDataLoaded(
void SharedModelTypeProcessor::OnDataLoadedForReEncryption(
std::unique_ptr<DataBatch> data_batch) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(!waiting_for_pending_data_);
ConsumeDataBatch(std::move(data_batch));
« no previous file with comments | « components/sync/model_impl/shared_model_type_processor.h ('k') | components/sync/syncable/directory_backing_store.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698