/external/chromium_org/net/http/ |
H A D | http_stream_factory_impl_request_unittest.cc | 77 HttpStreamFactoryImpl::Job* job = local 85 request.AttachJob(job); 86 EXPECT_EQ(DEFAULT_PRIORITY, job->priority()); 89 EXPECT_EQ(MEDIUM, job->priority()); 91 // Make |job| the bound job. 92 request.OnStreamFailed(job, ERR_FAILED, SSLConfig()); 95 EXPECT_EQ(IDLE, job->priority());
|
/external/chromium_org/third_party/npapi/npspy/extern/nspr/ |
H A D | prtpool.h | 66 /* queue a job */ 70 /* queue a job, when a socket is readable */ 75 /* queue a job, when a socket is writeable */ 80 /* queue a job, when a socket has a pending connection */ 85 /* queue a job, when the socket connection to addr succeeds or fails */ 90 /* queue a job, when a timer exipres */ 94 /* cancel a job */ 96 PR_CancelJob(PRJob *job); variable 98 /* join a job */ 100 PR_JoinJob(PRJob *job); variable [all...] |
/external/chromium_org/tools/gyp/test/mac/ |
H A D | gyptest-xctest.py | 20 job = subprocess.Popen(['xcodebuild', '-version'], variable 23 out, err = job.communicate() 24 if job.returncode != 0: 25 raise Exception('Error %d running xcodebuild' % job.returncode)
|
H A D | gyptest-postbuild-fail.py | 36 job = subprocess.Popen(['xcodebuild', '-version'], variable 39 out, err = job.communicate() 40 if job.returncode != 0: 42 raise Exception('Error %d running xcodebuild' % job.returncode)
|
/external/chromium_org/android_webview/browser/net/ |
H A D | aw_url_request_job_factory.cc | 44 URLRequestJob* job = next_factory_->MaybeCreateJobWithProtocolHandler( local 47 if (job) 48 return job; 51 // In that case the built in handlers will then be used to create the job.
|
/external/chromium_org/net/socket_stream/ |
H A D | socket_stream_job_manager.cc | 28 SocketStreamJob* job = new SocketStreamJob(); local 29 job->InitSocketStream(new SocketStream(url, delegate, context, 31 return job; 39 SocketStreamJob* job = found->second(url, delegate, context, cookie_store); local 40 if (job) 41 return job; 43 SocketStreamJob* job = new SocketStreamJob(); local 44 job->InitSocketStream(new SocketStream(url, delegate, context, cookie_store)); 45 return job;
|
/external/chromium_org/net/url_request/ |
H A D | url_request_intercepting_job_factory.cc | 27 URLRequestJob* job = interceptor_->MaybeInterceptRequest(request, local 29 if (job) 30 return job;
|
H A D | url_request_job_factory_impl.cc | 54 URLRequestJob* job = g_interceptor_for_testing->MaybeInterceptRequest( local 56 if (job) 57 return job;
|
H A D | url_request_filter.cc | 132 URLRequestJob* job = NULL; local 143 job = it->second->MaybeInterceptRequest(request, network_delegate); 145 if (!job) { 150 job = it->second->MaybeInterceptRequest(request, network_delegate); 152 if (job) { 156 return job;
|
H A D | url_request_job_manager.cc | 77 URLRequestJob* job = (*i)->MaybeIntercept(request, network_delegate); local 78 if (job) 79 return job; 83 URLRequestJob* job = job_factory->MaybeCreateJobWithProtocolHandler( local 85 if (job) 86 return job; 91 URLRequestJob* job = (kBuiltinFactories[i].factory)( local 93 DCHECK(job); // The built-in factories are not expected to fail! 94 return job; 125 URLRequestJob* job local 152 URLRequestJob* job = (*i)->MaybeInterceptResponse(request, local [all...] |
/external/chromium_org/content/browser/service_worker/ |
H A D | service_worker_unregister_job.cc | 41 bool ServiceWorkerUnregisterJob::Equals(ServiceWorkerRegisterJobBase* job) { argument 42 if (job->GetType() != GetType()) 44 return static_cast<ServiceWorkerUnregisterJob*>(job)->pattern_ == pattern_;
|
H A D | service_worker_job_coordinator.cc | 22 scoped_ptr<ServiceWorkerRegisterJobBase> job) { 24 job->Start(); 25 jobs_.push_back(job.release()); 26 } else if (!job->Equals(jobs_.back())) { 27 jobs_.push_back(job.release()); 29 // Note we are releasing 'job' here. 36 ServiceWorkerRegisterJobBase* job) { 37 DCHECK(job == jobs_.front()); 39 delete job; 68 << job_queues_.size() << " job queue 21 Push( scoped_ptr<ServiceWorkerRegisterJobBase> job) argument 35 Pop( ServiceWorkerRegisterJobBase* job) argument 103 FinishJob(const GURL& pattern, ServiceWorkerRegisterJobBase* job) argument [all...] |
/external/chromium_org/sandbox/win/src/ |
H A D | job_unittest.cc | 5 // This file contains unit tests for the job object. 8 #include "sandbox/win/src/job.h" 13 // Tests the creation and destruction of the job. 17 // Create the job. 18 Job job; local 19 ASSERT_EQ(ERROR_SUCCESS, job.Init(JOB_LOCKDOWN, L"my_test_job_name", 0, 0)); 21 // check if the job exists. 30 // Check if the job is destroyed when the object goes out of scope. 41 // Create the job. 42 Job job; local 74 Job job; local 95 Job job; local 117 Job job; local 125 Job job; local 160 Job job; local [all...] |
/external/chromium_org/sandbox/win/tests/integration_tests/ |
H A D | integration_tests_test.cc | 68 // Creates a job and tries to run a process inside it. The function can be 72 // JOB_OBJECT_LIMIT_BREAKAWAY_OK flag should be set on the job object created 77 HANDLE job = ::CreateJobObject(NULL, NULL); local 78 if (!job) 82 if (!::QueryInformationJobObject(job, JobObjectExtendedLimitInformation, 95 if (!::SetInformationJobObject(job, JobObjectExtendedLimitInformation, 99 if (!::AssignProcessToJobObject(job, ::GetCurrentProcess())) 112 // Terminate the job now. 113 ::TerminateJobObject(job, SBOX_TEST_SUCCEEDED); 267 // Running from inside job tha [all...] |
/external/chromium_org/chrome/browser/printing/ |
H A D | print_job_manager.cc | 30 void PrintQueriesQueue::QueuePrinterQuery(PrinterQuery* job) { argument 32 DCHECK(job); 33 queued_queries_.push_back(make_scoped_refptr(job)); 34 DCHECK(job->is_valid()); 53 scoped_refptr<PrinterQuery> job = new printing::PrinterQuery; local 55 job->SetWorkerDestination(destination_); 56 return job; 108 for (PrintJobs::const_iterator job = to_stop.begin(); job != to_stop.end(); 109 ++job) { [all...] |
/external/chromium_org/net/base/ |
H A D | prioritized_dispatcher.cc | 27 Job* job, Priority priority) { 28 DCHECK(job); 32 job->Start(); 35 return queue_.Insert(job, priority); 39 Job* job, Priority priority) { 40 DCHECK(job); 44 job->Start(); 47 return queue_.InsertAtFront(job, priority); 58 Job* job = handle.value(); 60 return job; 26 Add( Job* job, Priority priority) argument 38 AddAtHead( Job* job, Priority priority) argument [all...] |
/external/chromium_org/net/websockets/ |
H A D | websocket_throttle.cc | 42 bool WebSocketThrottle::PutInQueue(WebSocketJob* job) { argument 46 queue_.push_back(job); 47 const AddressList& address_list = job->address_list(); 61 new_queue->second.push_back(job); 64 iter->second.push_back(job); 65 job->SetWaiting(); 73 void WebSocketThrottle::RemoveFromQueue(WebSocketJob* job) { argument 75 std::find(queue_.begin(), queue_.end(), job); 82 const AddressList& resolved_address_list = job->address_list(); 99 std::find(per_address_queue.begin(), per_address_queue.end(), job); 121 WebSocketJob* job = *iter; local [all...] |
/external/glide/library/src/main/java/com/bumptech/glide/load/engine/ |
H A D | ResourceRunner.java | 28 private final EngineJob job; field in class:ResourceRunner 42 ExecutorService resizeService, EngineJob job, Priority priority) { 53 this.job = job; 58 return job; 90 job.onResourceReady(transcoded); 39 ResourceRunner(EngineKey key, int width, int height, CacheLoader cacheLoader, ResourceDecoder<InputStream, Z> cacheDecoder, Transformation<Z> transformation, ResourceTranscoder<Z, R> transcoder, SourceResourceRunner sourceRunner, ExecutorService diskCacheService, ExecutorService resizeService, EngineJob job, Priority priority) argument
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
H A D | Dispatcher.java | 106 Job job = new Job(this, client, request, receiver); 108 if (runningJobs.size() < maxRequests && runningJobsForHost(job) < maxRequestsPerHost) { 109 runningJobs.add(job); 110 getExecutorService().execute(job); 112 readyJobs.add(job); 117 * Cancel all jobs with the tag {@code tag}. If a canceled job is running it 125 for (Job job : runningJobs) { 126 if (Util.equal(tag, job.tag())) job.canceled = true; 131 synchronized void finished(Job job) { argument 154 runningJobsForHost(Job job) argument [all...] |
/external/chromium_org/components/policy/core/common/cloud/ |
H A D | external_policy_data_fetcher.cc | 23 // Helper that forwards the result of a fetch job from the thread that the 25 // ExternalPolicyDataFetcher which started the job runs on. 29 ExternalPolicyDataFetcher::Job* job, 33 base::Bind(callback, job, result, base::Passed(&data))); 36 // Helper that forwards a job cancelation confirmation from the thread that the 38 // ExternalPolicyDataFetcher which canceled the job runs on. 45 // Helper invoked when a job cancelation confirmation has been forwarded to the 46 // thread which canceled the job. The helper itself does nothing. It exists so 47 // that the |job| can be passed as base::Owned(), allowing it to be deleted on 48 // the correct thread and after any pending callbacks for the |job| hav 26 ForwardJobFinished( scoped_refptr<base::SequencedTaskRunner> task_runner, const ExternalPolicyDataFetcherBackend::FetchCallback& callback, ExternalPolicyDataFetcher::Job* job, ExternalPolicyDataFetcher::Result result, scoped_ptr<std::string> data) argument 50 DoNothing(ExternalPolicyDataFetcher::Job* job) argument 98 Job* job = new Job( local 112 CancelJob(Job* job) argument 132 OnJobFinished(const FetchCallback& callback, Job* job, Result result, scoped_ptr<std::string> data) argument 170 StartJob( ExternalPolicyDataFetcher::Job* job) argument 185 CancelJob( ExternalPolicyDataFetcher::Job* job, const base::Closure& callback) argument 239 ExternalPolicyDataFetcher::Job* job = it->second; local 258 ExternalPolicyDataFetcher::Job* job = it->second; local [all...] |
H A D | external_policy_data_fetcher_unittest.cc | 98 ExternalPolicyDataFetcher::Job* job = it->second; local 100 fetcher_->CancelJob(job); 121 // Start a fetch job. 147 // Start a fetch job. 173 // Start a fetch job. 199 // Start a fetch job. 224 // Start a fetch job. 248 // Start a fetch job. 272 // Start a fetch job. 296 // Start a fetch job [all...] |
/external/chromium_org/content/test/net/ |
H A D | url_request_slow_download_job.cc | 65 URLRequestSlowDownloadJob* job = new URLRequestSlowDownloadJob( local 69 pending_requests_.Get().insert(job); 70 return job;
|
/external/chromium_org/net/dns/ |
H A D | address_sorter_win.cc | 36 scoped_refptr<Job> job = new Job(list, callback); variable
|
/external/chromium_org/v8/src/ |
H A D | optimizing-compiler-thread.cc | 91 OptimizedCompileJob* job = input_queue_[InputQueueIndex(0)]; 92 ASSERT_NE(NULL, job); 95 return job; 100 OptimizedCompileJob* job = NextInput(); local 101 ASSERT_NE(NULL, job); 104 OptimizedCompileJob::Status status = job->OptimizeGraph(); 111 output_queue_.Enqueue(job); 116 static void DisposeOptimizedCompileJob(OptimizedCompileJob* job, argument 118 // The recompile job is allocated in the CompilationInfo's zone. 119 CompilationInfo* info = job 138 OptimizedCompileJob* job; local 152 OptimizedCompileJob* job; local 223 OptimizedCompileJob* job; local 252 QueueForOptimization(OptimizedCompileJob* job) argument 333 AddToOsrBuffer(OptimizedCompileJob* job) argument [all...] |
/external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/plugins/ |
H A D | org.eclipse.core.jobs_3.5.1.R36x_v20100824.jar | ... org.eclipse.core.runtime.jobs.Job realJob
synchronized void end (org.eclipse.core. ... |