Index: chrome/browser/sync/engine/syncer_thread_adapter.cc |
diff --git a/chrome/browser/sync/engine/syncer_thread_adapter.cc b/chrome/browser/sync/engine/syncer_thread_adapter.cc |
index 8a513e91e2858b28ace5b4bad722f4309716e16e..05e7cb62a0dd8282fdd6d5619bd35e641682d44d 100644 |
--- a/chrome/browser/sync/engine/syncer_thread_adapter.cc |
+++ b/chrome/browser/sync/engine/syncer_thread_adapter.cc |
@@ -12,136 +12,66 @@ using syncable::ModelTypeBitSet; |
namespace browser_sync { |
-SyncerThreadAdapter::SyncerThreadAdapter(sessions::SyncSessionContext* context, |
- bool using_new_impl) |
- : legacy_(NULL), new_impl_(NULL), using_new_impl_(using_new_impl) { |
- if (using_new_impl_) { |
- new_impl_.reset(new s3::SyncerThread(context, new Syncer())); |
- } else { |
- legacy_ = new SyncerThread(context); |
- } |
+SyncerThreadAdapter::SyncerThreadAdapter(sessions::SyncSessionContext* context) |
+ : new_impl_(NULL) { |
+ new_impl_.reset(new SyncerThread(context, new Syncer())); |
} |
SyncerThreadAdapter::~SyncerThreadAdapter() { |
- legacy_ = NULL; |
new_impl_.reset(); |
} |
-void SyncerThreadAdapter::WatchConnectionManager( |
- ServerConnectionManager* conn_mgr) { |
- DCHECK(!using_new_impl_); |
- legacy_->WatchConnectionManager(conn_mgr); |
-} |
- |
bool SyncerThreadAdapter::Start() { |
- if (using_new_impl_) { |
- new_impl_->Start(s3::SyncerThread::NORMAL_MODE, NULL); |
- return true; |
- } else { |
- return legacy_->Start(); |
- } |
+ new_impl_->Start(SyncerThread::NORMAL_MODE, NULL); |
+ return true; |
} |
bool SyncerThreadAdapter::Stop(int max_wait) { |
- if (using_new_impl_) { |
- new_impl_->Stop(); |
- return true; |
- } else { |
- return legacy_->Stop(max_wait); |
- } |
-} |
- |
-bool SyncerThreadAdapter::RequestPause() { |
- DCHECK(!using_new_impl_); |
- return legacy_->RequestPause(); |
-} |
- |
-bool SyncerThreadAdapter::RequestResume() { |
- DCHECK(!using_new_impl_); |
- return legacy_->RequestResume(); |
-} |
- |
-s3::NudgeSource LegacyToNewSyncerThreadSource(SyncerThread::NudgeSource s) { |
- switch (s) { |
- case SyncerThread::kNotification: |
- return s3::NUDGE_SOURCE_NOTIFICATION; |
- case SyncerThread::kContinuation: |
- return s3::NUDGE_SOURCE_CONTINUATION; |
- case SyncerThread::kLocal: |
- return s3::NUDGE_SOURCE_LOCAL; |
- case SyncerThread::kUnknown: |
- return s3::NUDGE_SOURCE_UNKNOWN; |
- default: |
- NOTREACHED(); |
- return s3::NUDGE_SOURCE_UNKNOWN; |
- } |
+ new_impl_->Stop(); |
+ return true; |
} |
void SyncerThreadAdapter::NudgeSyncer(int milliseconds_from_now, |
- SyncerThread::NudgeSource source, |
+ NudgeSource source, |
const tracked_objects::Location& nudge_location) { |
- if (using_new_impl_) { |
- if (source == SyncerThread::kClearPrivateData) { |
- new_impl_->ScheduleClearUserData(); |
- return; |
- } |
- new_impl_->ScheduleNudge( |
- TimeDelta::FromMilliseconds(milliseconds_from_now), |
- LegacyToNewSyncerThreadSource(source), ModelTypeBitSet(), |
- nudge_location); |
- } else { |
- legacy_->NudgeSyncer(milliseconds_from_now, source); |
+ if (source == CLEAR_USER_PRIVATE_DATA) { |
+ new_impl_->ScheduleClearUserData(); |
+ return; |
} |
+ new_impl_->ScheduleNudge( |
+ TimeDelta::FromMilliseconds(milliseconds_from_now), |
+ source, ModelTypeBitSet(), |
+ nudge_location); |
} |
void SyncerThreadAdapter::NudgeSyncerWithDataTypes( |
int milliseconds_from_now, |
- SyncerThread::NudgeSource source, |
+ NudgeSource source, |
const syncable::ModelTypeBitSet& model_types, |
const tracked_objects::Location& nudge_location) { |
- DCHECK_NE(SyncerThread::kClearPrivateData, source); |
- if (using_new_impl_) { |
- new_impl_->ScheduleNudge( |
- TimeDelta::FromMilliseconds(milliseconds_from_now), |
- LegacyToNewSyncerThreadSource(source), model_types, |
- nudge_location); |
- } else { |
- legacy_->NudgeSyncerWithDataTypes(milliseconds_from_now, source, |
- model_types); |
- } |
+ DCHECK_NE(CLEAR_USER_PRIVATE_DATA, source); |
+ new_impl_->ScheduleNudge( |
+ TimeDelta::FromMilliseconds(milliseconds_from_now), |
+ source, model_types, |
+ nudge_location); |
} |
void SyncerThreadAdapter::NudgeSyncerWithPayloads( |
int milliseconds_from_now, |
- SyncerThread::NudgeSource source, |
+ NudgeSource source, |
const syncable::ModelTypePayloadMap& model_types_with_payloads, |
const tracked_objects::Location& nudge_location) { |
- DCHECK_NE(SyncerThread::kClearPrivateData, source); |
- if (using_new_impl_) { |
- new_impl_->ScheduleNudgeWithPayloads( |
- TimeDelta::FromMilliseconds(milliseconds_from_now), |
- LegacyToNewSyncerThreadSource(source), model_types_with_payloads, |
- nudge_location); |
- } else { |
- legacy_->NudgeSyncerWithPayloads(milliseconds_from_now, source, |
- model_types_with_payloads); |
- } |
+ new_impl_->ScheduleNudgeWithPayloads( |
+ TimeDelta::FromMilliseconds(milliseconds_from_now), |
+ source, model_types_with_payloads, |
+ nudge_location); |
} |
void SyncerThreadAdapter::SetNotificationsEnabled(bool enabled) { |
- if (using_new_impl_) |
- new_impl_->set_notifications_enabled(enabled); |
- else |
- legacy_->SetNotificationsEnabled(enabled); |
-} |
- |
-void SyncerThreadAdapter::CreateSyncer(const std::string& dirname) { |
- if (!using_new_impl_) |
- legacy_->CreateSyncer(dirname); |
- // No-op if using new impl. |
+ new_impl_->set_notifications_enabled(enabled); |
} |
-s3::SyncerThread* SyncerThreadAdapter::new_impl() { |
+SyncerThread* SyncerThreadAdapter::new_impl() { |
return new_impl_.get(); |
} |