Searched defs:job (Results 1 - 25 of 123) sorted by relevance

12345

/external/chromium_org/net/http/
H A Dhttp_stream_factory_impl_request_unittest.cc77 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 Dprtpool.h66 /* 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 Dgyptest-xctest.py20 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 Dgyptest-postbuild-fail.py36 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 Daw_url_request_job_factory.cc44 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 Dsocket_stream_job_manager.cc28 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 Durl_request_intercepting_job_factory.cc27 URLRequestJob* job = interceptor_->MaybeInterceptRequest(request, local
29 if (job)
30 return job;
H A Durl_request_job_factory_impl.cc54 URLRequestJob* job = g_interceptor_for_testing->MaybeInterceptRequest( local
56 if (job)
57 return job;
H A Durl_request_filter.cc132 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 Durl_request_job_manager.cc77 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 Dservice_worker_context_request_handler_unittest.cc99 scoped_refptr<net::URLRequestJob> job = local
101 ASSERT_TRUE(job.get());
103 static_cast<ServiceWorkerWriteToCacheJob*>(job.get());
130 scoped_refptr<net::URLRequestJob> job = local
132 ASSERT_TRUE(job.get());
134 static_cast<ServiceWorkerWriteToCacheJob*>(job.get());
H A Dservice_worker_unregister_job.cc46 bool ServiceWorkerUnregisterJob::Equals(ServiceWorkerRegisterJobBase* job) { argument
47 if (job->GetType() != GetType())
49 return static_cast<ServiceWorkerUnregisterJob*>(job)->pattern_ == pattern_;
H A Dservice_worker_controllee_request_handler_unittest.cc105 scoped_refptr<net::URLRequestJob> job = local
108 static_cast<ServiceWorkerURLRequestJob*>(job.get());
155 scoped_refptr<net::URLRequestJob> job = local
158 static_cast<ServiceWorkerURLRequestJob*>(job.get());
H A Dservice_worker_job_coordinator.cc22 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
112 FinishJob(const GURL& pattern, ServiceWorkerRegisterJobBase* job) argument
[all...]
/external/chromium_org/sandbox/win/src/
H A Djob_unittest.cc5 // 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 Dintegration_tests_test.cc68 // 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 Dprint_job_manager.cc25 void PrintQueriesQueue::QueuePrinterQuery(PrinterQuery* job) { argument
27 DCHECK(job);
28 queued_queries_.push_back(make_scoped_refptr(job));
29 DCHECK(job->is_valid());
50 scoped_refptr<PrinterQuery> job = local
52 return job;
102 for (PrintJobs::const_iterator job = to_stop.begin(); job != to_stop.end();
103 ++job) {
104 // Wait for two minutes for the print job t
[all...]
/external/chromium_org/net/base/
H A Dprioritized_dispatcher.cc27 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 Dwebsocket_throttle.cc42 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 DResourceRunner.java28 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 DDispatcher.java106 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 Dexternal_policy_data_fetcher.cc23 // 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 Dexternal_policy_data_fetcher_unittest.cc98 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 Durl_request_slow_download_job.cc65 URLRequestSlowDownloadJob* job = new URLRequestSlowDownloadJob( local
69 pending_requests_.Get().insert(job);
70 return job;
/external/chromium_org/net/dns/
H A Daddress_sorter_win.cc36 scoped_refptr<Job> job = new Job(list, callback); variable

Completed in 6775 milliseconds

12345