[Sync] Adds a new switch for enabling the new local server backend.

components/sync/engine_impl/sync_manager_impl.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 "components/sync/engine_impl/sync_manager_impl.h"
 
 #include <stddef.h>
 
 #include <utility>
 
@@ skipping 29 matching lines @@
 #include "components/sync/syncable/base_node.h"
 #include "components/sync/syncable/directory.h"
 #include "components/sync/syncable/entry.h"
 #include "components/sync/syncable/in_memory_directory_backing_store.h"
 #include "components/sync/syncable/on_disk_directory_backing_store.h"
 #include "components/sync/syncable/read_node.h"
 #include "components/sync/syncable/read_transaction.h"
 #include "components/sync/syncable/write_node.h"
 #include "components/sync/syncable/write_transaction.h"
 
+#if defined(OS_WIN)
+#include "components/sync/engine_impl/loopback_server/loopback_connection_manager.h"
+#endif
+
 using base::TimeDelta;
 using sync_pb::GetUpdatesCallerInfo;
 
 class GURL;
 
 namespace syncer {
 
 using syncable::ImmutableWriteTransactionInfo;
 using syncable::SPECIFICS;
 using syncable::UNIQUE_POSITION;
@@ skipping 215 matching lines @@
     return;
   }
 
   // Now that we have opened the Directory we can restore any previously saved
   // nigori specifics.
   if (args->saved_nigori_state) {
     sync_encryption_handler_->RestoreNigori(*args->saved_nigori_state);
     args->saved_nigori_state.reset();
   }
 
-  connection_manager_ = base::MakeUnique<SyncServerConnectionManager>(
-      args->service_url.host() + args->service_url.path(),
-      args->service_url.EffectiveIntPort(),
-      args->service_url.SchemeIsCryptographic(), args->post_factory.release(),
-      args->cancelation_signal);
+  if (args->enable_local_sync_backend) {
+#if defined(OS_WIN)
+    VLOG(1) << "Running against local sync backend.";
+    connection_manager_ = base::MakeUnique<LoopbackConnectionManager>(
+        args->cancelation_signal, args->local_sync_backend_folder);
+#else
+    NOTREACHED();
+#endif  // defined(OS_WIN)
+  } else {
+    connection_manager_ = base::MakeUnique<SyncServerConnectionManager>(
+        args->service_url.host() + args->service_url.path(),
+        args->service_url.EffectiveIntPort(),
+        args->service_url.SchemeIsCryptographic(), args->post_factory.release(),
+        args->cancelation_signal);
+  }
   connection_manager_->set_client_id(directory()->cache_guid());
   connection_manager_->AddListener(this);
 
   std::string sync_id = directory()->cache_guid();
 
   DVLOG(1) << "Setting sync client ID: " << sync_id;
   allstatus_.SetSyncId(sync_id);
   DVLOG(1) << "Setting invalidator client ID: " << args->invalidator_client_id;
   allstatus_.SetInvalidatorClientId(args->invalidator_client_id);
 
@@ skipping 698 matching lines @@
 }
 
 void SyncManagerImpl::OnCookieJarChanged(bool account_mismatch,
                                          bool empty_jar) {
   DCHECK(thread_checker_.CalledOnValidThread());
   cycle_context_->set_cookie_jar_mismatch(account_mismatch);
   cycle_context_->set_cookie_jar_empty(empty_jar);
 }
 
 }  // namespace syncer