WIP: Local sync only...

components/sync/engine_impl/sync_scheduler_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_scheduler_impl.h"
 
 #include <algorithm>
 #include <cstring>
 #include <utility>
 
@@ skipping 338 matching lines @@
   if (IsCurrentlyThrottled()) {
     SDVLOG(1) << "Unable to run a job because we're throttled.";
     return false;
   }
 
   if (IsBackingOff() && priority != CANARY_PRIORITY) {
     SDVLOG(1) << "Unable to run a job because we're backing off.";
     return false;
   }
 
-  if (cycle_context_->connection_manager()->HasInvalidAuthToken()) {
-    SDVLOG(1) << "Unable to run a job because we have no valid auth token.";
-    return false;
-  }
+  // ### Only if needed.
+  //if (cycle_context_->connection_manager()->HasInvalidAuthToken()) {
+  //  SDVLOG(1) << "Unable to run a job because we have no valid auth token.";
+  //  return false;
+  //}
 
   return true;
 }
 
 bool SyncSchedulerImpl::CanRunNudgeJobNow(JobPriority priority) {
   DCHECK(CalledOnValidThread());
 
   if (!CanRunJobNow(priority)) {
     SDVLOG(1) << "Unable to run a nudge job right now";
     return false;
@@ skipping 140 matching lines @@
     }
   } else {
     HandleFailure(cycle->status_controller().model_neutral_state());
   }
 }
 
 void SyncSchedulerImpl::DoConfigurationSyncCycleJob(JobPriority priority) {
   DCHECK(CalledOnValidThread());
   DCHECK_EQ(mode_, CONFIGURATION_MODE);
   DCHECK(pending_configure_params_ != NULL);
-
+  LOG(ERROR) << "@@@@@ SyncSchedulerImpl::DoConfigurationSyncCycleJob 1";
   if (!CanRunJobNow(priority)) {
     SDVLOG(2) << "Unable to run configure job right now.";
     RunAndReset(&pending_configure_params_->retry_task);
     return;
   }
 
+  LOG(ERROR) << "@@@@@ SyncSchedulerImpl::DoConfigurationSyncCycleJob 2";
   SDVLOG(2) << "Will run configure SyncShare with types "
             << ModelTypeSetToString(cycle_context_->GetEnabledTypes());
   std::unique_ptr<SyncCycle> cycle(SyncCycle::Build(cycle_context_, this));
   bool success = syncer_->ConfigureSyncShare(
       pending_configure_params_->types_to_download,
       pending_configure_params_->source, cycle.get());
 
   if (success) {
+    LOG(ERROR) << "@@@@@ SyncSchedulerImpl::DoConfigurationSyncCycleJob 3";
     SDVLOG(2) << "Configure succeeded.";
     pending_configure_params_->ready_task.Run();
     pending_configure_params_.reset();
     HandleSuccess();
   } else {
+    LOG(ERROR) << "@@@@@ SyncSchedulerImpl::DoConfigurationSyncCycleJob 4";
     HandleFailure(cycle->status_controller().model_neutral_state());
     // Sync cycle might receive response from server that causes scheduler to
     // stop and draws pending_configure_params_ invalid.
     if (started_)
       RunAndReset(&pending_configure_params_->retry_task);
   }
 }
 
 void SyncSchedulerImpl::DoClearServerDataSyncCycleJob(JobPriority priority) {
   DCHECK(CalledOnValidThread());
@@ skipping 410 matching lines @@
 
 #undef SDVLOG_LOC
 
 #undef SDVLOG
 
 #undef SLOG
 
 #undef ENUM_CASE
 
 }  // namespace syncer