Searched refs:job (Results 1 - 25 of 187) sorted by relevance

12345678

/external/chromium_org/net/http/
H A Dhttp_stream_factory_impl_request.cc65 void HttpStreamFactoryImpl::Request::AttachJob(Job* job) { argument
66 DCHECK(job);
67 jobs_.insert(job);
68 factory_->request_map_[job] = this;
90 Job* job,
98 OnJobSucceeded(job);
103 Job* job,
111 OnJobSucceeded(job);
117 Job* job,
121 DCHECK(job);
89 OnStreamReady( Job* job, const SSLConfig& used_ssl_config, const ProxyInfo& used_proxy_info, HttpStreamBase* stream) argument
102 OnWebSocketHandshakeStreamReady( Job* job, const SSLConfig& used_ssl_config, const ProxyInfo& used_proxy_info, WebSocketHandshakeStreamBase* stream) argument
116 OnStreamFailed( Job* job, int status, const SSLConfig& used_ssl_config) argument
145 OnCertificateError( Job* job, int status, const SSLConfig& used_ssl_config, const SSLInfo& ssl_info) argument
158 OnNeedsProxyAuth( Job* job, const HttpResponseInfo& proxy_response, const SSLConfig& used_ssl_config, const ProxyInfo& used_proxy_info, HttpAuthController* auth_controller) argument
172 OnNeedsClientAuth( Job* job, const SSLConfig& used_ssl_config, SSLCertRequestInfo* cert_info) argument
183 OnHttpsProxyTunnelResponse( Job *job, const HttpResponseInfo& response_info, const SSLConfig& used_ssl_config, const ProxyInfo& used_proxy_info, HttpStreamBase* stream) argument
264 OnNewSpdySessionReady( Job* job, scoped_ptr<HttpStream> stream, const base::WeakPtr<SpdySession>& spdy_session, bool direct) argument
318 OrphanJobsExcept(Job* job) argument
339 OnJobSucceeded(Job* job) argument
[all...]
H A Dhttp_stream_factory_impl_request.h42 // Attaches |job| to this request. Does not mean that Request will use |job|,
43 // but Request will own |job|.
44 void AttachJob(HttpStreamFactoryImpl::Job* job);
58 void OnNewSpdySessionReady(Job* job,
71 void OnStreamReady(Job* job,
75 void OnWebSocketHandshakeStreamReady(Job* job,
79 void OnStreamFailed(Job* job, int status, const SSLConfig& used_ssl_config);
80 void OnCertificateError(Job* job,
84 void OnNeedsProxyAuth(Job* job,
[all...]
H A Dhttp_stream_factory_impl.cc130 Job* job = new Job(this, session_, request_info, priority, local
132 request->AttachJob(job);
137 job->WaitFor(alternate_job);
139 // |alternate_job|, otherwise |alternate_job| will not notify |job|
145 // so starting |job| is always safe.
146 job->Start(request);
160 Job* job = NULL; local
164 job = new Job(this, session_, alternate_request_info, priority,
166 job->MarkAsAlternate(request_info.url, alternate);
168 job
248 OrphanJob(Job* job, const Request* request) argument
302 OnOrphanedJobComplete(const Job* job) argument
307 OnPreconnectsComplete(const Job* job) argument
[all...]
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/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/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/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/content/browser/service_worker/
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
103 FinishJob(const GURL& pattern, ServiceWorkerRegisterJobBase* job) argument
[all...]
H A Dservice_worker_job_coordinator.h41 // Removes the job. A job that was not aborted must call FinishJob when it is
43 void FinishJob(const GURL& pattern, ServiceWorkerRegisterJobBase* job);
51 // Adds a job to the queue. If an identical job is already in the queue, no
52 // new job is added. Returns the job in the queue, regardless of whether it
55 scoped_ptr<ServiceWorkerRegisterJobBase> job);
57 // Removes a job from the queue.
58 void Pop(ServiceWorkerRegisterJobBase* job);
[all...]
H A Dservice_worker_register_job_base.h11 // job lives only for the lifetime of a single registration or unregistration.
18 // Starts the job. This method should be called once and only once per job.
21 // Aborts the job. This method should be called once and only once per job.
25 // Returns true if this job is identical to |job| for the purpose of
29 virtual bool Equals(ServiceWorkerRegisterJobBase* job) = 0;
31 // Returns the type of this job.
/external/chromium_org/chrome/browser/policy/cloud/
H A Ddevice_management_service_browsertest.cc132 scoped_ptr<DeviceManagementRequestJob> job(
135 job->SetGaiaToken("gaia_auth_token");
136 job->SetOAuthToken("oauth_token");
137 job->SetClientID("testid");
138 job->GetRequest()->mutable_register_request();
139 job->Start(base::Bind(&DeviceManagementServiceIntegrationTest::OnJobDone,
193 scoped_ptr<DeviceManagementRequestJob> job(service_->CreateJob(
196 job->SetDMToken(token_);
197 job->SetClientID("testid");
199 job
[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_updater.cc140 // If the job is currently running, a corresponding |fetch_job_| exists in the
141 // |external_policy_data_fetcher_|. The job must eventually call back to the
143 // If the job is currently not running, |fetch_job_| is NULL and no callbacks
192 // Cancel the fetch job in the |external_policy_data_fetcher_|.
194 // Inform the |updater_| that the job was canceled.
210 // Start a fetch job in the |external_policy_data_fetcher_|. This will
221 // The fetch job in the |external_policy_data_fetcher_| is finished.
278 // This function may have been invoked because the job was obsoleted and is
318 // Check whether a job exists for this |key| already.
319 FetchJob* job local
346 std::map<std::string, FetchJob*>::iterator job = job_map_.find(key); local
358 FetchJob* job = job_queue_.front().get(); local
370 ScheduleJob(FetchJob* job) argument
378 OnJobSucceeded(FetchJob* job) argument
389 OnJobFailed(FetchJob* job) argument
[all...]
/external/chromium_org/net/url_request/
H A Durl_request_http_job_unittest.cc66 scoped_refptr<TestURLRequestHttpJob> job(new TestURLRequestHttpJob(&req_));
67 EXPECT_EQ(DEFAULT_PRIORITY, job->priority());
69 job->SetPriority(LOWEST);
70 EXPECT_EQ(LOWEST, job->priority());
72 job->SetPriority(LOW);
73 EXPECT_EQ(LOW, job->priority());
75 job->Start();
76 EXPECT_EQ(LOW, job->priority());
78 job->SetPriority(MEDIUM);
79 EXPECT_EQ(MEDIUM, job
[all...]
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...]
H A Durl_request_intercepting_job_factory.cc27 URLRequestJob* job = interceptor_->MaybeInterceptRequest(request, local
29 if (job)
30 return job;
/external/chromium_org/v8/src/
H A Doptimizing-compiler-thread.cc91 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/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...]
H A Dwebsocket_throttle.h36 // Puts |job| in |queue_| and queues for the destination addresses
37 // of |job|.
38 // If other job is using the same destination address, set |job| waiting.
42 bool PutInQueue(WebSocketJob* job);
44 // Removes |job| from |queue_| and queues for the destination addresses
45 // of |job|, and then wakes up jobs that can now resume establishing a
47 void RemoveFromQueue(WebSocketJob* job);
59 // (job->address_list()) of a job, th
[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/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/chrome/browser/printing/
H A Dprint_job_unittest.cc103 scoped_refptr<printing::PrintJob> job(new TestPrintJob(&check));
104 EXPECT_EQ(base::MessageLoop::current(), job->message_loop());
107 job->Initialize(owner.get(), &source, 1);
108 job->Stop();
109 while (job->document()) {
112 EXPECT_FALSE(job->document());
113 job = NULL;
123 scoped_refptr<printing::PrintJob> job(new TestPrintJob(&check));
124 job = NULL;
127 job
[all...]
H A Dprint_job_manager.cc30 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/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.

Completed in 699 milliseconds

12345678