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

Unified Diff: components/sync/driver/data_type_manager_impl.cc

Issue 2376123003: [Sync] Move //components/sync to the syncer namespace. (Closed)
Patch Set: Rebase. Created 4 years, 3 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/driver/data_type_manager_impl.cc
diff --git a/components/sync/driver/data_type_manager_impl.cc b/components/sync/driver/data_type_manager_impl.cc
index 4f33e3fa063802f2e6054114d52518bbae737c48..f9e9a102645754b24a3f3e03a5fdccf564d77600 100644
--- a/components/sync/driver/data_type_manager_impl.cc
+++ b/components/sync/driver/data_type_manager_impl.cc
@@ -21,9 +21,7 @@
#include "components/sync/driver/data_type_manager_observer.h"
#include "components/sync/driver/data_type_status_table.h"
-using syncer::ModelTypeSet;
-
-namespace sync_driver {
+namespace syncer {
namespace {
@@ -32,8 +30,8 @@ DataTypeStatusTable::TypeErrorMap GenerateCryptoErrorsForTypes(
DataTypeStatusTable::TypeErrorMap crypto_errors;
for (ModelTypeSet::Iterator iter = encrypted_types.First(); iter.Good();
iter.Inc()) {
- crypto_errors[iter.Get()] = syncer::SyncError(
- FROM_HERE, syncer::SyncError::CRYPTO_ERROR, "", iter.Get());
+ crypto_errors[iter.Get()] =
+ SyncError(FROM_HERE, SyncError::CRYPTO_ERROR, "", iter.Get());
}
return crypto_errors;
}
@@ -46,8 +44,7 @@ DataTypeManagerImpl::AssociationTypesInfo::AssociationTypesInfo(
DataTypeManagerImpl::AssociationTypesInfo::~AssociationTypesInfo() {}
DataTypeManagerImpl::DataTypeManagerImpl(
- const syncer::WeakHandle<syncer::DataTypeDebugInfoListener>&
- debug_info_listener,
+ const WeakHandle<DataTypeDebugInfoListener>& debug_info_listener,
const DataTypeController::TypeMap* controllers,
const DataTypeEncryptionHandler* encryption_handler,
BackendDataTypeConfigurer* configurer,
@@ -56,7 +53,7 @@ DataTypeManagerImpl::DataTypeManagerImpl(
controllers_(controllers),
state_(DataTypeManager::STOPPED),
needs_reconfigure_(false),
- last_configure_reason_(syncer::CONFIGURE_REASON_UNKNOWN),
+ last_configure_reason_(CONFIGURE_REASON_UNKNOWN),
debug_info_listener_(debug_info_listener),
model_association_manager_(controllers, this),
observer_(observer),
@@ -71,14 +68,14 @@ DataTypeManagerImpl::DataTypeManagerImpl(
DataTypeManagerImpl::~DataTypeManagerImpl() {}
void DataTypeManagerImpl::Configure(ModelTypeSet desired_types,
- syncer::ConfigureReason reason) {
+ ConfigureReason reason) {
// Once requested, we will remain in "catch up" mode until we notify the
// caller (see NotifyDone). We do this to ensure that once started, subsequent
// calls to Configure won't take us out of "catch up" mode.
- if (reason == syncer::CONFIGURE_REASON_CATCH_UP)
+ if (reason == CONFIGURE_REASON_CATCH_UP)
catch_up_in_progress_ = true;
- desired_types.PutAll(syncer::CoreTypes());
+ desired_types.PutAll(CoreTypes());
// Only allow control types and types that have controllers.
ModelTypeSet filtered_desired_types;
@@ -86,17 +83,16 @@ void DataTypeManagerImpl::Configure(ModelTypeSet desired_types,
type.Inc()) {
DataTypeController::TypeMap::const_iterator iter =
controllers_->find(type.Get());
- if (syncer::IsControlType(type.Get()) || iter != controllers_->end()) {
+ if (IsControlType(type.Get()) || iter != controllers_->end()) {
if (iter != controllers_->end()) {
if (!iter->second->ReadyForStart() &&
!data_type_status_table_.GetUnreadyErrorTypes().Has(type.Get())) {
// Add the type to the unready types set to prevent purging it. It's
// up to the datatype controller to, if necessary, explicitly
// mark the type as broken to trigger a purge.
- syncer::SyncError error(FROM_HERE, syncer::SyncError::UNREADY_ERROR,
- "Datatype not ready at config time.",
- type.Get());
- std::map<syncer::ModelType, syncer::SyncError> errors;
+ SyncError error(FROM_HERE, SyncError::UNREADY_ERROR,
+ "Datatype not ready at config time.", type.Get());
+ std::map<ModelType, SyncError> errors;
errors[type.Get()] = error;
data_type_status_table_.UpdateFailedDataTypes(errors);
} else if (iter->second->ReadyForStart()) {
@@ -109,7 +105,7 @@ void DataTypeManagerImpl::Configure(ModelTypeSet desired_types,
ConfigureImpl(filtered_desired_types, reason);
}
-void DataTypeManagerImpl::ReenableType(syncer::ModelType type) {
+void DataTypeManagerImpl::ReenableType(ModelType type) {
// TODO(zea): move the "should we reconfigure" logic into the datatype handler
// itself.
// Only reconfigure if the type actually had a data type or unready error.
@@ -122,9 +118,9 @@ void DataTypeManagerImpl::ReenableType(syncer::ModelType type) {
if (!last_requested_types_.Has(type))
return;
- DVLOG(1) << "Reenabling " << syncer::ModelTypeToString(type);
+ DVLOG(1) << "Reenabling " << ModelTypeToString(type);
needs_reconfigure_ = true;
- last_configure_reason_ = syncer::CONFIGURE_REASON_PROGRAMMATIC;
+ last_configure_reason_ = CONFIGURE_REASON_PROGRAMMATIC;
ProcessReconfigure();
}
@@ -133,14 +129,14 @@ void DataTypeManagerImpl::ResetDataTypeErrors() {
}
void DataTypeManagerImpl::PurgeForMigration(ModelTypeSet undesired_types,
- syncer::ConfigureReason reason) {
+ ConfigureReason reason) {
ModelTypeSet remainder = Difference(last_requested_types_, undesired_types);
ConfigureImpl(remainder, reason);
}
void DataTypeManagerImpl::ConfigureImpl(ModelTypeSet desired_types,
- syncer::ConfigureReason reason) {
- DCHECK_NE(reason, syncer::CONFIGURE_REASON_UNKNOWN);
+ ConfigureReason reason) {
+ DCHECK_NE(reason, CONFIGURE_REASON_UNKNOWN);
DVLOG(1) << "Configuring for " << ModelTypeSetToString(desired_types)
<< " with reason " << reason;
if (state_ == STOPPING) {
@@ -204,11 +200,10 @@ DataTypeManagerImpl::BuildDataTypeConfigStateMap(
if (catch_up_in_progress_)
clean_types.PutAll(enabled_types);
- ModelTypeSet disabled_types = syncer::Difference(
- syncer::Union(syncer::UserTypes(), syncer::ControlTypes()),
- enabled_types);
+ ModelTypeSet disabled_types =
+ Difference(Union(UserTypes(), ControlTypes()), enabled_types);
ModelTypeSet to_configure =
- syncer::Intersection(enabled_types, types_being_configured);
+ Intersection(enabled_types, types_being_configured);
DVLOG(1) << "Enabling: " << ModelTypeSetToString(enabled_types);
DVLOG(1) << "Configuring: " << ModelTypeSetToString(to_configure);
DVLOG(1) << "Disabling: " << ModelTypeSetToString(disabled_types);
@@ -234,19 +229,19 @@ DataTypeManagerImpl::BuildDataTypeConfigStateMap(
return config_state_map;
}
-void DataTypeManagerImpl::Restart(syncer::ConfigureReason reason) {
+void DataTypeManagerImpl::Restart(ConfigureReason reason) {
DVLOG(1) << "Restarting...";
// Only record the type histograms for user-triggered configurations or
// restarts.
- if (reason == syncer::CONFIGURE_REASON_RECONFIGURATION ||
- reason == syncer::CONFIGURE_REASON_NEW_CLIENT ||
- reason == syncer::CONFIGURE_REASON_NEWLY_ENABLED_DATA_TYPE) {
+ if (reason == CONFIGURE_REASON_RECONFIGURATION ||
+ reason == CONFIGURE_REASON_NEW_CLIENT ||
+ reason == CONFIGURE_REASON_NEWLY_ENABLED_DATA_TYPE) {
for (ModelTypeSet::Iterator iter = last_requested_types_.First();
iter.Good(); iter.Inc()) {
UMA_HISTOGRAM_ENUMERATION("Sync.ConfigureDataTypes",
- syncer::ModelTypeToHistogramInt(iter.Get()),
- syncer::MODEL_TYPE_COUNT);
+ ModelTypeToHistogramInt(iter.Get()),
+ MODEL_TYPE_COUNT);
}
}
@@ -304,8 +299,8 @@ void DataTypeManagerImpl::OnAllDataTypesReadyForConfigure() {
ModelTypeSet DataTypeManagerImpl::GetPriorityTypes() const {
ModelTypeSet high_priority_types;
- high_priority_types.PutAll(syncer::PriorityCoreTypes());
- high_priority_types.PutAll(syncer::PriorityUserTypes());
+ high_priority_types.PutAll(PriorityCoreTypes());
+ high_priority_types.PutAll(PriorityUserTypes());
return high_priority_types;
}
@@ -314,8 +309,7 @@ TypeSetPriorityList DataTypeManagerImpl::PrioritizeTypes(
ModelTypeSet high_priority_types = GetPriorityTypes();
high_priority_types.RetainAll(types);
- ModelTypeSet low_priority_types =
- syncer::Difference(types, high_priority_types);
+ ModelTypeSet low_priority_types = Difference(types, high_priority_types);
TypeSetPriorityList result;
if (!high_priority_types.Empty())
@@ -383,8 +377,8 @@ void DataTypeManagerImpl::DownloadReady(
DataTypeStatusTable::TypeErrorMap errors;
for (ModelTypeSet::Iterator iter = failed_configuration_types.First();
iter.Good(); iter.Inc()) {
- syncer::SyncError error(FROM_HERE, syncer::SyncError::DATATYPE_ERROR,
- "Backend failed to download type.", iter.Get());
+ SyncError error(FROM_HERE, SyncError::DATATYPE_ERROR,
+ "Backend failed to download type.", iter.Get());
errors[iter.Get()] = error;
}
data_type_status_table_.UpdateFailedDataTypes(errors);
@@ -484,9 +478,8 @@ void DataTypeManagerImpl::StartNextAssociation(AssociationGroup group) {
model_association_manager_.StartAssociationAsync(types_to_associate);
}
-void DataTypeManagerImpl::OnSingleDataTypeWillStop(
- syncer::ModelType type,
- const syncer::SyncError& error) {
+void DataTypeManagerImpl::OnSingleDataTypeWillStop(ModelType type,
+ const SyncError& error) {
DataTypeController::TypeMap::const_iterator c_it = controllers_->find(type);
DCHECK(c_it != controllers_->end());
// Delegate deactivation to the controller.
@@ -499,9 +492,9 @@ void DataTypeManagerImpl::OnSingleDataTypeWillStop(
// Unrecoverable errors will shut down the entire backend, so no need to
// reconfigure.
- if (error.error_type() != syncer::SyncError::UNRECOVERABLE_ERROR) {
+ if (error.error_type() != SyncError::UNRECOVERABLE_ERROR) {
needs_reconfigure_ = true;
- last_configure_reason_ = syncer::CONFIGURE_REASON_PROGRAMMATIC;
+ last_configure_reason_ = CONFIGURE_REASON_PROGRAMMATIC;
// Do this asynchronously so the ModelAssociationManager has a chance to
// finish stopping this type, otherwise DeactivateDataType() and Stop()
// end up getting called twice on the controller.
@@ -513,8 +506,8 @@ void DataTypeManagerImpl::OnSingleDataTypeWillStop(
}
void DataTypeManagerImpl::OnSingleDataTypeAssociationDone(
- syncer::ModelType type,
- const syncer::DataTypeAssociationStats& association_stats) {
+ ModelType type,
+ const DataTypeAssociationStats& association_stats) {
DCHECK(!association_types_queue_.empty());
DataTypeController::TypeMap::const_iterator c_it = controllers_->find(type);
DCHECK(c_it != controllers_->end());
@@ -527,7 +520,7 @@ void DataTypeManagerImpl::OnSingleDataTypeAssociationDone(
return;
AssociationTypesInfo& info = association_types_queue_.front();
- configuration_stats_.push_back(syncer::DataTypeConfigurationStats());
+ configuration_stats_.push_back(DataTypeConfigurationStats());
configuration_stats_.back().model_type = type;
configuration_stats_.back().association_stats = association_stats;
if (info.types.Has(type)) {
@@ -652,8 +645,7 @@ void DataTypeManagerImpl::NotifyDone(const ConfigureResult& raw_result) {
if (debug_info_listener_.IsInitialized() &&
!configuration_stats_.empty()) {
debug_info_listener_.Call(
- FROM_HERE,
- &syncer::DataTypeDebugInfoListener::OnDataTypeConfigureComplete,
+ FROM_HERE, &DataTypeDebugInfoListener::OnDataTypeConfigureComplete,
configuration_stats_);
}
configuration_stats_.clear();
@@ -685,8 +677,8 @@ void DataTypeManagerImpl::AddToConfigureTime() {
}
ModelTypeSet DataTypeManagerImpl::GetEnabledTypes() const {
- return syncer::Difference(last_requested_types_,
- data_type_status_table_.GetFailedTypes());
+ return Difference(last_requested_types_,
+ data_type_status_table_.GetFailedTypes());
}
-} // namespace sync_driver
+} // namespace syncer
« no previous file with comments | « components/sync/driver/data_type_manager_impl.h ('k') | components/sync/driver/data_type_manager_impl_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698