| /external/chromium/net/http/ |
| D | http_stream_factory_impl_request.cc | 58 void HttpStreamFactoryImpl::Request::AttachJob(Job* job) { in AttachJob() argument
59 DCHECK(job); in AttachJob()
60 jobs_.insert(job); in AttachJob()
61 factory_->request_map_[job] = this; in AttachJob()
79 Job* job, in OnStreamReady() argument
88 if (!job) { in OnStreamReady()
102 OrphanJobsExcept(job); in OnStreamReady()
110 Job* job, in OnStreamFailed() argument
118 jobs_.erase(job); in OnStreamFailed()
119 factory_->request_map_.erase(job); in OnStreamFailed()
[all …]
|
| D | http_stream_factory_impl.cc | 72 Job* job = new Job(this, session_, request_info, ssl_config, net_log); in RequestStream() local
73 request->AttachJob(job); in RequestStream()
75 job->WaitFor(alternate_job); in RequestStream()
84 job->Start(request); in RequestStream()
96 Job* job = NULL; in PreconnectStreams() local
100 job = new Job(this, session_, alternate_request_info, ssl_config, net_log); in PreconnectStreams()
101 job->MarkAsAlternate(request_info.url); in PreconnectStreams()
103 job = new Job(this, session_, request_info, ssl_config, net_log); in PreconnectStreams()
105 preconnect_job_set_.insert(job); in PreconnectStreams()
106 job->Preconnect(num_streams); in PreconnectStreams()
[all …]
|
| D | http_stream_factory_impl_request.h | 35 void AttachJob(HttpStreamFactoryImpl::Job* job);
49 void OnSpdySessionReady(Job* job,
56 void OnStreamReady(Job* job,
60 void OnStreamFailed(Job* job, int status, const SSLConfig& used_ssl_config);
61 void OnCertificateError(Job* job,
65 void OnNeedsProxyAuth(Job* job,
70 void OnNeedsClientAuth(Job* job,
74 Job *job,
91 void OrphanJobsExcept(Job* job);
|
| /external/webkit/Source/WebCore/platform/network/curl/ |
| D | ResourceHandleManager.cpp | 158 static void handleLocalReceiveResponse (CURL* handle, ResourceHandle* job, ResourceHandleInternal* … in handleLocalReceiveResponse() argument
170 d->client()->didReceiveResponse(job, d->m_response); in handleLocalReceiveResponse()
178 ResourceHandle* job = static_cast<ResourceHandle*>(data); in writeCallback() local
179 ResourceHandleInternal* d = job->getInternal(); in writeCallback()
200 handleLocalReceiveResponse(h, job, d); in writeCallback()
206 d->client()->didReceiveData(job, static_cast<char*>(ptr), totalSize, 0); in writeCallback()
221 ResourceHandle* job = static_cast<ResourceHandle*>(data); in headerCallback() local
222 ResourceHandleInternal* d = job->getInternal(); in headerCallback()
267 KURL newURL = KURL(job->firstRequest().url(), location); in headerCallback()
269 ResourceRequest redirectedRequest = job->firstRequest(); in headerCallback()
[all …]
|
| /external/chromium/net/url_request/ |
| D | url_request_job_tracker.cc | 26 void URLRequestJobTracker::AddNewJob(URLRequestJob* job) { in AddNewJob() argument
27 active_jobs_.push_back(job); in AddNewJob()
28 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobAdded(job)); in AddNewJob()
31 void URLRequestJobTracker::RemoveJob(URLRequestJob* job) { in RemoveJob() argument
33 job); in RemoveJob()
40 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobRemoved(job)); in RemoveJob()
43 void URLRequestJobTracker::OnJobDone(URLRequestJob* job, in OnJobDone() argument
45 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobDone(job, status)); in OnJobDone()
48 void URLRequestJobTracker::OnJobRedirect(URLRequestJob* job, in OnJobRedirect() argument
52 OnJobRedirect(job, location, status_code)); in OnJobRedirect()
[all …]
|
| D | url_request_job_tracker.h | 38 virtual void OnJobAdded(URLRequestJob* job) = 0;
41 virtual void OnJobRemoved(URLRequestJob* job) = 0;
44 virtual void OnJobDone(URLRequestJob* job,
49 virtual void OnJobRedirect(URLRequestJob* job, const GURL& location,
57 virtual void OnBytesRead(URLRequestJob* job, const char* buf,
76 void AddNewJob(URLRequestJob* job);
77 void RemoveJob(URLRequestJob* job);
80 void OnJobDone(URLRequestJob* job, const URLRequestStatus& status);
81 void OnJobRedirect(URLRequestJob* job, const GURL& location,
85 void OnBytesRead(URLRequestJob* job, const char* buf, int byte_count);
|
| D | url_request_job_manager.cc | 72 URLRequestJob* job = (*i)->MaybeIntercept(request); in CreateJob() local
73 if (job) in CreateJob()
74 return job; in CreateJob()
83 URLRequestJob* job = i->second(request, scheme); in CreateJob() local
84 if (job) in CreateJob()
85 return job; in CreateJob()
91 URLRequestJob* job = (kBuiltinFactories[i].factory)(request, scheme); in CreateJob() local
92 DCHECK(job); // The built-in factories are not expected to fail! in CreateJob()
93 return job; in CreateJob()
118 URLRequestJob* job = (*i)->MaybeInterceptRedirect(request, location); in MaybeInterceptRedirect() local
[all …]
|
| D | url_request_filter.cc | 122 URLRequestJob* job = NULL; in FindRequestHandler() local
130 job = i->second(request, scheme); in FindRequestHandler()
132 if (!job) { in FindRequestHandler()
137 job = i->second(request, scheme); in FindRequestHandler()
140 if (job) { in FindRequestHandler()
144 return job; in FindRequestHandler()
|
| /external/chromium/chrome/browser/sync/engine/ |
| D | syncer_thread.cc | 170 const SyncSessionJob& job) { in DecideWhileInWaitInterval() argument
173 DCHECK_NE(job.purpose, SyncSessionJob::CLEAR_USER_DATA); in DecideWhileInWaitInterval()
178 << job.is_canary_job; in DecideWhileInWaitInterval()
180 if (job.purpose == SyncSessionJob::POLL) in DecideWhileInWaitInterval()
183 DCHECK(job.purpose == SyncSessionJob::NUDGE || in DecideWhileInWaitInterval()
184 job.purpose == SyncSessionJob::CONFIGURATION); in DecideWhileInWaitInterval()
189 if (job.purpose == SyncSessionJob::NUDGE) { in DecideWhileInWaitInterval()
198 return job.is_canary_job ? CONTINUE : SAVE; in DecideWhileInWaitInterval()
202 const SyncSessionJob& job) { in DecideOnJob() argument
203 if (job.purpose == SyncSessionJob::CLEAR_USER_DATA) in DecideOnJob()
[all …]
|
| D | syncer_thread2_whitebox_unittest.cc | 68 const SyncerThread::SyncSessionJob& job) { in DecideOnJob() argument
69 return syncer_thread_->DecideOnJob(job); in DecideOnJob()
81 struct SyncerThread::SyncSessionJob job; in CreateAndDecideJob() local
82 job.purpose = purpose; in CreateAndDecideJob()
83 job.scheduled_start = TimeTicks::Now(); in CreateAndDecideJob()
84 return DecideOnJob(job); in CreateAndDecideJob()
218 struct SyncerThread::SyncSessionJob job; in TEST_F() local
219 job.purpose = SyncerThread::SyncSessionJob::CONFIGURATION; in TEST_F()
220 job.scheduled_start = TimeTicks::Now(); in TEST_F()
221 job.is_canary_job = true; in TEST_F()
[all …]
|
| D | syncer_thread.h | 208 void DoSyncSessionJob(const SyncSessionJob& job);
212 void FinishSyncSessionJob(const SyncSessionJob& job);
230 bool ShouldRunJob(const SyncSessionJob& job);
233 JobProcessDecision DecideOnJob(const SyncSessionJob& job);
237 JobProcessDecision DecideWhileInWaitInterval(const SyncSessionJob& job);
240 void SaveJob(const SyncSessionJob& job);
243 void InitOrCoalescePendingJob(const SyncSessionJob& job);
|
| /external/chromium/chrome/browser/policy/ |
| D | device_management_service.cc | 131 for (JobFetcherMap::iterator job(pending_jobs_.begin()); in Shutdown() local
132 job != pending_jobs_.end(); in Shutdown()
133 ++job) { in Shutdown()
134 delete job->first; in Shutdown()
135 queued_jobs_.push_back(job->second); in Shutdown()
145 void DeviceManagementService::AddJob(DeviceManagementJob* job) { in AddJob() argument
147 StartJob(job); in AddJob()
149 queued_jobs_.push_back(job); in AddJob()
152 void DeviceManagementService::RemoveJob(DeviceManagementJob* job) { in RemoveJob() argument
156 if (entry->second == job) { in RemoveJob()
[all …]
|
| D | device_management_backend_impl.cc | 384 for (JobSet::iterator job(pending_jobs_.begin()); in ~DeviceManagementBackendImpl() local
385 job != pending_jobs_.end(); in ~DeviceManagementBackendImpl()
386 ++job) { in ~DeviceManagementBackendImpl()
387 service_->RemoveJob(*job); in ~DeviceManagementBackendImpl()
388 delete *job; in ~DeviceManagementBackendImpl()
448 void DeviceManagementBackendImpl::JobDone(DeviceManagementJobBase* job) { in JobDone() argument
449 pending_jobs_.erase(job); in JobDone()
452 void DeviceManagementBackendImpl::AddJob(DeviceManagementJobBase* job) { in AddJob() argument
453 pending_jobs_.insert(job); in AddJob()
454 service_->AddJob(job); in AddJob()
|
| /external/chromium/net/websockets/ |
| D | websocket_throttle.cc | 62 void WebSocketThrottle::PutInQueue(WebSocketJob* job) { in PutInQueue() argument
63 queue_.push_back(job); in PutInQueue()
64 const AddressList& address_list = job->address_list(); in PutInQueue()
79 queue->push_back(job); in PutInQueue()
82 iter->second->push_back(job); in PutInQueue()
83 job->SetWaiting(); in PutInQueue()
89 void WebSocketThrottle::RemoveFromQueue(WebSocketJob* job) { in RemoveFromQueue() argument
94 if (*iter == job) { in RemoveFromQueue()
102 const AddressList& address_list = job->address_list(); in RemoveFromQueue()
121 if (*iter == job) { in RemoveFromQueue()
[all …]
|
| /external/chromium/net/proxy/ |
| D | multi_threaded_proxy_resolver.cc | 52 void StartJob(Job* job);
55 void OnJobCompleted(Job* job);
313 void MultiThreadedProxyResolver::Executor::StartJob(Job* job) { in StartJob() argument
315 outstanding_job_ = job; in StartJob()
319 job->set_executor(this); in StartJob()
320 job->FinishedWaitingForThread(); in StartJob()
323 NewRunnableMethod(job, &Job::Run, MessageLoop::current())); in StartJob()
326 void MultiThreadedProxyResolver::Executor::OnJobCompleted(Job* job) { in OnJobCompleted() argument
327 DCHECK_EQ(job, outstanding_job_.get()); in OnJobCompleted()
407 scoped_refptr<GetProxyForURLJob> job( in GetProxyForURL() local
[all …]
|
| /external/chromium/net/socket_stream/ |
| D | socket_stream_job_manager.cc | 27 SocketStreamJob* job = new SocketStreamJob(); in CreateJob() local
28 job->InitSocketStream(new SocketStream(url, delegate)); in CreateJob()
29 return job; in CreateJob()
37 SocketStreamJob* job = found->second(url, delegate); in CreateJob() local
38 if (job) in CreateJob()
39 return job; in CreateJob()
41 SocketStreamJob* job = new SocketStreamJob(); in CreateJob() local
42 job->InitSocketStream(new SocketStream(url, delegate)); in CreateJob()
43 return job; in CreateJob()
|
| /external/chromium/chrome/browser/automation/ |
| D | automation_resource_message_filter.cc | 161 URLRequestAutomationJob* job = it->second; in OnMessageReceived() local
162 DCHECK(job); in OnMessageReceived()
163 if (job) { in OnMessageReceived()
164 job->OnMessage(message); in OnMessageReceived()
205 URLRequestAutomationJob* job) { in RegisterRequest() argument
206 if (!job) { in RegisterRequest()
213 if (job->is_pending()) { in RegisterRequest()
214 DCHECK(!ContainsKey(pending_request_map_, job->id())); in RegisterRequest()
215 DCHECK(!ContainsKey(request_map_, job->id())); in RegisterRequest()
216 pending_request_map_[job->id()] = job; in RegisterRequest()
[all …]
|
| /external/chromium/chrome/browser/printing/ |
| D | print_job_manager.cc | 49 PrintJob* job = current_jobs[i]; in StopJobs() local
50 if (!job) in StopJobs()
54 job->FlushJob(120000); in StopJobs()
55 job->Stop(); in StopJobs()
61 void PrintJobManager::QueuePrinterQuery(PrinterQuery* job) { in QueuePrinterQuery() argument
63 DCHECK(job); in QueuePrinterQuery()
64 queued_queries_.push_back(make_scoped_refptr(job)); in QueuePrinterQuery()
65 DCHECK(job->is_valid()); in QueuePrinterQuery()
69 scoped_refptr<PrinterQuery>* job) { in PopPrinterQuery() argument
77 *job = current_query; in PopPrinterQuery()
|
| D | print_job_unittest.cc | 100 scoped_refptr<printing::PrintJob> job(new TestPrintJob(&check)); in TEST() local
101 EXPECT_EQ(MessageLoop::current(), job->message_loop()); in TEST()
104 job->Initialize(owner, &source, 1); in TEST()
105 job->Stop(); in TEST()
106 job = NULL; in TEST()
113 scoped_refptr<printing::PrintJob> job(new TestPrintJob(&check)); in TEST() local
114 job = NULL; in TEST()
|
| /external/chromium/net/base/ |
| D | host_resolver_impl.cc | 277 void set_job(Job* job) { in set_job() argument
278 DCHECK(job != NULL); in set_job()
280 job_ = job; in set_job()
295 Job* job() const { in job() function in net::HostResolverImpl::Request
865 void MoveRequestsToJob(Job* job) { in MoveRequestsToJob() argument
871 if (job->CanServiceRequest(req->info())) { in MoveRequestsToJob()
873 job->AddRequest(req); in MoveRequestsToJob()
1078 scoped_refptr<Job> job; in Resolve() local
1082 job = FindOutstandingJob(key); in Resolve()
1083 if (job) { in Resolve()
[all …]
|
| D | host_resolver_impl.h | 148 void AddOutstandingJob(Job* job);
154 void RemoveOutstandingJob(Job* job);
157 void OnJobComplete(Job* job, int net_error, int os_error,
162 void AbortJob(Job* job);
165 void OnJobCompleteInternal(Job* job, int net_error, int os_error,
|
| D | cert_verifier.cc | 337 CertVerifierJob* job; in Verify() local
344 job = j->second; in Verify()
349 job = new CertVerifierJob(worker); in Verify()
351 delete job; in Verify()
358 inflight_.insert(std::make_pair(key, job)); in Verify()
363 job->AddRequest(request); in Verify()
431 CertVerifierJob* job = j->second; in HandleResult() local
434 job->HandleResult(cached_result); in HandleResult()
435 delete job; in HandleResult()
|
| /external/webkit/Tools/Scripts/ |
| D | parallelcl | 123 my $job = makeJob(@sources, $jobSize);
124 ($pid, $tmpFile) = forkAndCompileFiles(@{$job}, $options);
146 my @job;
148 @job = splice(@{$files}, -$jobSize);
151 @job = splice(@{$files});
154 return \@job;
|
| /external/chromium/chrome/browser/ui/webui/ |
| D | chrome_url_data_manager_backend.cc | 179 URLRequestChromeJob* job) const { in HasPendingJob()
182 if (i->second == job) in HasPendingJob()
189 URLRequestChromeJob* job) { in StartRequest() argument
204 pending_requests_.insert(std::make_pair(request_id, job)); in StartRequest()
209 job->SetMimeType(source->GetMimeType(path)); in StartRequest()
212 job->request()->context()); in StartRequest()
233 void ChromeURLDataManagerBackend::RemoveRequest(URLRequestChromeJob* job) { in RemoveRequest() argument
239 if (i->second == job) { in RemoveRequest()
253 scoped_refptr<URLRequestChromeJob> job(i->second); in DataAvailable() local
255 job->DataAvailable(bytes); in DataAvailable()
|
| /external/chromium/net/socket/ |
| D | client_socket_pool_base.cc | 581 std::set<ConnectJob*>::const_iterator job = group->jobs().begin(); in GetInfoAsValue() local
582 for (job = group->jobs().begin(); job != group->jobs().end(); job++) { in GetInfoAsValue()
583 int source_id = (*job)->net_log().source().id; in GetInfoAsValue()
794 int result, ConnectJob* job) { in OnConnectJobComplete() argument
796 const std::string group_name = job->group_name(); in OnConnectJobComplete()
801 scoped_ptr<ClientSocket> socket(job->ReleaseSocket()); in OnConnectJobComplete()
803 BoundNetLog job_log = job->net_log(); in OnConnectJobComplete()
807 RemoveConnectJob(job, group); in OnConnectJobComplete()
830 job->GetAdditionalErrorState(r->handle()); in OnConnectJobComplete()
831 RemoveConnectJob(job, group); in OnConnectJobComplete()
[all …]
|