Index: components/sync/core/shared_model_type_processor.cc |
diff --git a/components/sync/core/shared_model_type_processor.cc b/components/sync/core/shared_model_type_processor.cc |
index 85475769c889196ab6e59c3caa382d54b8758dd9..3d86598a12ba5e95d52fa3ff502842c1fc03dcee 100644 |
--- a/components/sync/core/shared_model_type_processor.cc |
+++ b/components/sync/core/shared_model_type_processor.cc |
@@ -18,7 +18,7 @@ |
#include "components/sync/protocol/proto_value_conversions.h" |
#include "components/sync/syncable/syncable_util.h" |
-namespace syncer_v2 { |
+namespace syncer { |
namespace { |
@@ -77,7 +77,7 @@ void ModelTypeProcessorProxy::OnUpdateReceived( |
} // namespace |
-SharedModelTypeProcessor::SharedModelTypeProcessor(syncer::ModelType type, |
+SharedModelTypeProcessor::SharedModelTypeProcessor(ModelType type, |
ModelTypeService* service) |
: type_(type), |
is_metadata_loaded_(false), |
@@ -92,14 +92,14 @@ SharedModelTypeProcessor::~SharedModelTypeProcessor() {} |
// static |
std::unique_ptr<ModelTypeChangeProcessor> |
-SharedModelTypeProcessor::CreateAsChangeProcessor(syncer::ModelType type, |
+SharedModelTypeProcessor::CreateAsChangeProcessor(ModelType type, |
ModelTypeService* service) { |
return std::unique_ptr<ModelTypeChangeProcessor>( |
new SharedModelTypeProcessor(type, service)); |
} |
void SharedModelTypeProcessor::OnSyncStarting( |
- std::unique_ptr<syncer::DataTypeErrorHandler> error_handler, |
+ std::unique_ptr<DataTypeErrorHandler> error_handler, |
const StartCallback& start_callback) { |
DCHECK(CalledOnValidThread()); |
DCHECK(start_callback_.is_null()); |
@@ -113,7 +113,7 @@ void SharedModelTypeProcessor::OnSyncStarting( |
} |
void SharedModelTypeProcessor::OnMetadataLoaded( |
- syncer::SyncError error, |
+ SyncError error, |
std::unique_ptr<MetadataBatch> batch) { |
DCHECK(CalledOnValidThread()); |
DCHECK(entities_.empty()); |
@@ -194,7 +194,7 @@ bool SharedModelTypeProcessor::IsConnected() const { |
void SharedModelTypeProcessor::GetAllNodes( |
const scoped_refptr<base::TaskRunner>& task_runner, |
- const base::Callback<void(const syncer::ModelType, |
+ const base::Callback<void(const ModelType, |
std::unique_ptr<base::ListValue>)>& callback) { |
DCHECK(service_); |
service_->GetAllData( |
@@ -214,14 +214,13 @@ void SharedModelTypeProcessor::DisableSync() { |
service_->ApplySyncChanges(std::move(change_list), EntityChangeList()); |
} |
-syncer::SyncError SharedModelTypeProcessor::CreateAndUploadError( |
+SyncError SharedModelTypeProcessor::CreateAndUploadError( |
const tracked_objects::Location& location, |
const std::string& message) { |
if (error_handler_) { |
return error_handler_->CreateAndUploadError(location, message, type_); |
} else { |
- return syncer::SyncError(location, syncer::SyncError::DATATYPE_ERROR, |
- message, type_); |
+ return SyncError(location, SyncError::DATATYPE_ERROR, message, type_); |
} |
} |
@@ -255,7 +254,7 @@ void SharedModelTypeProcessor::Put(const std::string& storage_key, |
DCHECK(data.get()); |
DCHECK(!data->is_deleted()); |
DCHECK(!data->non_unique_name.empty()); |
- DCHECK_EQ(type_, syncer::GetModelTypeFromSpecifics(data->specifics)); |
+ DCHECK_EQ(type_, GetModelTypeFromSpecifics(data->specifics)); |
if (!data_type_state_.initial_sync_done()) { |
// Ignore changes before the initial sync is done. |
@@ -365,7 +364,7 @@ void SharedModelTypeProcessor::OnCommitCompleted( |
} |
} |
- syncer::SyncError error = |
+ SyncError error = |
service_->ApplySyncChanges(std::move(change_list), EntityChangeList()); |
if (error.IsSet()) { |
error_handler_->OnUnrecoverableError(error); |
@@ -421,7 +420,7 @@ void SharedModelTypeProcessor::OnUpdateReceived( |
} |
// Inform the service of the new or updated data. |
- syncer::SyncError error = |
+ SyncError error = |
service_->ApplySyncChanges(std::move(metadata_changes), entity_changes); |
if (error.IsSet()) { |
@@ -614,7 +613,7 @@ void SharedModelTypeProcessor::OnInitialUpdateReceived( |
} |
// Let the service handle associating and merging the data. |
- syncer::SyncError error = |
+ SyncError error = |
service_->MergeSyncData(std::move(metadata_changes), data_map); |
if (error.IsSet()) { |
@@ -626,7 +625,7 @@ void SharedModelTypeProcessor::OnInitialUpdateReceived( |
} |
void SharedModelTypeProcessor::OnInitialPendingDataLoaded( |
- syncer::SyncError error, |
+ SyncError error, |
std::unique_ptr<DataBatch> data_batch) { |
DCHECK(!is_initial_pending_data_loaded_); |
@@ -641,7 +640,7 @@ void SharedModelTypeProcessor::OnInitialPendingDataLoaded( |
} |
void SharedModelTypeProcessor::OnDataLoadedForReEncryption( |
- syncer::SyncError error, |
+ SyncError error, |
std::unique_ptr<DataBatch> data_batch) { |
DCHECK(is_initial_pending_data_loaded_); |
@@ -667,7 +666,7 @@ void SharedModelTypeProcessor::ConsumeDataBatch( |
} |
std::string SharedModelTypeProcessor::GetHashForTag(const std::string& tag) { |
- return syncer::syncable::GenerateSyncableHash(type_, tag); |
+ return syncable::GenerateSyncableHash(type_, tag); |
} |
std::string SharedModelTypeProcessor::GetClientTagHash( |
@@ -717,9 +716,9 @@ ProcessorEntityTracker* SharedModelTypeProcessor::CreateEntity( |
void SharedModelTypeProcessor::MergeDataWithMetadata( |
const scoped_refptr<base::TaskRunner>& task_runner, |
- const base::Callback<void(const syncer::ModelType, |
+ const base::Callback<void(const ModelType, |
std::unique_ptr<base::ListValue>)>& callback, |
- syncer::SyncError error, |
+ SyncError error, |
std::unique_ptr<DataBatch> batch) { |
std::unique_ptr<base::ListValue> all_nodes = |
base::MakeUnique<base::ListValue>(); |
@@ -732,7 +731,7 @@ void SharedModelTypeProcessor::MergeDataWithMetadata( |
ProcessorEntityTracker* entity = GetEntityForStorageKey(data.first); |
// Entity could be null if there are some unapplied changes. |
if (entity != nullptr) { |
- node->Set("metadata", syncer::EntityMetadataToValue(entity->metadata())); |
+ node->Set("metadata", EntityMetadataToValue(entity->metadata())); |
} |
node->SetString("modelType", type_string); |
all_nodes->Append(std::move(node)); |
@@ -758,4 +757,4 @@ void SharedModelTypeProcessor::MergeDataWithMetadata( |
base::Bind(callback, type_, base::Passed(&all_nodes))); |
} |
-} // namespace syncer_v2 |
+} // namespace syncer |