Lines Matching defs:job_id
210 void JobScheduler::CancelJob(JobID job_id) {
213 JobEntry* job = job_map_.Lookup(job_id);
247 new_job->job_info.job_id,
263 new_job->job_info.job_id,
280 new_job->job_info.job_id,
300 new_job->job_info.job_id,
318 new_job->job_info.job_id,
337 new_job->job_info.job_id,
356 new_job->job_info.job_id,
375 new_job->job_info.job_id,
396 new_job->job_info.job_id,
419 new_job->job_info.job_id,
440 new_job->job_info.job_id,
465 new_job->job_info.job_id,
494 new_job->job_info.job_id,
515 new_job->job_info.job_id,
537 new_job->job_info.job_id,
561 new_job->job_info.job_id,
588 new_job->job_info.job_id,
593 new_job->job_info.job_id));
596 return new_job->job_info.job_id;
627 new_job->job_info.job_id,
632 new_job->job_info.job_id);
664 new_job->job_info.job_id,
669 new_job->job_info.job_id);
691 new_job->job_info.job_id,
699 job->job_info.job_id = job_map_.Add(job); // Takes the ownership of |job|.
706 QueueJob(job->job_info.job_id);
711 void JobScheduler::QueueJob(JobID job_id) {
714 JobEntry* job_entry = job_map_.Lookup(job_id);
719 queue_[queue_type]->Push(job_id, job_entry->context.type);
759 JobID job_id = -1;
760 if (!queue_[queue_type]->PopForRun(accepted_priority, &job_id))
763 JobEntry* entry = job_map_.Lookup(job_id);
821 bool JobScheduler::OnJobDone(JobID job_id, google_apis::GDataErrorCode error) {
824 JobEntry* job_entry = job_map_.Lookup(job_id);
828 queue_[queue_type]->MarkFinished(job_id);
861 QueueJob(job_id);
866 job_map_.Remove(job_id);
879 JobID job_id,
886 if (OnJobDone(job_id, error))
891 JobID job_id,
898 if (OnJobDone(job_id, error))
903 JobID job_id,
910 if (OnJobDone(job_id, error))
915 JobID job_id,
922 if (OnJobDone(job_id, error))
927 JobID job_id,
934 if (OnJobDone(job_id, error))
939 JobID job_id,
946 if (OnJobDone(job_id, error))
951 JobID job_id,
957 if (OnJobDone(job_id, error))
962 JobID job_id,
969 if (OnJobDone(job_id, error))
974 JobID job_id,
988 JobEntry* job_entry = job_map_.Lookup(job_id);
997 job_id,
1002 job_id);
1006 if (OnJobDone(job_id, error))
1011 JobID job_id,
1024 JobEntry* job_entry = job_map_.Lookup(job_id);
1029 if (OnJobDone(job_id, error))
1033 void JobScheduler::UpdateProgress(JobID job_id, int64 progress, int64 total) {
1034 JobEntry* job_entry = job_map_.Lookup(job_id);
1100 queue_[GetJobQueueType(job->job_info.job_type)]->Remove(job->job_info.job_id);
1102 job_map_.Remove(job->job_info.job_id);