| Index: sync/engine/sync_scheduler_impl.cc
|
| diff --git a/sync/engine/sync_scheduler_impl.cc b/sync/engine/sync_scheduler_impl.cc
|
| index b2180fbded8e803e691895fe562d4c82dd5be815..e26c29984ad165d157feb83b8939e351fab7a1ea 100644
|
| --- a/sync/engine/sync_scheduler_impl.cc
|
| +++ b/sync/engine/sync_scheduler_impl.cc
|
| @@ -140,8 +140,6 @@ GetUpdatesCallerInfo::GetUpdatesSource GetUpdatesFromNudgeSource(
|
| return GetUpdatesCallerInfo::NOTIFICATION;
|
| case NUDGE_SOURCE_LOCAL:
|
| return GetUpdatesCallerInfo::LOCAL;
|
| - case NUDGE_SOURCE_CONTINUATION:
|
| - return GetUpdatesCallerInfo::SYNC_CYCLE_CONTINUATION;
|
| case NUDGE_SOURCE_LOCAL_REFRESH:
|
| return GetUpdatesCallerInfo::DATATYPE_REFRESH;
|
| case NUDGE_SOURCE_UNKNOWN:
|
| @@ -782,23 +780,14 @@ void SyncSchedulerImpl::DoSyncSessionJob(const SyncSessionJob& job) {
|
|
|
| job.session->RebaseRoutingInfoWithLatest(*session);
|
| }
|
| - SDVLOG(2) << "DoSyncSessionJob with "
|
| - << SyncSessionJob::GetPurposeString(job.purpose) << " job";
|
| -
|
| SyncerStep begin(SYNCER_END);
|
| SyncerStep end(SYNCER_END);
|
| SetSyncerStepsForPurpose(job.purpose, &begin, &end);
|
|
|
| - bool has_more_to_sync = true;
|
| - while (ShouldRunJob(job) && has_more_to_sync) {
|
| - SDVLOG(2) << "Calling SyncShare.";
|
| - // Synchronously perform the sync session from this thread.
|
| - syncer_->SyncShare(job.session.get(), begin, end);
|
| - has_more_to_sync = job.session->HasMoreToSync();
|
| - if (has_more_to_sync)
|
| - job.session->PrepareForAnotherSyncCycle();
|
| - }
|
| - SDVLOG(2) << "Done SyncShare looping.";
|
| + SDVLOG(2) << "Calling SyncShare with "
|
| + << SyncSessionJob::GetPurposeString(job.purpose) << "job";
|
| + syncer_->SyncShare(job.session.get(), begin, end);
|
| + SDVLOG(2) << "Done SyncShare.";
|
|
|
| FinishSyncSessionJob(job);
|
| }
|
| @@ -861,8 +850,6 @@ void SyncSchedulerImpl::FinishSyncSessionJob(const SyncSessionJob& job) {
|
|
|
| void SyncSchedulerImpl::ScheduleNextSync(const SyncSessionJob& old_job) {
|
| DCHECK_EQ(MessageLoop::current(), sync_loop_);
|
| - DCHECK(!old_job.session->HasMoreToSync());
|
| -
|
| AdjustPolling(&old_job);
|
|
|
| if (old_job.session->Succeeded()) {
|
|
|