| /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...] |
| /external/bluetooth/glib/gio/ |
| gioscheduler.c | 52 GSourceFunc cancel_func; /* Runs under job map lock */
71 g_io_job_free (GIOSchedulerJob *job)
73 if (job->cancellable)
74 g_object_unref (job->cancellable);
75 g_free (job);
125 remove_active_job (GIOSchedulerJob *job)
132 active_jobs = g_slist_delete_link (active_jobs, job->active_link);
158 GIOSchedulerJob *job = data; local
160 if (job->destroy_notify)
161 job->destroy_notify (job->data)
171 GIOSchedulerJob *job = data; local
192 GIOSchedulerJob *job = data; local
232 GIOSchedulerJob *job; local
283 GIOSchedulerJob *job = l->data; local
[all...] |
| gioscheduler.h | 41 gboolean g_io_scheduler_job_send_to_mainloop (GIOSchedulerJob *job,
45 void g_io_scheduler_job_send_to_mainloop_async (GIOSchedulerJob *job,
|
| /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 */
|
| /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...] |
| /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/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...] |
| /sdk/eclipse/plugins/com.android.ide.eclipse.adt/src/com/android/ide/eclipse/adt/internal/lint/ |
| LintRunner.java | 32 import org.eclipse.core.runtime.jobs.Job;
55 CheckFileJob job = (CheckFileJob) startLint(resource, doc); local
57 job.join();
58 return job.isFatal();
67 * Runs lint and updates the markers. Does not wait for the job to
72 * @return the job running lint in the background.
74 public static Job startLint(IResource resource, IDocument doc) {
78 CheckFileJob job = new CheckFileJob(resource, doc); local
79 job.schedule();
80 return job;
[all...] |
