170     const SyncSessionJob& job) {  in DecideWhileInWaitInterval()  argument
173   DCHECK_NE(job.purpose, SyncSessionJob::CLEAR_USER_DATA);  in DecideWhileInWaitInterval()
178           << job.is_canary_job;  in DecideWhileInWaitInterval()
180   if (job.purpose == SyncSessionJob::POLL)  in DecideWhileInWaitInterval()
183   DCHECK(job.purpose == SyncSessionJob::NUDGE ||  in DecideWhileInWaitInterval()
184       job.purpose == SyncSessionJob::CONFIGURATION);  in DecideWhileInWaitInterval()
189   if (job.purpose == SyncSessionJob::NUDGE) {  in DecideWhileInWaitInterval()
198   return job.is_canary_job ? CONTINUE : SAVE;  in DecideWhileInWaitInterval()
202     const SyncSessionJob& job) {  in DecideOnJob()  argument
203   if (job.purpose == SyncSessionJob::CLEAR_USER_DATA)  in DecideOnJob()
207     return DecideWhileInWaitInterval(job);  in DecideOnJob()
210     if (job.purpose == SyncSessionJob::NUDGE)  in DecideOnJob()
212     else if (job.purpose == SyncSessionJob::CONFIGURATION)  in DecideOnJob()
220   DCHECK_NE(job.purpose, SyncSessionJob::CONFIGURATION);  in DecideOnJob()
223   if (job.scheduled_start < last_sync_session_end_time_) {  in DecideOnJob()
234   return job.purpose == SyncSessionJob::NUDGE ? SAVE : DROP;  in DecideOnJob()
237 void SyncerThread::InitOrCoalescePendingJob(const SyncSessionJob& job) {  in InitOrCoalescePendingJob()  argument
238   DCHECK(job.purpose != SyncSessionJob::CONFIGURATION);  in InitOrCoalescePendingJob()
242     SyncSession* s = job.session.get();  in InitOrCoalescePendingJob()
246     SyncSessionJob new_job(SyncSessionJob::NUDGE, job.scheduled_start,  in InitOrCoalescePendingJob()
247         make_linked_ptr(session.release()), false, job.nudge_location);  in InitOrCoalescePendingJob()
254   pending_nudge_->session->Coalesce(*(job.session.get()));  in InitOrCoalescePendingJob()
255   pending_nudge_->scheduled_start = job.scheduled_start;  in InitOrCoalescePendingJob()
261 bool SyncerThread::ShouldRunJob(const SyncSessionJob& job) {  in ShouldRunJob()  argument
262   JobProcessDecision decision = DecideOnJob(job);  in ShouldRunJob()
264           << decision << " Job purpose " << job.purpose << "mode " << mode_;  in ShouldRunJob()
268   DCHECK(job.purpose == SyncSessionJob::NUDGE || job.purpose ==  in ShouldRunJob()
271   SaveJob(job);  in ShouldRunJob()
275 void SyncerThread::SaveJob(const SyncSessionJob& job) {  in SaveJob()  argument
276   DCHECK(job.purpose != SyncSessionJob::CLEAR_USER_DATA);  in SaveJob()
277   if (job.purpose == SyncSessionJob::NUDGE) {  in SaveJob()
279     InitOrCoalescePendingJob(job);  in SaveJob()
280   } else if (job.purpose == SyncSessionJob::CONFIGURATION){  in SaveJob()
285     SyncSession* old = job.session.get();  in SaveJob()
288     SyncSessionJob new_job(job.purpose, TimeTicks::Now(),  in SaveJob()
289                           make_linked_ptr(s), false, job.nudge_location);  in SaveJob()
368   SyncSessionJob job(SyncSessionJob::NUDGE, TimeTicks::Now() + delay,  in ScheduleNudgeImpl()  local
373   if (!ShouldRunJob(job))  in ScheduleNudgeImpl()
384     pending_nudge_->session->Coalesce(*(job.session.get()));  in ScheduleNudgeImpl()
394       job.session.reset(new SyncSession(s->context(), s->delegate(),  in ScheduleNudgeImpl()
401   ScheduleSyncSessionJob(delay, SyncSessionJob::NUDGE, job.session.release(),  in ScheduleNudgeImpl()
489   SyncSessionJob job(purpose, TimeTicks::Now() + delay,  in ScheduleSyncSessionJob()  local
495     pending_nudge_.reset(new SyncSessionJob(job));  in ScheduleSyncSessionJob()
499           << job.purpose;  in ScheduleSyncSessionJob()
501       &SyncerThread::DoSyncSessionJob, job),  in ScheduleSyncSessionJob()
526 void SyncerThread::DoSyncSessionJob(const SyncSessionJob& job) {  in DoSyncSessionJob()  argument
528   if (!ShouldRunJob(job)) {  in DoSyncSessionJob()
530         << job.session->source().updates_source;  in DoSyncSessionJob()
534   if (job.purpose == SyncSessionJob::NUDGE) {  in DoSyncSessionJob()
535     if (pending_nudge_.get() == NULL || pending_nudge_->session != job.session)  in DoSyncSessionJob()
540           << job.purpose;  in DoSyncSessionJob()
544   SetSyncerStepsForPurpose(job.purpose, &begin, &end);  in DoSyncSessionJob()
547   while (ShouldRunJob(job) && has_more_to_sync) {  in DoSyncSessionJob()
551     syncer_->SyncShare(job.session.get(), begin, end);  in DoSyncSessionJob()
552     has_more_to_sync = job.session->HasMoreToSync();  in DoSyncSessionJob()
554       job.session->ResetTransientState();  in DoSyncSessionJob()
558   FinishSyncSessionJob(job);  in DoSyncSessionJob()
580 void SyncerThread::FinishSyncSessionJob(const SyncSessionJob& job) {  in FinishSyncSessionJob()  argument
586     for (iter = job.session->source().types.begin();  in FinishSyncSessionJob()
587          iter != job.session->source().types.end();  in FinishSyncSessionJob()
594   UpdateCarryoverSessionState(job);  in FinishSyncSessionJob()
598     SaveJob(job);  in FinishSyncSessionJob()
604   ScheduleNextSync(job);  in FinishSyncSessionJob()
713     SyncSessionJob job(old_job.purpose, TimeTicks::Now() + length,  in HandleConsecutiveContinuationError()  local
715     wait_interval_->pending_configure_job.reset(new SyncSessionJob(job));  in HandleConsecutiveContinuationError()