| 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));
|
|
|