Cross Reference: /external/chromium/net/proxy/multi_threaded_proxy

Lines Matching refs:executor
36 // An "executor" is a job-runner for PAC requests. It encapsulates a worker
43   // signal when the executor is ready to receive work by calling
51   // Submit a job to this executor.
54   // Callback for when a job has completed running on the executor's thread.
57   // Cleanup the executor. Cancels all outstanding work, and frees the thread
77   // The currently active job for this executor (either a SetPacScript or
110   void set_executor(Executor* executor) {
111     executor_ = executor;
114   // The "executor" is the job runner that is scheduling this job. If
115   // this job has not been submitted to an executor yet, this will be
117   Executor* executor() {
153     // |executor_| will be NULL if the executor has already been deleted.
192     ProxyResolver* resolver = executor()->resolver();
242     DCHECK(executor());
252             "thread_number", executor()->thread_number())));
257     ProxyResolver* resolver = executor()->resolver();
351     // Orphan the job (since this executor may be deleted soon).
415   // If there is an executor that is ready to run this request, submit it!
416   Executor* executor = FindIdleExecutor();
417   if (executor) {
419     executor->StartJob(job);
431     executor = AddNewExecutor();
432     executor->StartJob(
446   if (job->executor()) {
447     // If the job was already submitted to the executor, just mark it
477     Executor* executor = *it;
478     executor->PurgeMemory();
498   // Provision a new executor, and run the SetPacScript request. On completion
500   Executor* executor = AddNewExecutor();
501   executor->StartJob(new SetPacScriptJob(script_data, callback));
511     const Executor* executor = *it;
512     Job* job = executor->outstanding_job();
527     Executor* executor = *it;
528     executor->Destroy();
538     Executor* executor = *it;
539     if (!executor->outstanding_job())
540       return executor;
552   Executor* executor = new Executor(
554   executors_.push_back(make_scoped_refptr(executor));
555   return executor;
558 void MultiThreadedProxyResolver::OnExecutorReady(Executor* executor) {
564   // to the executor.
567   executor->StartJob(job);