/external/chromium_org/net/http/ |
H A D | http_stream_factory_impl_request.cc | 65 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 D | http_stream_factory_impl_request.h | 42 // 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 D | http_stream_factory_impl.cc | 130 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 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/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/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/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/content/browser/service_worker/ |
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...] |
H A D | service_worker_job_coordinator.h | 41 // 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 D | service_worker_register_job_base.h | 11 // 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 D | device_management_service_browsertest.cc | 132 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 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_updater.cc | 140 // 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 D | url_request_http_job_unittest.cc | 66 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 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...] |
H A D | url_request_intercepting_job_factory.cc | 27 URLRequestJob* job = interceptor_->MaybeInterceptRequest(request, local 29 if (job) 30 return job;
|
/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/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...] |
H A D | websocket_throttle.h | 36 // 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 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/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/chrome/browser/printing/ |
H A D | print_job_unittest.cc | 103 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 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/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.
|