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

Unified Diff: chrome/browser/sync/engine/syncer_thread_adapter.cc

Issue 6874018: make new syncer thread the default. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Upload before submit. Created 9 years, 8 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: 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
deleted file mode 100644
index 8a513e91e2858b28ace5b4bad722f4309716e16e..0000000000000000000000000000000000000000
--- a/chrome/browser/sync/engine/syncer_thread_adapter.cc
+++ /dev/null
@@ -1,148 +0,0 @@
-// Copyright (c) 2011 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 "base/time.h"
-#include "base/tracked.h"
-#include "chrome/browser/sync/engine/syncer_thread_adapter.h"
-#include "chrome/browser/sync/syncable/model_type.h"
-
-using base::TimeDelta;
-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() {
- 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();
- }
-}
-
-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;
- }
-}
-
-void SyncerThreadAdapter::NudgeSyncer(int milliseconds_from_now,
- SyncerThread::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);
- }
-}
-
-void SyncerThreadAdapter::NudgeSyncerWithDataTypes(
- int milliseconds_from_now,
- SyncerThread::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);
- }
-}
-
-void SyncerThreadAdapter::NudgeSyncerWithPayloads(
- int milliseconds_from_now,
- SyncerThread::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);
- }
-}
-
-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.
-}
-
-s3::SyncerThread* SyncerThreadAdapter::new_impl() {
- return new_impl_.get();
-}
-
-} // namespace browser_sync
« no previous file with comments | « chrome/browser/sync/engine/syncer_thread_adapter.h ('k') | chrome/browser/sync/engine/syncer_thread_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698