| /external/chromium/net/url_request/ |
| url_request_job_tracker.cc | 26 void URLRequestJobTracker::AddNewJob(URLRequestJob* job) {
27 active_jobs_.push_back(job);
28 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobAdded(job));
31 void URLRequestJobTracker::RemoveJob(URLRequestJob* job) {
33 job);
35 NOTREACHED() << "Removing a non-active job";
40 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobRemoved(job));
43 void URLRequestJobTracker::OnJobDone(URLRequestJob* job,
45 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobDone(job, status));
48 void URLRequestJobTracker::OnJobRedirect(URLRequestJob* job,
[all...] |
| url_request_job_tracker.h | 37 // Called after the given job has been added to the list
38 virtual void OnJobAdded(URLRequestJob* job) = 0;
40 // Called after the given job has been removed from the list
41 virtual void OnJobRemoved(URLRequestJob* job) = 0;
43 // Called when the given job has completed, before notifying the request
44 virtual void OnJobDone(URLRequestJob* job,
47 // Called when the given job is about to follow a redirect to the given
49 virtual void OnJobRedirect(URLRequestJob* job, const GURL& location,
53 // the given job. |byte_count| is the number of bytes for that
57 virtual void OnBytesRead(URLRequestJob* job, const char* buf
[all...] |
| url_request_job_manager.cc | 72 URLRequestJob* job = (*i)->MaybeIntercept(request); local
73 if (job)
74 return job;
83 URLRequestJob* job = i->second(request, scheme); local
84 if (job)
85 return job;
91 URLRequestJob* job = (kBuiltinFactories[i].factory)(request, scheme); local
92 DCHECK(job); // The built-in factories are not expected to fail!
93 return job;
118 URLRequestJob* job = (*i)->MaybeInterceptRedirect(request, location) local
138 URLRequestJob* job = (*i)->MaybeInterceptResponse(request); local
[all...] |
| /external/chromium/net/http/ |
| http_stream_factory_impl_request.cc | 40 for (std::set<Job*>::iterator it = jobs_.begin(); it != jobs_.end(); ++it)
58 void HttpStreamFactoryImpl::Request::AttachJob(Job* job) {
59 DCHECK(job);
60 jobs_.insert(job);
61 factory_->request_map_[job] = this;
79 Job* job,
86 // |job| should only be NULL if we're being serviced by a late bound
87 // SpdySession (one that was not created by a job in our |jobs_| set)
[all...] |
| http_stream_factory_impl_request.h | 27 // Called when the Job determines the appropriate |spdy_session_key| for the
33 // Attaches |job| to this request. Does not mean that Request will use |job|,
34 // but Request will own |job|.
35 void AttachJob(HttpStreamFactoryImpl::Job* job);
38 // |source| is the NetLog::Source generated by the Job that fulfilled this
48 // Called by an attached Job if it sets up a SpdySession.
49 void OnSpdySessionReady(Job* job,
[all...] |
| http_stream_factory_impl.cc | 41 std::set<const Job*> tmp_job_set;
62 Job* alternate_job = NULL;
67 new Job(this, session_, alternate_request_info, ssl_config, net_log);
72 Job* job = new Job(this, session_, request_info, ssl_config, net_log); local
73 request->AttachJob(job);
75 job->WaitFor(alternate_job);
77 // |alternate_job|, otherwise |alternate_job| will not notify |job|
83 // so starting |job| is always safe
96 Job* job = NULL; local
[all...] |
| http_stream_factory_impl.h | 43 class Job;
51 // Detaches |job| from |request|.
52 void OrphanJob(Job* job, const Request* request);
65 // Called when the Job detects that the endpoint indicated by the
68 void OnBrokenAlternateProtocol(const Job*, const HostPortPair& origin);
70 // Invoked when an orphaned Job finishes.
71 void OnOrphanedJobComplete(const Job* job);
73 // Invoked when the Job finishes preconnecting sockets
[all...] |
| /system/core/sh/ |
| jobs.h | 50 #define SHOW_ISSIG 0x20 /* job was signalled */
51 #define SHOW_NO_FREE 0x40 /* do not free job */
55 * A job structure contains information about a job. A job is either a
68 struct job { struct
72 pid_t pgrp; /* process group of this job */
80 char jobctl; /* job running under job control */
81 int prev_job; /* previous job index *
[all...] |
| eval.h | 47 struct job *jp; /* job structure for command */
|
| jobs.c | 89 static struct job *jobtab; /* array of jobs */
95 static int curjob = -1; /* current job */
99 STATIC void restartjob(struct job *);
100 STATIC void freejob(struct job *);
101 STATIC struct job *getjob(const char *, int);
102 STATIC int dowait(int, struct job *);
104 STATIC int waitproc(int, struct job *, int *);
131 * Turn job control on and off.
135 * System V doesn't have job control yet, this isn't a problem now.
184 out2str("sh: Need FIOCLEX or FD_CLOEXEC to support job control")
604 struct job *job; local
[all...] |
| /external/chromium/net/socket_stream/ |
| socket_stream_job_manager.cc | 27 SocketStreamJob* job = new SocketStreamJob(); local
28 job->InitSocketStream(new SocketStream(url, delegate));
29 return job;
37 SocketStreamJob* job = found->second(url, delegate); local
38 if (job)
39 return job;
41 SocketStreamJob* job = new SocketStreamJob(); local
42 job->InitSocketStream(new SocketStream(url, delegate));
43 return job;
|
| /external/webkit/Source/WebCore/platform/network/curl/ |
| ResourceHandleManager.cpp | 158 static void handleLocalReceiveResponse (CURL* handle, ResourceHandle* job, ResourceHandleInternal* d)
170 d->client()->didReceiveResponse(job, d->m_response);
178 ResourceHandle* job = static_cast<ResourceHandle*>(data); local
179 ResourceHandleInternal* d = job->getInternal();
200 handleLocalReceiveResponse(h, job, d);
206 d->client()->didReceiveData(job, static_cast<char*>(ptr), totalSize, 0);
221 ResourceHandle* job = static_cast<ResourceHandle*>(data); local
222 ResourceHandleInternal* d = job->getInternal();
267 KURL newURL = KURL(job->firstRequest().url(), location);
269 ResourceRequest redirectedRequest = job->firstRequest()
299 ResourceHandle* job = static_cast<ResourceHandle*>(data); local
373 ResourceHandle* job = 0; local
567 ResourceHandle* job = m_resourceHandleList[0]; local
[all...] |
| /external/chromium/chrome/browser/policy/ |
| device_management_service.cc | 131 for (JobFetcherMap::iterator job(pending_jobs_.begin());
132 job != pending_jobs_.end();
133 ++job) {
134 delete job->first;
135 queued_jobs_.push_back(job->second);
145 void DeviceManagementService::AddJob(DeviceManagementJob* job) {
147 StartJob(job);
149 queued_jobs_.push_back(job);
152 void DeviceManagementService::RemoveJob(DeviceManagementJob* job) {
156 if (entry->second == job) {
190 DeviceManagementJob* job = entry->second; local
[all...] |
| device_management_service.h | 34 // Describes a device management job handled by the service.
68 // Adds a job. Caller must make sure the job pointer stays valid until the job
70 void AddJob(DeviceManagementJob* job);
72 // Removes a job. The job will be removed and won't receive a completion
74 void RemoveJob(DeviceManagementJob* job);
80 // Starts the given job.
81 void StartJob(DeviceManagementJob* job);
[all...] |
| /external/chromium/net/websockets/ |
| websocket_throttle.h | 34 // Puts |job| in |queue_| and queues for the destination addresses
35 // of |job|.
36 // If other job is using the same destination address, set |job| waiting.
37 void PutInQueue(WebSocketJob* job);
39 // Removes |job| from |queue_| and queues for the destination addresses
40 // of |job|.
41 void RemoveFromQueue(WebSocketJob* job);
|
| websocket_throttle.cc | 62 void WebSocketThrottle::PutInQueue(WebSocketJob* job) {
63 queue_.push_back(job);
64 const AddressList& address_list = job->address_list();
79 queue->push_back(job);
82 iter->second->push_back(job);
83 job->SetWaiting();
89 void WebSocketThrottle::RemoveFromQueue(WebSocketJob* job) {
94 if (*iter == job) {
102 const AddressList& address_list = job->address_list();
117 // Job may not be front of queue when job is closed early while waiting
137 WebSocketJob* job = *iter; local
[all...] |
| /external/chromium/chrome/browser/printing/ |
| print_job_unittest.cc | 100 scoped_refptr<printing::PrintJob> job(new TestPrintJob(&check));
101 EXPECT_EQ(MessageLoop::current(), job->message_loop());
104 job->Initialize(owner, &source, 1);
105 job->Stop();
106 job = NULL;
113 scoped_refptr<printing::PrintJob> job(new TestPrintJob(&check));
114 job = NULL;
117 job->Initialize()
118 job->Observe();
119 job->GetSettingsDone()
[all...] |
| print_job_manager.cc | 47 // Wait for each job to finish.
49 PrintJob* job = current_jobs[i]; local
50 if (!job)
52 // Wait for 120 seconds for the print job to be spooled.
54 job->FlushJob(120000);
55 job->Stop();
61 void PrintJobManager::QueuePrinterQuery(PrinterQuery* job) {
63 DCHECK(job);
64 queued_queries_.push_back(make_scoped_refptr(job));
65 DCHECK(job->is_valid())
[all...] |
| print_job_manager.h | 29 // On browser quit, we should wait to have the print job finished.
39 void QueuePrinterQuery(PrinterQuery* job);
43 void PopPrinterQuery(int document_cookie, scoped_refptr<PrinterQuery>* job);
|
| /external/chromium/chrome/browser/ui/webui/ |
| chrome_url_data_manager_backend.h | 57 // Called by the job when it's starting up.
59 bool StartRequest(const GURL& url, URLRequestChromeJob* job);
62 void RemoveRequest(URLRequestChromeJob* job);
64 // Returns true if the job exists in |pending_requests_|. False otherwise.
67 bool HasPendingJob(URLRequestChromeJob* job) const;
|
| /external/chromium/chrome/browser/automation/ |
| automation_resource_message_filter.cc | 161 URLRequestAutomationJob* job = it->second; local
162 DCHECK(job);
163 if (job) {
164 job->OnMessage(message);
205 URLRequestAutomationJob* job) {
206 if (!job) {
213 if (job->is_pending()) {
214 DCHECK(!ContainsKey(pending_request_map_, job->id()));
215 DCHECK(!ContainsKey(request_map_, job->id()));
216 pending_request_map_[job->id()] = job
390 URLRequestAutomationJob* job = it->second; local
553 scoped_refptr<URLRequestAutomationJob> job = (*index).second; local
[all...] |
| /external/chromium/chrome/browser/sync/engine/ |
| syncer_thread.cc | 170 const SyncSessionJob& job) {
173 DCHECK_NE(job.purpose, SyncSessionJob::CLEAR_USER_DATA);
177 << wait_interval_->had_nudge << "is canary job : "
178 << job.is_canary_job;
180 if (job.purpose == SyncSessionJob::POLL)
183 DCHECK(job.purpose == SyncSessionJob::NUDGE ||
184 job.purpose == SyncSessionJob::CONFIGURATION);
189 if (job.purpose == SyncSessionJob::NUDGE) {
197 // This is a config job.
198 return job.is_canary_job ? CONTINUE : SAVE
[all...] |
| /external/chromium/net/proxy/ |
| multi_threaded_proxy_resolver.cc | 36 // An "executor" is a job-runner for PAC requests. It encapsulates a worker
51 // Submit a job to this executor.
52 void StartJob(Job* job);
54 // Callback for when a job has completed running on the executor's thread.
55 void OnJobCompleted(Job* job);
63 // Returns the outstanding job, or NULL.
64 Job* outstanding_job() const { return outstanding_job_.get(); }
77 // The currently active job for this executor (either a SetPacScript o
443 Job* job = reinterpret_cast<Job*>(req); local
512 Job* job = executor->outstanding_job(); local
[all...] |
| /packages/apps/Gallery2/src/com/android/gallery3d/util/ |
| JobLimiter.java | 20 import com.android.gallery3d.util.ThreadPool.Job;
41 private static class JobWrapper<T> implements Future<T>, Job<T> {
43 private Job<T> mJob;
48 public JobWrapper(Job<T> job, FutureListener<T> listener) {
49 mJob = job;
105 Job<T> job = null; local
108 job = mJob;
112 result = job.run(jc)
[all...] |
| /external/chromium/net/base/ |
| host_resolver_impl.h | 23 // HostResolverImpl::Job. This job gets dispatched to a thread in the global
25 // host are made while the job is already outstanding, then they are attached
26 // to the existing job rather than creating a new one. This avoids doing
34 // Job Job Job
41 // When a HostResolverImpl::Job finishes its work in the threadpool, the
56 // The index into |job_pools_| for the various job pools. Pools with a higher
132 class Job;
[all...] |
