| /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/base/ |
| 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;
|
| /sdk/eclipse/plugins/com.android.ide.eclipse.adt/src/com/android/ide/eclipse/adt/internal/lint/ |
| EclipseLintRunner.java | 29 import org.eclipse.core.runtime.jobs.Job;
62 LintJob job = (LintJob) startLint(resources, source, doc, fatalOnly, local
65 job.join();
66 boolean fatal = job.isFatal();
81 * Runs lint and updates the markers. Does not wait for the job to finish -
95 * @return the job running lint in the background.
97 public static Job startLint(
109 * Runs lint and updates the markers. Does not wait for the job to finish -
122 * @return the job running lint in the background.
124 public static Job startLint
136 LintJob job = new LintJob(client, resources, source); local
[all...] |
| /sdk/eclipse/plugins/com.android.ide.eclipse.adt/src/com/android/ide/eclipse/adt/internal/launch/junit/runtime/ |
| RemoteAdtTestRunner.java | 33 import org.eclipse.core.runtime.jobs.Job;
95 * <li> First, a separate job per device is run to collect test tree data. A per device
100 * <li> A job per device is again launched to do the actual test run. A per device
154 TestTreeCollectorJob job = new TestTreeCollectorJob( local
157 job.setPriority(Job.INTERACTIVE);
158 job.schedule();
160 collectorJobs.add(job);
165 for (TestTreeCollectorJob job : collectorJobs) {
167 job.join()
203 InstrumentationRunJob job = new InstrumentationRunJob( local
[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_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/gallerycommon/src/com/android/gallery3d/util/ |
| ThreadPool.java | 43 // A Job is like a Callable, but it has an addition JobContext parameter.
44 public interface Job<T> {
95 // Submit a job to the thread pool. The listener will be called when the
96 // job is finished (or cancelled).
97 public <T> Future<T> submit(Job<T> job, FutureListener<T> listener) {
98 Worker<T> w = new Worker<T>(job, listener);
103 public <T> Future<T> submit(Job<T> job) {
104 return submit(job, null)
[all...] |
| /external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/plugins/ |
| org.eclipse.core.jobs_3.5.1.R36x_v20100824.jar | |
| /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();
|
| /packages/apps/Gallery2/src/com/android/photos/data/ |
| MediaCache.java | 206 ProcessingJob job = (ProcessingJob) parameter;
208 addNotification(job.lowResolution, file);
514 ProcessingJob job = new ProcessingJob(uri, size, complete, lowResolution); local
516 tasks.add(job);
522 tasks.add(index + 1, job);
570 private void processTask(ProcessingJob job) {
571 File cachedFile = getCachedFile(job.contentUri, job.size);
573 addNotification(job.complete, cachedFile);
577 boolean hasLowResolution = job.lowResolution != null
[all...] |
| /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...] |
| /external/compiler-rt/lib/tsan/lit_tests/ |
| test_output.sh | 45 for job in `jobs -p`; do
46 wait $job || exit 1
|
| /prebuilts/gcc/linux-x86/host/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...] |
| /device/lge/mako/camera/QCamera/stack/mm-jpeg-interface/src/ |
| mm_jpeg.c | 67 /* special queue functions for job queue */
254 int32_t mm_jpeg_omx_config_user_preference(mm_jpeg_obj* my_obj, mm_jpeg_encode_job* job)
262 map_jpeg_format(job->encode_parm.buf_info.src_imgs.src_img[JPEG_SRC_IMAGE_TYPE_MAIN].color_format);
263 if (job->encode_parm.buf_info.src_imgs.src_img_num > 1) {
265 map_jpeg_format(job->encode_parm.buf_info.src_imgs.src_img[JPEG_SRC_IMAGE_TYPE_THUMB].color_format);
276 int32_t mm_jpeg_omx_config_thumbnail(mm_jpeg_obj* my_obj, mm_jpeg_encode_job* job)
284 &(job->encode_parm.buf_info.src_imgs.src_img[JPEG_SRC_IMAGE_TYPE_THUMB]);
382 int32_t mm_jpeg_omx_config_main(mm_jpeg_obj* my_obj, mm_jpeg_encode_job* job)
386 &(job->encode_parm.buf_info.src_imgs.src_img[JPEG_SRC_IMAGE_TYPE_MAIN]);
420 int32_t mm_jpeg_omx_config_common(mm_jpeg_obj* my_obj, mm_jpeg_encode_job* job)
500 mm_jpeg_encode_job* job = &job_entry->job.encode_job; local
[all...] |
| mm_jpeg_interface.c | 68 static int32_t mm_jpeg_intf_start_job(uint32_t client_hdl, mm_jpeg_job* job, uint32_t* jobId)
73 NULL == job ||
75 CDBG_ERROR("%s: invalid parameters for client_hdl, job or jobId", __func__);
87 rc = mm_jpeg_start_job(g_jpeg_obj, client_hdl, job, jobId);
|
| /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...] |
| /packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/latin/ |
| SubtypeLocaleTests.java | 133 protected Void job(Resources res) {
157 protected Void job(Resources res) {
179 protected Void job(Resources res) {
203 protected Void job(Resources res) {
251 protected Void job(Resources res) {
275 protected Void job(Resources res) {
315 protected Void job(Resources res) {
339 protected Void job(Resources res) {
|
| /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;
|
