[Sync] Rename csync namespace to syncer

chrome/browser/sync/glue/sync_backend_registrar.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/sync/glue/sync_backend_registrar.h"
 
 #include <cstddef>
 
 #include "base/compiler_specific.h"
 #include "base/logging.h"
@@ skipping 10 matching lines @@
 #include "sync/internal_api/public/engine/passive_model_worker.h"
 
 using content::BrowserThread;
 
 namespace browser_sync {
 
 namespace {
 
 // Returns true if the current thread is the native thread for the
 // given group (or if it is undeterminable).
-bool IsOnThreadForGroup(csync::ModelSafeGroup group) {
+bool IsOnThreadForGroup(syncer::ModelSafeGroup group) {
   switch (group) {
-    case csync::GROUP_PASSIVE:
+    case syncer::GROUP_PASSIVE:
       return false;
-    case csync::GROUP_UI:
+    case syncer::GROUP_UI:
       return BrowserThread::CurrentlyOn(BrowserThread::UI);
-    case csync::GROUP_DB:
+    case syncer::GROUP_DB:
       return BrowserThread::CurrentlyOn(BrowserThread::DB);
-    case csync::GROUP_FILE:
+    case syncer::GROUP_FILE:
       return BrowserThread::CurrentlyOn(BrowserThread::FILE);
-    case csync::GROUP_HISTORY:
+    case syncer::GROUP_HISTORY:
       // TODO(ncarter): How to determine this?
       return true;
-    case csync::GROUP_PASSWORD:
+    case syncer::GROUP_PASSWORD:
       // TODO(ncarter): How to determine this?
       return true;
-    case csync::MODEL_SAFE_GROUP_COUNT:
+    case syncer::MODEL_SAFE_GROUP_COUNT:
     default:
       return false;
   }
 }
 
 }  // namespace
 
 SyncBackendRegistrar::SyncBackendRegistrar(
     syncable::ModelTypeSet initial_types,
     const std::string& name, Profile* profile,
     MessageLoop* sync_loop) :
     name_(name),
     profile_(profile),
     sync_loop_(sync_loop),
     ui_worker_(new UIModelWorker()),
     stopped_on_ui_thread_(false) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   CHECK(profile_);
   DCHECK(sync_loop_);
-  workers_[csync::GROUP_DB] = new DatabaseModelWorker();
-  workers_[csync::GROUP_FILE] = new FileModelWorker();
-  workers_[csync::GROUP_UI] = ui_worker_;
-  workers_[csync::GROUP_PASSIVE] = new csync::PassiveModelWorker(sync_loop_);
+  workers_[syncer::GROUP_DB] = new DatabaseModelWorker();
+  workers_[syncer::GROUP_FILE] = new FileModelWorker();
+  workers_[syncer::GROUP_UI] = ui_worker_;
+  workers_[syncer::GROUP_PASSIVE] = new syncer::PassiveModelWorker(sync_loop_);
 
   // Any datatypes that we want the syncer to pull down must be in the
   // routing_info map.  We set them to group passive, meaning that
   // updates will be applied to sync, but not dispatched to the native
   // models.
   for (syncable::ModelTypeSet::Iterator it = initial_types.First();
        it.Good(); it.Inc()) {
-    routing_info_[it.Get()] = csync::GROUP_PASSIVE;
+    routing_info_[it.Get()] = syncer::GROUP_PASSIVE;
   }
 
   HistoryService* history_service = profile->GetHistoryService(
       Profile::IMPLICIT_ACCESS);
   if (history_service) {
-    workers_[csync::GROUP_HISTORY] = new HistoryModelWorker(history_service);
+    workers_[syncer::GROUP_HISTORY] = new HistoryModelWorker(history_service);
   } else {
     LOG_IF(WARNING, initial_types.Has(syncable::TYPED_URLS))
         << "History store disabled, cannot sync Omnibox History";
     routing_info_.erase(syncable::TYPED_URLS);
   }
 
   scoped_refptr<PasswordStore> password_store =
       PasswordStoreFactory::GetForProfile(profile, Profile::IMPLICIT_ACCESS);
   if (password_store.get()) {
-    workers_[csync::GROUP_PASSWORD] = new PasswordModelWorker(password_store);
+    workers_[syncer::GROUP_PASSWORD] = new PasswordModelWorker(password_store);
   } else {
     LOG_IF(WARNING, initial_types.Has(syncable::PASSWORDS))
         << "Password store not initialized, cannot sync passwords";
     routing_info_.erase(syncable::PASSWORDS);
   }
 }
 
 SyncBackendRegistrar::~SyncBackendRegistrar() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   DCHECK(stopped_on_ui_thread_);
 }
 
 bool SyncBackendRegistrar::IsNigoriEnabled() const {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   base::AutoLock lock(lock_);
   return routing_info_.find(syncable::NIGORI) != routing_info_.end();
 }
 
 syncable::ModelTypeSet SyncBackendRegistrar::ConfigureDataTypes(
     syncable::ModelTypeSet types_to_add,
     syncable::ModelTypeSet types_to_remove) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   DCHECK(Intersection(types_to_add, types_to_remove).Empty());
   syncable::ModelTypeSet filtered_types_to_add = types_to_add;
-  if (workers_.count(csync::GROUP_HISTORY) == 0) {
+  if (workers_.count(syncer::GROUP_HISTORY) == 0) {
     LOG(WARNING) << "No history worker -- removing TYPED_URLS";
     filtered_types_to_add.Remove(syncable::TYPED_URLS);
   }
-  if (workers_.count(csync::GROUP_PASSWORD) == 0) {
+  if (workers_.count(syncer::GROUP_PASSWORD) == 0) {
     LOG(WARNING) << "No password worker -- removing PASSWORDS";
     filtered_types_to_add.Remove(syncable::PASSWORDS);
   }
 
   base::AutoLock lock(lock_);
   syncable::ModelTypeSet newly_added_types;
   for (syncable::ModelTypeSet::Iterator it =
            filtered_types_to_add.First();
        it.Good(); it.Inc()) {
-    // Add a newly specified data type as csync::GROUP_PASSIVE into the
+    // Add a newly specified data type as syncer::GROUP_PASSIVE into the
     // routing_info, if it does not already exist.
     if (routing_info_.count(it.Get()) == 0) {
-      routing_info_[it.Get()] = csync::GROUP_PASSIVE;
+      routing_info_[it.Get()] = syncer::GROUP_PASSIVE;
       newly_added_types.Put(it.Get());
     }
   }
   for (syncable::ModelTypeSet::Iterator it = types_to_remove.First();
        it.Good(); it.Inc()) {
     routing_info_.erase(it.Get());
   }
 
   // TODO(akalin): Use SVLOG/SLOG if we add any more logging.
   DVLOG(1) << name_ << ": Adding types "
            << syncable::ModelTypeSetToString(types_to_add)
            << " (with newly-added types "
            << syncable::ModelTypeSetToString(newly_added_types)
            << ") and removing types "
            << syncable::ModelTypeSetToString(types_to_remove)
            << " to get new routing info "
-           <<csync::ModelSafeRoutingInfoToString(routing_info_);
+           <<syncer::ModelSafeRoutingInfoToString(routing_info_);
 
   return newly_added_types;
 }
 
 void SyncBackendRegistrar::StopOnUIThread() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   DCHECK(!stopped_on_ui_thread_);
   ui_worker_->Stop();
   stopped_on_ui_thread_ = true;
 }
 
 void SyncBackendRegistrar::OnSyncerShutdownComplete() {
   DCHECK_EQ(MessageLoop::current(), sync_loop_);
   ui_worker_->OnSyncerShutdownComplete();
 }
 
 void SyncBackendRegistrar::ActivateDataType(
     syncable::ModelType type,
-    csync::ModelSafeGroup group,
+    syncer::ModelSafeGroup group,
     ChangeProcessor* change_processor,
-    csync::UserShare* user_share) {
+    syncer::UserShare* user_share) {
   CHECK(IsOnThreadForGroup(group));
   base::AutoLock lock(lock_);
   // Ensure that the given data type is in the PASSIVE group.
- csync::ModelSafeRoutingInfo::iterator i = routing_info_.find(type);
+ syncer::ModelSafeRoutingInfo::iterator i = routing_info_.find(type);
   DCHECK(i != routing_info_.end());
-  DCHECK_EQ(i->second, csync::GROUP_PASSIVE);
+  DCHECK_EQ(i->second, syncer::GROUP_PASSIVE);
   routing_info_[type] = group;
   CHECK(IsCurrentThreadSafeForModel(type));
 
   // Add the data type's change processor to the list of change
   // processors so it can receive updates.
   DCHECK_EQ(processors_.count(type), 0U);
   processors_[type] = change_processor;
 
   // Start the change processor.
   change_processor->Start(profile_, user_share);
@@ skipping 12 matching lines @@
   DCHECK(!GetProcessorUnsafe(type));
 }
 
 bool SyncBackendRegistrar::IsTypeActivatedForTest(
     syncable::ModelType type) const {
   return GetProcessor(type) != NULL;
 }
 
 void SyncBackendRegistrar::OnChangesApplied(
     syncable::ModelType model_type,
-    const csync::BaseTransaction* trans,
-    const csync::ImmutableChangeRecordList& changes) {
+    const syncer::BaseTransaction* trans,
+    const syncer::ImmutableChangeRecordList& changes) {
   ChangeProcessor* processor = GetProcessor(model_type);
   if (!processor)
     return;
 
   processor->ApplyChangesFromSyncModel(trans, changes);
 }
 
 void SyncBackendRegistrar::OnChangesComplete(
     syncable::ModelType model_type) {
   ChangeProcessor* processor = GetProcessor(model_type);
   if (!processor)
     return;
 
   // This call just notifies the processor that it can commit; it
   // already buffered any changes it plans to makes so needs no
   // further information.
   processor->CommitChangesFromSyncModel();
 }
 
 void SyncBackendRegistrar::GetWorkers(
-    std::vector<csync::ModelSafeWorker*>* out) {
+    std::vector<syncer::ModelSafeWorker*>* out) {
   base::AutoLock lock(lock_);
   out->clear();
   for (WorkerMap::const_iterator it = workers_.begin();
        it != workers_.end(); ++it) {
     out->push_back(it->second);
   }
 }
 
 void SyncBackendRegistrar::GetModelSafeRoutingInfo(
-   csync::ModelSafeRoutingInfo* out) {
+   syncer::ModelSafeRoutingInfo* out) {
   base::AutoLock lock(lock_);
- csync::ModelSafeRoutingInfo copy(routing_info_);
+ syncer::ModelSafeRoutingInfo copy(routing_info_);
   out->swap(copy);
 }
 
 ChangeProcessor* SyncBackendRegistrar::GetProcessor(
     syncable::ModelType type) const {
   base::AutoLock lock(lock_);
   ChangeProcessor* processor = GetProcessorUnsafe(type);
   if (!processor)
     return NULL;
 
   // We can only check if |processor| exists, as otherwise the type is
-  // mapped to csync::GROUP_PASSIVE.
+  // mapped to syncer::GROUP_PASSIVE.
   CHECK(IsCurrentThreadSafeForModel(type));
   CHECK(processor->IsRunning());
   return processor;
 }
 
 ChangeProcessor* SyncBackendRegistrar::GetProcessorUnsafe(
     syncable::ModelType type) const {
   lock_.AssertAcquired();
   std::map<syncable::ModelType, ChangeProcessor*>::const_iterator it =
       processors_.find(type);
@@ skipping 10 matching lines @@
   return it->second;
 }
 
 bool SyncBackendRegistrar::IsCurrentThreadSafeForModel(
     syncable::ModelType model_type) const {
   lock_.AssertAcquired();
   return IsOnThreadForGroup(GetGroupForModelType(model_type, routing_info_));
 }
 
 }  // namespace browser_sync