Lines Matching refs:job_info

145     : job_info(type),
196 job_info_list.push_back(iter.GetCurrentValue()->job_info);
215 if (job->job_info.state == STATE_RUNNING) {
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,
578 new_job->job_info.file_path = virtual_path;
579 new_job->job_info.num_total_bytes = expected_file_size;
588 new_job->job_info.job_id,
593 new_job->job_info.job_id));
596 return new_job->job_info.job_id;
611 new_job->job_info.file_path = drive_file_path;
627 new_job->job_info.job_id,
632 new_job->job_info.job_id);
649 new_job->job_info.file_path = drive_file_path;
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);
707 NotifyJobAdded(job->job_info);
708 DoJobLoop(GetJobQueueType(job->job_info.job_type));
716 const JobInfo& job_info = job_entry->job_info;
718 const QueueType queue_type = GetJobQueueType(job_info.job_type);
726 job_info.ToString().c_str(),
766 JobInfo* job_info = &entry->job_info;
767 job_info->state = STATE_RUNNING;
768 job_info->start_time = now;
769 NotifyJobUpdated(*job_info);
777 job_info->ToString().c_str(),
826 JobInfo* job_info = &job_entry->job_info;
827 QueueType queue_type = GetJobQueueType(job_info->job_type);
830 const base::TimeDelta elapsed = base::Time::Now() - job_info->start_time;
834 job_info->ToString().c_str(),
855 job_info->state = STATE_RETRY;
856 NotifyJobUpdated(*job_info);
863 NotifyJobDone(*job_info, error);
1037 job_entry->job_info.num_completed_bytes = progress;
1039 job_entry->job_info.num_total_bytes = total;
1040 NotifyJobUpdated(job_entry->job_info);
1089 const base::TimeDelta elapsed = base::Time::Now() - job->job_info.start_time;
1090 const QueueType queue_type = GetJobQueueType(job->job_info.job_type);
1093 job->job_info.ToString().c_str(),
1100 queue_[GetJobQueueType(job->job_info.job_type)]->Remove(job->job_info.job_id);
1101 NotifyJobDone(job->job_info, error);
1102 job_map_.Remove(job->job_info.job_id);
1107 void JobScheduler::NotifyJobAdded(const JobInfo& job_info) {
1109 FOR_EACH_OBSERVER(JobListObserver, observer_list_, OnJobAdded(job_info));
1112 void JobScheduler::NotifyJobDone(const JobInfo& job_info,
1116 OnJobDone(job_info, GDataToFileError(error)));
1119 void JobScheduler::NotifyJobUpdated(const JobInfo& job_info) {
1121 FOR_EACH_OBSERVER(JobListObserver, observer_list_, OnJobUpdated(job_info));