| /external/chromium/net/http/ |
| 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...] |
| http_stream_factory_impl_job.h | 35 class HttpStreamFactoryImpl::Job {
37 Job(HttpStreamFactoryImpl* stream_factory,
42 ~Job();
45 // notified upon completion if the Job has not been Orphan()'d.
56 // Marks this Job as the "alternate" job, from Alternate-Protocol. Tracks the
61 // Tells |this| to wait for |job| to resume it.
62 void WaitFor(Job* job);
64 // Tells |this| that |job| has determined it still needs to continu
[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...] |
| host_resolver_impl.cc | 180 // Parameters associated with the creation of a HostResolverImpl::Job.
277 void set_job(Job* job) {
278 DCHECK(job != NULL);
279 // Identify which job the request is waiting on.
280 job_ = job;
295 Job* job() const { function in class:net::HostResolverImpl::Request
325 // The resolve job (running in worker pool) that this request is dependent on.
326 Job* job_
1078 scoped_refptr<Job> job; local
[all...] |
| cert_verifier.cc | 337 CertVerifierJob* job; local
344 job = j->second;
349 job = new CertVerifierJob(worker);
351 delete job;
358 inflight_.insert(std::make_pair(key, job));
363 job->AddRequest(request);
431 CertVerifierJob* job = j->second; local
434 job->HandleResult(cached_result);
435 delete job;
|
| /system/core/sh/ |
| 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/chrome/browser/sync/engine/ |
| syncer_thread2_whitebox_unittest.cc | 68 const SyncerThread::SyncSessionJob& job) {
69 return syncer_thread_->DecideOnJob(job);
81 struct SyncerThread::SyncSessionJob job; local
82 job.purpose = purpose;
83 job.scheduled_start = TimeTicks::Now();
84 return DecideOnJob(job);
218 struct SyncerThread::SyncSessionJob job; local
219 job.purpose = SyncerThread::SyncSessionJob::CONFIGURATION;
220 job.scheduled_start = TimeTicks::Now();
221 job.is_canary_job = true
[all...] |
| syncer_thread.h | 101 // Indicates we should continue with the current job.
105 // Indicates we should drop this job.
200 // Helper to assemble a job and post a delayed task to sync.
208 void DoSyncSessionJob(const SyncSessionJob& job);
210 // Called after the Syncer has performed the sync represented by |job|, to
212 void FinishSyncSessionJob(const SyncSessionJob& job);
227 // Determines if it is legal to run |job| by checking current
230 bool ShouldRunJob(const SyncSessionJob& job);
232 // Decide whether we should CONTINUE, SAVE or DROP the job.
233 JobProcessDecision DecideOnJob(const SyncSessionJob& job);
[all...] |
| /external/chromium/net/url_request/ |
| url_request_filter.cc | 122 URLRequestJob* job = NULL; local
130 job = i->second(request, scheme);
132 if (!job) {
137 job = i->second(request, scheme);
140 if (job) {
144 return job;
|
| url_request.cc | 246 // The first job completed and none of the subsequent series of
248 // cached results from the initial job, the POST.
399 void URLRequest::StartJob(URLRequestJob* job) {
408 job_ = job;
426 // Should only be called if the original job didn't make any progress.
431 void URLRequest::RestartWithJob(URLRequestJob *job) {
432 DCHECK(job->request() == this);
434 StartJob(job);
465 // There's nothing to do if we are not waiting on a Job.
471 // The Job will call our NotifyDone method asynchronously. This is done s
502 URLRequestJob* job = local
518 URLRequestJob* job = local
[all...] |
| url_request_job_tracker_unittest.cc | 55 MOCK_METHOD1(OnJobAdded, void(URLRequestJob* job));
56 MOCK_METHOD1(OnJobRemoved, void(URLRequestJob* job));
57 MOCK_METHOD2(OnJobDone, void(URLRequestJob* job,
59 MOCK_METHOD3(OnJobRedirect, void(URLRequestJob* job,
62 MOCK_METHOD3(OnBytesRead, void(URLRequestJob* job,
|
| /external/webkit/Tools/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...] |
| /packages/apps/Gallery2/src/com/android/gallery3d/util/ |
| ThreadPool.java | 40 // A Job is like a Callable, but it has an addition JobContext parameter.
41 public interface Job<T> {
88 // Submit a job to the thread pool. The listener will be called when the
89 // job is finished (or cancelled).
90 public <T> Future<T> submit(Job<T> job, FutureListener<T> listener) {
91 Worker<T> w = new Worker<T>(job, listener);
96 public <T> Future<T> submit(Job<T> job) {
97 return submit(job, null)
[all...] |
| /sdk/eclipse/plugins/com.android.ide.eclipse.hierarchyviewer/src/com/android/ide/eclipse/hierarchyviewer/ |
| HierarchyViewerPluginDirector.java | 29 import org.eclipse.core.runtime.jobs.Job;
43 Job job = new Job(taskName) { local
50 job.setPriority(Job.SHORT);
51 job.setRule(mSchedulingRule);
52 job.schedule();
|
| /external/chromium/chrome/browser/policy/ |
| device_management_backend_impl.h | 51 void JobDone(DeviceManagementJobBase* job);
53 // Add a job to the pending job set and register it with the service (if
55 void AddJob(DeviceManagementJobBase* job);
|
| device_management_backend_impl.cc | 129 // Constructs a device management job running for the given backend.
171 // The backend this job is handling a request for.
384 for (JobSet::iterator job(pending_jobs_.begin());
385 job != pending_jobs_.end();
386 ++job) {
387 service_->RemoveJob(*job);
388 delete *job;
448 void DeviceManagementBackendImpl::JobDone(DeviceManagementJobBase* job) {
449 pending_jobs_.erase(job);
452 void DeviceManagementBackendImpl::AddJob(DeviceManagementJobBase* 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/chrome/browser/ui/webui/ |
| chrome_url_data_manager_backend.cc | 179 URLRequestChromeJob* job) const {
182 if (i->second == job)
189 URLRequestChromeJob* job) {
204 pending_requests_.insert(std::make_pair(request_id, job));
209 job->SetMimeType(source->GetMimeType(path));
212 job->request()->context());
233 void ChromeURLDataManagerBackend::RemoveRequest(URLRequestChromeJob* job) {
239 if (i->second == job) {
251 // We acquire a reference to the job so that it doesn't disappear under the
253 scoped_refptr<URLRequestChromeJob> job(i->second)
[all...] |
| /external/chromium/chrome/browser/printing/ |
| print_view_manager.h | 56 // Terminates or cancels the print job if one was pending.
59 // Cancels the print job.
69 // Requests the RenderView to render all the missing pages for the print job.
70 // Noop if no print job is pending. Returns true if at least one page has been
81 // Creates a new empty print job. It has no settings loaded. If there is
82 // currently a print job, safely disconnect from it. Returns false if it is
83 // impossible to safely disconnect from the current print job or it is
84 // impossible to create a new print job.
85 bool CreateNewPrintJob(PrintJobWorkerOwner* job);
94 // Terminates the print job. Noop if no print job has been created. I
[all...] |
| /external/chromium/net/socket/ |
| client_socket_pool_base.cc | 475 // We let the job run, unless we're at the socket limit.
581 std::set<ConnectJob*>::const_iterator job = group->jobs().begin(); local
582 for (job = group->jobs().begin(); job != group->jobs().end(); job++) {
583 int source_id = (*job)->net_log().source().id;
794 int result, ConnectJob* job) {
796 const std::string group_name = job->group_name();
801 scoped_ptr<ClientSocket> socket(job->ReleaseSocket());
803 BoundNetLog job_log = job->net_log()
1079 ConnectJob* job = *it; local
[all...] |
| /external/chromium/chrome/browser/task_manager/ |
| task_manager.h | 296 virtual void OnJobAdded(net::URLRequestJob* job);
297 virtual void OnJobRemoved(net::URLRequestJob* job);
298 virtual void OnJobDone(net::URLRequestJob* job,
300 virtual void OnJobRedirect(net::URLRequestJob* job,
303 virtual void OnBytesRead(net::URLRequestJob* job,
|
| /external/chromium/chrome/browser/net/ |
| url_request_slow_download_job.cc | 51 URLRequestSlowDownloadJob* job = new URLRequestSlowDownloadJob(request); local
53 URLRequestSlowDownloadJob::kPendingRequests.push_back(job);
54 return job;
|
| /sdk/eclipse/plugins/com.android.ide.eclipse.adt/src/com/android/ide/eclipse/adt/internal/lint/ |
| RunLintAction.java | 25 import org.eclipse.core.runtime.jobs.Job;
50 Job job = LintRunner.startLint(project, null); local
51 if (job != null) {
52 job.addJobChangeListener(new FinishListener(project));
|
| /external/chromium/net/websockets/ |
| websocket_job_unittest.cc | 220 SocketStream* GetSocket(SocketStreamJob* job) {
221 return job->socket_.get();
511 scoped_refptr<SocketStreamJob> job = SocketStreamJob::CreateSocketStreamJob( local
513 EXPECT_TRUE(GetSocket(job.get())->is_secure());
514 job->DetachDelegate();
517 job = SocketStreamJob::CreateSocketStreamJob(
519 EXPECT_FALSE(GetSocket(job.get())->is_secure());
520 job->DetachDelegate();
|
| /external/bluetooth/glib/gio/ |
| 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,
|
