[Sync] Allow sync start without sign-in if the local sync backend is on.

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 12 matching lines @@
 #include "components/sync/base/cancelation_signal.h"
 #include "components/sync/base/experiments.h"
 #include "components/sync/base/invalidation_interface.h"
 #include "components/sync/base/model_type.h"
 #include "components/sync/engine/configure_reason.h"
 #include "components/sync/engine/engine_components_factory.h"
 #include "components/sync/engine/engine_util.h"
 #include "components/sync/engine/net/http_post_provider_factory.h"
 #include "components/sync/engine/polling_constants.h"
 #include "components/sync/engine_impl/cycle/directory_type_debug_info_emitter.h"
+#include "components/sync/engine_impl/loopback_server/loopback_connection_manager.h"
 #include "components/sync/engine_impl/model_type_connector_proxy.h"
 #include "components/sync/engine_impl/net/sync_server_connection_manager.h"
 #include "components/sync/engine_impl/sync_scheduler.h"
 #include "components/sync/engine_impl/syncer_types.h"
 #include "components/sync/engine_impl/uss_migrator.h"
 #include "components/sync/protocol/proto_value_conversions.h"
 #include "components/sync/protocol/sync.pb.h"
 #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;
@@ skipping 142 matching lines @@
                              new_routing_info, ready_task, retry_task);
 
   scheduler_->Start(SyncScheduler::CONFIGURATION_MODE, base::Time());
   scheduler_->ScheduleConfiguration(params);
 }
 
 void SyncManagerImpl::Init(InitArgs* args) {
   CHECK(!initialized_);
   DCHECK(thread_checker_.CalledOnValidThread());
   DCHECK(args->post_factory.get());
-  DCHECK(!args->credentials.account_id.empty());
-  DCHECK(!args->credentials.sync_token.empty());
-  DCHECK(!args->credentials.scope_set.empty());
+  if (!args->enable_local_sync_backend) {
+    DCHECK(!args->credentials.account_id.empty());
+    DCHECK(!args->credentials.sync_token.empty());
+    DCHECK(!args->credentials.scope_set.empty());
+  }
   DCHECK(args->cancelation_signal);
   DVLOG(1) << "SyncManager starting Init...";
 
   weak_handle_this_ = MakeWeakHandle(weak_ptr_factory_.GetWeakPtr());
 
   change_delegate_ = args->change_delegate;
 
   AddObserver(&js_sync_manager_observer_);
   SetJsEventHandler(args->event_handler);
 
@@ skipping 41 matching lines @@
   }
 
   // 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();
   }
 
   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);
 
@@ skipping 13 matching lines @@
   // Build a SyncCycleContext and store the worker in it.
   DVLOG(1) << "Sync is bringing up SyncCycleContext.";
   std::vector<SyncEngineEventListener*> listeners;
   listeners.push_back(&allstatus_);
   listeners.push_back(this);
   cycle_context_ = args->engine_components_factory->BuildContext(
       connection_manager_.get(), directory(), args->extensions_activity,
       listeners, &debug_info_event_listener_, model_type_registry_.get(),
       args->invalidator_client_id);
   scheduler_ = args->engine_components_factory->BuildScheduler(
-      name_, cycle_context_.get(), args->cancelation_signal);
+      name_, cycle_context_.get(), args->cancelation_signal,
+      args->enable_local_sync_backend);
 
   scheduler_->Start(SyncScheduler::CONFIGURATION_MODE, base::Time());
 
   initialized_ = true;
 
-  net::NetworkChangeNotifier::AddIPAddressObserver(this);
-  net::NetworkChangeNotifier::AddConnectionTypeObserver(this);
-  observing_network_connectivity_changes_ = true;
+  if (!args->enable_local_sync_backend) {
+    net::NetworkChangeNotifier::AddIPAddressObserver(this);
+    net::NetworkChangeNotifier::AddConnectionTypeObserver(this);
+    observing_network_connectivity_changes_ = true;
 
-  UpdateCredentials(args->credentials);
+    UpdateCredentials(args->credentials);
+  } else {
+    scheduler_->OnCredentialsUpdated();
+  }
 
   NotifyInitializationSuccess();
 }
 
 void SyncManagerImpl::NotifyInitializationSuccess() {
   for (auto& observer : observers_) {
     observer.OnInitializationComplete(
         MakeWeakHandle(weak_ptr_factory_.GetWeakPtr()),
         MakeWeakHandle(debug_info_event_listener_.GetWeakPtr()), true,
         InitialSyncEndedTypes());
@@ skipping 666 matching lines @@
   DCHECK(thread_checker_.CalledOnValidThread());
   cycle_context_->set_cookie_jar_mismatch(account_mismatch);
   cycle_context_->set_cookie_jar_empty(empty_jar);
 }
 
 void SyncManagerImpl::OnMemoryDump(base::trace_event::ProcessMemoryDump* pmd) {
   directory()->OnMemoryDump(pmd);
 }
 
 }  // namespace syncer