| Index: sync/engine/sync_scheduler_impl.cc
|
| diff --git a/sync/engine/sync_scheduler_impl.cc b/sync/engine/sync_scheduler_impl.cc
|
| index c270fc525f31819f193813d70cb87614756a3345..aeb95c4a81663cc00ca871efb75efab04ce287d6 100644
|
| --- a/sync/engine/sync_scheduler_impl.cc
|
| +++ b/sync/engine/sync_scheduler_impl.cc
|
| @@ -112,8 +112,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:
|
| @@ -763,23 +761,12 @@ bool SyncSchedulerImpl::DoSyncSessionJob(scoped_ptr<SyncSessionJob> job) {
|
| return false;
|
| }
|
|
|
| - SDVLOG(2) << "DoSyncSessionJob with "
|
| + SDVLOG(2) << "Calling SyncShare with "
|
| << SyncSessionJob::GetPurposeString(job->purpose()) << " job";
|
| -
|
| - bool has_more_to_sync = true;
|
| - bool premature_exit = false;
|
| - while (DecideOnJob(*job) == CONTINUE && has_more_to_sync) {
|
| - SDVLOG(2) << "Calling SyncShare.";
|
| - // Synchronously perform the sync session from this thread.
|
| - premature_exit = !syncer_->SyncShare(job->mutable_session(),
|
| - job->start_step(),
|
| - job->end_step());
|
| -
|
| - has_more_to_sync = job->session()->HasMoreToSync();
|
| - if (has_more_to_sync)
|
| - job->mutable_session()->PrepareForAnotherSyncCycle();
|
| - }
|
| - SDVLOG(2) << "Done SyncShare looping.";
|
| + bool premature_exit = !syncer_->SyncShare(job->mutable_session(),
|
| + job->start_step(),
|
| + job->end_step());
|
| + SDVLOG(2) << "Done SyncShare, returned: " << premature_exit;
|
|
|
| return FinishSyncSessionJob(job.Pass(), premature_exit);
|
| }
|
| @@ -838,7 +825,6 @@ bool SyncSchedulerImpl::FinishSyncSessionJob(scoped_ptr<SyncSessionJob> job,
|
| void SyncSchedulerImpl::ScheduleNextSync(
|
| scoped_ptr<SyncSessionJob> finished_job, bool succeeded) {
|
| DCHECK_EQ(MessageLoop::current(), sync_loop_);
|
| - DCHECK(!finished_job->session()->HasMoreToSync());
|
|
|
| AdjustPolling(finished_job.get());
|
|
|
|
|