Lines Matching refs:Job
101 // SingleThreadedProxyResolver::Job -------------------------------------------
103 class SingleThreadedProxyResolver::Job
104 : public base::RefCountedThreadSafe<SingleThreadedProxyResolver::Job> {
106 // |coordinator| -- the SingleThreadedProxyResolver that owns this job.
109 Job(SingleThreadedProxyResolver* coordinator,
131 FROM_HERE, NewRunnableMethod(this, &Job::DoQuery,
150 friend class base::RefCountedThreadSafe<SingleThreadedProxyResolver::Job>;
152 ~Job() {}
167 NewRunnableMethod(this, &Job::QueryComplete, rv, worker_log));
180 // The Job may have been cancelled after it was started.
216 // Cancel the inprogress job (if any), and free the rest.
237 scoped_refptr<Job> job = new Job(this, url, results, callback, load_log);
238 pending_jobs_.push_back(job);
244 *request = reinterpret_cast<RequestHandle>(job.get());
251 // (2) Executing Job::DoQuery in the worker thread.
252 // (3) Waiting for Job::QueryComplete to be run on the origin thread.
256 Job* job = reinterpret_cast<Job*>(req);
258 bool is_active_job = job->is_started() && !pending_jobs_.empty() &&
259 pending_jobs_.front().get() == job;
261 job->Cancel();
264 RemoveFrontOfJobsQueueAndStartNext(job);
268 // Otherwise just delete the job from the queue.
270 pending_jobs_.begin(), pending_jobs_.end(), job);
314 // Get the next job to process (FIFO).
315 Job* job = pending_jobs_.front().get();
316 if (job->is_started())
320 job->Start();
324 Job* expected_job) {
