Searched defs:job (Results 1 - 20 of 20) sorted by relevance

/external/chromium/net/url_request/
H A Durl_request_job_tracker.cc24 void URLRequestJobTracker::AddNewJob(URLRequestJob* job) { argument
25 active_jobs_.push_back(job);
26 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobAdded(job));
29 void URLRequestJobTracker::RemoveJob(URLRequestJob* job) { argument
31 job);
33 NOTREACHED() << "Removing a non-active job";
38 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobRemoved(job));
41 void URLRequestJobTracker::OnJobDone(URLRequestJob* job, argument
43 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobDone(job, status));
46 void URLRequestJobTracker::OnJobRedirect(URLRequestJob* job, argument
53 OnBytesRead(URLRequestJob* job, int byte_count) argument
[all...]
H A Durl_request_filter.cc113 URLRequestJob* job = NULL; local
121 job = i->second(request, scheme);
123 if (!job) {
128 job = i->second(request, scheme);
131 if (job) {
135 return job;
H A Durl_request_job_manager.cc68 URLRequestJob* job = (*i)->MaybeIntercept(request); local
69 if (job)
70 return job;
79 URLRequestJob* job = i->second(request, scheme); local
80 if (job)
81 return job;
87 URLRequestJob* job = (kBuiltinFactories[i].factory)(request, scheme); local
88 DCHECK(job); // The built-in factories are not expected to fail!
89 return job;
114 URLRequestJob* job local
134 URLRequestJob* job = (*i)->MaybeInterceptResponse(request); local
[all...]
H A Durl_request.cc150 // The first job completed and none of the subsequent series of
152 // cached results from the initial job, the POST.
255 void URLRequest::StartJob(URLRequestJob* job) { argument
261 job_ = job;
280 // Should only be called if the original job didn't make any progress.
285 void URLRequest::RestartWithJob(URLRequestJob *job) { argument
286 DCHECK(job->request() == this);
288 StartJob(job);
351 URLRequestJob* job = GetJobManager()->MaybeInterceptRedirect(this, location); local
352 if (job) {
365 URLRequestJob* job = GetJobManager()->MaybeInterceptResponse(this); local
[all...]
H A Durl_request.h70 // default job will be used.
80 // Called for every request made. Should return a new job to handle the
87 // job to replace the existing job if it should be intercepted, or NULL
88 // to allow the normal handling to continue. If a new job is provided,
90 // response produced by the intercept job will be returned.
99 // on dns or network errors. Can return a new job to replace the existing
100 // job if it should be intercepted, or NULL to allow the normal handling to
101 // continue. If a new job is provided, the delegate never sees the original
102 // response, instead the response produced by the intercept job wil
512 URLRequestJob* job() { return job_; } function in class:URLRequest
[all...]
H A Durl_request_unittest.cc972 URLRequestFileDirJob* job = static_cast<URLRequestFileDirJob*>(req.job()); local
973 while (!job->list_complete()) {
1936 // intercept the main request and cancel from within the restarted job
1967 // intercept the redirect and cancel from within that job
1997 // setup to intercept final response and cancel from within that job
2018 // intercept the main request and cancel then restart from within that job
/external/bluetooth/glib/gio/
H A Dgioscheduler.c52 GSourceFunc cancel_func; /* Runs under job map lock */
71 g_io_job_free (GIOSchedulerJob *job) argument
73 if (job->cancellable)
74 g_object_unref (job->cancellable);
75 g_free (job);
125 remove_active_job (GIOSchedulerJob *job) argument
132 active_jobs = g_slist_delete_link (active_jobs, job->active_link);
158 GIOSchedulerJob *job = data; local
160 if (job->destroy_notify)
161 job
171 GIOSchedulerJob *job = data; local
192 GIOSchedulerJob *job = data; local
232 GIOSchedulerJob *job; local
283 GIOSchedulerJob *job = l->data; local
355 g_io_scheduler_job_send_to_mainloop(GIOSchedulerJob *job, GSourceFunc func, gpointer user_data, GDestroyNotify notify) argument
422 g_io_scheduler_job_send_to_mainloop_async(GIOSchedulerJob *job, GSourceFunc func, gpointer user_data, GDestroyNotify notify) argument
[all...]
H A Dgsimpleasyncresult.c95 * g_simple_async_result_run_in_thread() will run the job in a separate
556 * Completes an asynchronous I/O job.
640 run_in_thread (GIOSchedulerJob *job, argument
677 * Runs the asynchronous job in a separated thread.
H A Dgfile.c4716 GIOSchedulerJob *job; member in struct:__anon412
4768 g_io_scheduler_job_send_to_mainloop_async (data->job,
4775 copy_async_thread (GIOSchedulerJob *job, argument
4788 data->job = job;
4799 g_io_scheduler_job_send_to_mainloop (job,
/external/chromium/net/proxy/
H A Dsingle_threaded_proxy_resolver.cc106 // |coordinator| -- the SingleThreadedProxyResolver that owns this job.
216 // Cancel the inprogress job (if any), and free the rest.
237 scoped_refptr<Job> job = new Job(this, url, results, callback, load_log); local
238 pending_jobs_.push_back(job);
244 *request = reinterpret_cast<RequestHandle>(job.get());
256 Job* job = reinterpret_cast<Job*>(req); local
258 bool is_active_job = job->is_started() && !pending_jobs_.empty() &&
259 pending_jobs_.front().get() == job;
261 job->Cancel();
264 RemoveFrontOfJobsQueueAndStartNext(job);
[all...]
/external/chromium/net/socket/
H A Dclient_socket_pool_base.cc229 ConnectJob* job = connect_job.release(); local
231 group.jobs.insert(job);
254 // TODO(willchan): Cancel the job in the earliest LoadState.
465 int result, ConnectJob* job) {
467 const std::string group_name = job->group_name();
472 scoped_ptr<ClientSocket> socket(job->ReleaseSocket());
474 scoped_refptr<LoadLog> job_load_log(job->load_log());
475 RemoveConnectJob(job, &group);
511 void ClientSocketPoolBaseHelper::RemoveConnectJob(const ConnectJob *job, argument
516 DCHECK(job);
464 OnConnectJobComplete( int result, ConnectJob* job) argument
[all...]
H A Dclient_socket_pool_base.h60 virtual void OnConnectJobComplete(int result, ConnectJob* job) = 0;
203 virtual void OnConnectJobComplete(int result, ConnectJob* job);
310 // Removes |job| from |connect_job_set_|. Also updates |group| if non-NULL.
311 void RemoveConnectJob(const ConnectJob* job, Group* group);
499 virtual void OnConnectJobComplete(int result, ConnectJob* job) { argument
500 return helper_->OnConnectJobComplete(result, job);
H A Dclient_socket_pool_base_unittest.cc90 void WaitForSignal(TestConnectJob* job) { waiting_jobs_.push_back(job); } argument
355 virtual void OnConnectJobComplete(int result, ConnectJob* job) { argument
357 scoped_ptr<ClientSocket> socket(job->ReleaseSocket());
360 delete job;
456 scoped_ptr<TestConnectJob> job(
464 EXPECT_EQ(OK, job->Connect());
474 TestConnectJob* job = local
482 ASSERT_EQ(ERR_IO_PENDING, job->Connect());
825 // The pending connect job wil
[all...]
/external/emma/core/java12/com/vladium/emma/instr/
H A DInstrProcessorST.java234 // class def modified: write it to an array and submit a write job
262 // clone the array and submit an entry write job
486 // class def modified: write it to an array and submit a write job
499 // clone the array and submit a file write job
577 // in overwrite mode, flush the job queue before going to the next directory:
702 // reset job queue position:
926 private void addJob (final Job job) argument
931 m_jobs [m_jobPos ++] = job;
939 final Job job = m_jobs [j];
940 if (job !
[all...]
/external/webkit/WebCore/platform/network/win/
H A DResourceHandleWin.cpp65 static int addToOutstandingJobs(ResourceHandle* job) argument
70 jobIdMap->set(transferJobId, job);
95 ResourceHandle* job = lookupResourceHandle(jobId); local
96 if (job) {
97 ASSERT(job->d->m_jobId == jobId);
98 ASSERT(job->d->m_threadId == GetCurrentThreadId());
99 (job->*(messageHandlers[index]))(lParam);
282 _snprintf(buf, sizeof(buf), "status-callback: status=%u, job=%p\n",
/external/bluetooth/glib/glib/
H A Dgmem.c317 profiler_log (ProfilerJob job, argument
334 profile_data[n_bytes + PROFILE_TABLE ((job & PROFILER_ALLOC) != 0,
335 (job & PROFILER_RELOC) != 0,
338 profile_data[MEM_PROFILE_TABLE_SIZE + PROFILE_TABLE ((job & PROFILER_ALLOC) != 0,
339 (job & PROFILER_RELOC) != 0,
343 if (job & PROFILER_ALLOC)
346 if (job & PROFILER_ZINIT)
/external/webkit/WebCore/platform/network/curl/
H A DResourceHandleManager.cpp155 static void handleLocalReceiveResponse (CURL* handle, ResourceHandle* job, ResourceHandleInternal* d) argument
167 d->client()->didReceiveResponse(job, d->m_response);
175 ResourceHandle* job = static_cast<ResourceHandle*>(data); local
176 ResourceHandleInternal* d = job->getInternal();
197 handleLocalReceiveResponse(h, job, d);
203 d->client()->didReceiveData(job, static_cast<char*>(ptr), totalSize, 0);
218 ResourceHandle* job = static_cast<ResourceHandle*>(data); local
219 ResourceHandleInternal* d = job->getInternal();
264 KURL newURL = KURL(job->request().url(), location);
266 ResourceRequest redirectedRequest = job
296 ResourceHandle* job = static_cast<ResourceHandle*>(data); local
370 ResourceHandle* job = 0; local
436 removeFromCurl(ResourceHandle* job) argument
457 setupPOST(ResourceHandle* job, struct curl_slist** headers) argument
535 add(ResourceHandle* job) argument
545 removeScheduledJob(ResourceHandle* job) argument
564 ResourceHandle* job = m_resourceHandleList[0]; local
626 dispatchSynchronousJob(ResourceHandle* job) argument
657 startJob(ResourceHandle* job) argument
681 initializeHandle(ResourceHandle* job) argument
793 cancel(ResourceHandle* job) argument
[all...]
/external/chromium/net/base/
H A Dhost_resolver_impl.cc100 void set_job(Job* job) { argument
101 DCHECK(job != NULL);
102 // Identify which job the request is waiting on.
103 job_ = job;
116 Job* job() const { function in class:net::HostResolverImpl::Request
141 // The resolve job (running in worker pool) that this request is dependent on.
198 "Created job j%d for {hostname='%s', address_family=%d}",
204 // Attaches a request to this job. The job takes ownership of |req| and will
209 "Attached request r%d to job
487 MoveRequestsToJob(Job* job) argument
636 scoped_refptr<Job> job; local
772 RemoveOutstandingJob(Job* job) argument
782 OnJobComplete(Job* job, int error, const AddressList& addrlist) argument
955 scoped_refptr<Job> job = new Job(next_job_id_++, this, key, requests_trace_); local
[all...]
/external/bluetooth/glib/gobject/
H A Dgobject.c174 gint job);
2078 gint job)
2080 switch (job)
2077 object_floating_flag_handler(GObject *object, gint job) argument
/external/emma/lib/
H A Demma.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/vladium/ com/vladium/app/ com/vladium/app/IAppVersion ...

Completed in 1009 milliseconds