/external/chromium/net/url_request/ |
url_request_job_tracker.cc | 24 void URLRequestJobTracker::AddNewJob(URLRequestJob* job) { 25 active_jobs_.push_back(job); 26 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobAdded(job)); 29 void URLRequestJobTracker::RemoveJob(URLRequestJob* job) { 31 job); 33 NOTREACHED() << "Removing a non-active job"; 38 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobRemoved(job)); 41 void URLRequestJobTracker::OnJobDone(URLRequestJob* job, 43 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobDone(job, status)); 46 void URLRequestJobTracker::OnJobRedirect(URLRequestJob* job, [all...] |
url_request_job_tracker.h | 31 // Called after the given job has been added to the list 32 virtual void OnJobAdded(URLRequestJob* job) = 0; 34 // Called after the given job has been removed from the list 35 virtual void OnJobRemoved(URLRequestJob* job) = 0; 37 // Called when the given job has completed, before notifying the request 38 virtual void OnJobDone(URLRequestJob* job, 41 // Called when the given job is about to follow a redirect to the given 43 virtual void OnJobRedirect(URLRequestJob* job, const GURL& location, 46 // Called when a new chunk of bytes has been read for the given job. The 48 virtual void OnBytesRead(URLRequestJob* job, int byte_count) = 0 [all...] |
url_request_job_manager.cc | 68 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 = (*i)->MaybeInterceptRedirect(request, location) local 134 URLRequestJob* job = (*i)->MaybeInterceptResponse(request); local [all...] |
url_request_filter.cc | 113 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;
|
url_request.cc | 150 // 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) { 261 job_ = job; 280 // Should only be called if the original job didn't make any progress. 285 void URLRequest::RestartWithJob(URLRequestJob *job) { 286 DCHECK(job->request() == this); 288 StartJob(job); 319 // There's nothing to do if we are not waiting on a Job. 325 // The Job will call our NotifyDone method asynchronously. This is done s 351 URLRequestJob* job = GetJobManager()->MaybeInterceptRedirect(this, location); local 365 URLRequestJob* job = GetJobManager()->MaybeInterceptResponse(this); local [all...] |
url_request.h | 70 // 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 will b 512 URLRequestJob* job() { return job_; } function in class:URLRequest [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,
|
giotypes.h | 161 * @job: a #GIOSchedulerJob. 165 * I/O Job function. 175 * complete the job, %FALSE if the job is complete (or cancelled) 177 typedef gboolean (*GIOSchedulerJobFunc) (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 */
|
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/webkit/WebCore/platform/network/curl/ |
ResourceHandleManager.cpp | 155 static void handleLocalReceiveResponse (CURL* handle, ResourceHandle* job, ResourceHandleInternal* d) 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->request() 296 ResourceHandle* job = static_cast<ResourceHandle*>(data); local 370 ResourceHandle* job = 0; local 564 ResourceHandle* job = m_resourceHandleList[0]; local [all...] |
/external/chromium/net/proxy/ |
single_threaded_proxy_resolver.cc | 101 // SingleThreadedProxyResolver::Job ------------------------------------------- 103 class SingleThreadedProxyResolver::Job 104 : public base::RefCountedThreadSafe<SingleThreadedProxyResolver::Job> { 106 // |coordinator| -- the SingleThreadedProxyResolver that owns this job. 109 Job(SingleThreadedProxyResolver* coordinator, 131 FROM_HERE, NewRunnableMethod(this, &Job::DoQuery, 150 friend class base::RefCountedThreadSafe<SingleThreadedProxyResolver::Job>; 152 ~Job() {} 167 NewRunnableMethod(this, &Job::QueryComplete, rv, worker_log)); 180 // The Job may have been cancelled after it was started 237 scoped_refptr<Job> job = new Job(this, url, results, callback, load_log); local 256 Job* job = reinterpret_cast<Job*>(req); local [all...] |
/external/webkit/WebKitTools/Scripts/ |
parallelcl | 93 # Magic determination of job size 95 # won't suffer too much if one job finishes much more quickly than another. 97 # the minimum job size to 5. 123 my $job = makeJob(@sources, $jobSize); 124 ($pid, $tmpFile) = forkAndCompileFiles(@{$job}, $options); 146 my @job; 148 @job = splice(@{$files}, -$jobSize); 150 # Compile all the remaining files in this job to avoid having a small job later 151 @job = splice(@{$files}) [all...] |
/external/chromium/net/base/ |
host_resolver_impl.cc | 100 void set_job(Job* job) { 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. 142 Job* job_; 185 class HostResolverImpl::Job 636 scoped_refptr<Job> job; local 955 scoped_refptr<Job> job = new Job(next_job_id_++, this, key, requests_trace_); local [all...] |
host_resolver_impl.h | 20 // HostResolverImpl::Job. This job gets dispatched to a thread in the global 22 // host are made while the job is already outstanding, then they are attached 23 // to the existing job rather than creating a new one. This avoids doing 31 // Job Job Job 38 // When a HostResolverImpl::Job finishes its work in the threadpool, the 52 // The index into |job_pools_| for the various job pools. Pools with a higher 130 class Job; [all...] |
/prebuilt/linux-x86/toolchain/i686-linux-glibc2.7-4.4.3/i686-linux/include/c++/4.4.3/parallel/ |
workstealing.h | 52 /** @brief One job for a certain thread. */ 54 struct Job 77 * Uses O(1) additional memory. Synchronization at job lists is 120 const int stride = __s.cache_line_size * 10 / sizeof(Job<difference_type>) + 1; 125 Job<difference_type> *job; local 145 // Create job description array. 146 job = new Job<difference_type>[num_threads * stride]; 157 // This job [all...] |
/external/chromium/net/socket/ |
client_socket_pool_base.cc | 229 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, 516 DCHECK(job); [all...] |
client_socket_pool_base.h | 60 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) { 500 return helper_->OnConnectJobComplete(result, job);
|
client_socket_pool_base_unittest.cc | 90 void WaitForSignal(TestConnectJob* job) { waiting_jobs_.push_back(job); } 355 virtual void OnConnectJobComplete(int result, ConnectJob* job) { 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 will be cancelled and should not call back int [all...] |
/external/bluetooth/glib/glib/ |
gmem.c | 317 profiler_log (ProfilerJob job, 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/win/ |
ResourceHandleWin.cpp | 65 static int addToOutstandingJobs(ResourceHandle* job) 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",
|
/packages/apps/Gallery3D/src/com/cooliris/media/ |
Util.java | 215 public BackgroundJob(MonitoredActivity activity, Runnable job, ProgressDialog dialog, Handler handler) { 218 mJob = job; 250 public static void startBackgroundJob(MonitoredActivity activity, String title, String message, Runnable job, Handler handler) { 254 new Thread(new BackgroundJob(activity, job, dialog, handler)).start();
|
/packages/apps/Gallery/src/com/android/camera/ |
Util.java | 377 public BackgroundJob(MonitoredActivity activity, Runnable job, 381 mJob = job; 415 String title, String message, Runnable job, Handler handler) { 420 new Thread(new BackgroundJob(activity, job, dialog, handler)).start();
|