| /device/lge/mako/camera/QCamera/stack/mm-jpeg-interface/inc/ |
| mm_jpeg.h | 55 MM_JPEG_CMD_TYPE_JOB, /* job cmd */
72 uint32_t jobId; /* job ID */
73 mm_jpeg_job job; /* job description */ member in struct:__anon3615
77 jpeg_job_status_t job_status; /* job status */
79 int32_t jpeg_size; /* the size of jpeg output after job is done */
98 pthread_t pid; /* job cmd thread ID */
99 sem_t job_sem; /* semaphore for job cmd thread */
100 mm_jpeg_queue_t job_queue; /* queue for job to do */
104 MM_JPEG_EVENT_MASK_JPEG_DONE = 0x00000001, /* jpeg job is done *
[all...] |
| /device/moto/shamu/camera/QCamera/stack/mm-jpeg-interface/inc/ |
| mm_jpeg.h | 55 MM_JPEG_CMD_TYPE_JOB, /* job cmd */
72 uint32_t jobId; /* job ID */
73 mm_jpeg_job job; /* job description */ member in struct:__anon4105
77 jpeg_job_status_t job_status; /* job status */
79 int32_t jpeg_size; /* the size of jpeg output after job is done */
98 pthread_t pid; /* job cmd thread ID */
99 sem_t job_sem; /* semaphore for job cmd thread */
100 mm_jpeg_queue_t job_queue; /* queue for job to do */
104 MM_JPEG_EVENT_MASK_JPEG_DONE = 0x00000001, /* jpeg job is done *
[all...] |
| /device/moto/shamu/camera/QCamera2/stack/mm-jpeg-interface/test/ |
| mm_jpegdec_test.c | 90 mm_jpeg_job_t job; member in struct:__anon4501
241 mm_jpeg_decode_job_t *p_job_params = &p_obj->job.decode_job;
402 &jpeg_obj.job.decode_job.session_id);
403 if (jpeg_obj.job.decode_job.session_id == 0) {
409 jpeg_obj.job.job_type = JPEG_JOB_TYPE_DECODE;
411 CDBG_ERROR("%s:%d] Starting decode job",__func__, __LINE__);
417 rc = jpeg_obj.ops.start_job(&jpeg_obj.job, &jpeg_obj.job_id[i]);
436 jpeg_obj.ops.destroy_session(jpeg_obj.job.decode_job.session_id);
|
| /external/chromium_org/cloud_print/gcp20/prototype/ |
| print_job_handler.cc | 44 LocalPrintJobExtended(const LocalPrintJob& job, const std::string& ticket)
45 : data(job),
116 const LocalPrintJob& job,
138 return CompleteLocalPrintJob(job, id, expires_in_out,
148 const LocalPrintJob& job,
161 if (job.content_type == "application/pdf") {
163 } else if (job.content_type == "image/pwg-raster") {
165 } else if (job.content_type == "image/jpeg") {
171 CompleteDraft(job_id, job);
202 std::map<std::string, LocalPrintJobExtended>::iterator job = jobs.find(id) local
264 std::map<std::string, LocalPrintJobExtended>::iterator job = jobs.find(id); local
[all...] |
| /external/chromium_org/components/policy/core/common/cloud/ |
| device_management_service_unittest.cc | 80 DeviceManagementRequestJob* job = service_->CreateJob( local
82 job->SetGaiaToken(kGaiaAuthToken);
83 job->SetOAuthToken(kOAuthToken);
84 job->SetClientID(kClientID);
85 job->GetRequest()->mutable_register_request();
86 job->SetRetryCallback(base::Bind(
88 job->Start(base::Bind(&DeviceManagementServiceTestBase::OnJobDone,
90 return job;
94 DeviceManagementRequestJob* job = service_->CreateJob( local
97 job->SetGaiaToken(kGaiaAuthToken)
109 DeviceManagementRequestJob* job = local
123 DeviceManagementRequestJob* job = service_->CreateJob( local
139 DeviceManagementRequestJob* job = local
[all...] |
| /external/chromium_org/extensions/browser/ |
| content_hash_fetcher.cc | 61 // Cancels this job, which will attempt to stop I/O operations sooner than
62 // just waiting for the entire job to complete. Safe to call from any thread.
65 // Checks whether this job has been cancelled. Safe to call from any thread.
68 // Returns whether this job was successful (we have both verified contents
69 // and computed hashes). Even if the job was a success, there might have been
106 // Callback for the job to write the verified contents to the filesystem.
147 // Whether this job succeeded.
444 // Just let the existing job keep running.
447 // Kill the existing non-force job, so we can start a new one below.
461 ContentHashFetcherJob* job local
[all...] |
| /external/chromium_org/remoting/host/win/ |
| wts_session_process_delegate.cc | 81 // Drains the completion port queue to make sure that all job object
88 // Creates and initializes the job object that will sandbox the launched child
90 void InitializeJob(scoped_ptr<base::win::ScopedHandle> job);
92 // Notified that the job object initialization is complete.
93 void InitializeJobCompleted(scoped_ptr<base::win::ScopedHandle> job);
95 // Called when the number of processes running in the job reaches zero.
104 // The task runner serving job object notifications.
120 // The job object used to control the lifetime of child processes.
176 ScopedHandle job; local
177 job.Set(CreateJobObject(NULL, NULL))
[all...] |
| /external/glide/library/src/main/java/com/bumptech/glide/load/engine/ |
| Engine.java | 140 EngineJob job = current.getJob(); local
141 job.addCallback(cb);
145 return new LoadStatus(cb, job);
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| DispatcherTest.java | 134 private List<Job> jobs = new ArrayList<Job>();
137 jobs.add((Job) command);
142 for (Job job : jobs) {
143 actualUrls.add(job.request().urlString());
149 for (Iterator<Job> i = jobs.iterator(); i.hasNext(); ) {
150 Job job = i.next(); local
151 if (job.request().urlString().equals(url))
[all...] |
| /frameworks/base/services/core/java/com/android/server/job/controllers/ |
| BatteryController.java | 17 package com.android.server.job.controllers;
32 import com.android.server.job.JobSchedulerService;
33 import com.android.server.job.StateChangedListener;
|
| IdleController.java | 17 package com.android.server.job.controllers;
32 import com.android.server.job.JobSchedulerService;
33 import com.android.server.job.StateChangedListener;
|
| /frameworks/base/services/tests/servicestests/src/com/android/server/job/ |
| JobStoreTest.java | 1 package com.android.server.job;
6 import android.app.job.JobInfo;
7 import android.app.job.JobInfo.Builder;
14 import com.android.server.job.controllers.JobStatus;
|
| /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...] |
| /sdk/eclipse/plugins/com.android.ide.eclipse.adt/src/com/android/ide/eclipse/adt/internal/welcome/ |
| AdtStartup.java | 37 import org.eclipse.core.runtime.jobs.Job;
286 Job pingJob = createPingUsageServerJob();
288 pingJob.setPriority(Job.BUILD);
289 // Wait another 30 seconds before starting the ping job. This gives other
296 * Creates a job than can ping the usage server.
298 private Job createPingUsageServerJob() {
300 Job job = new Job("Android SDK Ping") { // Job name, visible in progress vie local
[all...] |
| /external/emma/core/java12/com/vladium/emma/instr/ |
| InstrProcessorST.java | 234 // 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:
939 final Job job = m_jobs [j]; local
[all...] |
| /frameworks/base/services/core/java/com/android/server/job/ |
| JobStore.java | 17 package com.android.server.job;
20 import android.app.job.JobInfo;
36 import com.android.server.job.controllers.JobStatus;
53 * Maintains the master list of jobs that the job scheduler is tracking. These jobs are compared by
59 * This is important b/c {@link com.android.server.job.JobStore.WriteJobsMapToDiskRunnable}
60 * and {@link com.android.server.job.JobStore.ReadJobMapFromDiskRunnable} lock on that
92 * @return A freshly initialized job store object, with no loaded jobs.
102 * Construct the instance of the job store. This results in a blocking read from disk.
109 File jobDir = new File(systemDir, "job");
119 * Add a job to the master list, persisting it if necessary. If the JobStatus already exists
370 final JobInfo job = jobStatus.getJob(); local
[all...] |
| /sdk/eclipse/plugins/com.android.ide.eclipse.adt/src/com/android/ide/eclipse/adt/internal/editors/layout/ |
| LayoutEditorDelegate.java | 62 import org.eclipse.core.runtime.jobs.Job;
461 public Job delegateRunLint() {
464 // nodes on that lint job, such that we can quickly look up error nodes
465 //Job job = super.delegateRunLint();
467 Job job = null; local
477 job = EclipseLintRunner.startLint(mClient, resources, file,
481 if (job != null) {
484 job.addJobChangeListener(new LintJobListener(graphicalEditor))
[all...] |
| /sdk/eclipse/plugins/com.android.ide.eclipse.adt/src/com/android/ide/eclipse/adt/internal/sdk/ |
| Sdk.java | 73 import org.eclipse.core.runtime.jobs.Job;
618 * Adds or edit a build tools marker from the given project. This is done through a Job.
623 Job markerJob = new Job("Android SDK: Build Tools Marker") {
642 // Don't return e2.getStatus(); the job control will then produce
652 markerJob.setPriority(Job.BUILD);
659 * <p/> The data is loaded in a separate {@link Job}, and opened editors will be notified
707 Job job = new Job(String.format("Loading data for %1$s", target.getFullName())) local
1481 Job job = new Job("Update Android editor bindings") { \/\/$NON-NLS-1\$ local
[all...] |
| /sdk/eclipse/plugins/com.android.ide.eclipse.tests/src/com/android/ide/eclipse/adt/internal/wizards/templates/ |
| TemplateHandlerTest.java | 69 import org.eclipse.core.runtime.jobs.Job;
715 Job job = new Job("Validate project") { local
727 job.schedule(1000);
728 job.join();
729 Object property = job.getProperty(ERROR_KEY);
749 private void ensureValidProject(@NonNull Job job, @NonNull IProject project) throws Exception {
751 ensureNoBuildErrors(job, project)
[all...] |
| /device/asus/flo/camera/QCamera2/HAL/ |
| QCameraPostProc.cpp | 213 // dataProc Thread need to process "stop" as sync call because abort jpeg job should be a sync call
222 * DESCRIPTION: function to prepare encoding job information
480 ALOGE("%s: No memory for jpeg job", __func__);
528 * NOTE : This event will also trigger DataProc thread to move to next job
529 * processing (i.e., send a new jpeg encoding job to mm-jpeg-interface
530 * if there is any pending job in jpeg input queue)
537 // find job by jobId
538 qcamera_jpeg_data_t *job = findJpegJobByJobId(evt->jobId); local
540 if (job == NULL) {
541 ALOGE("%s: Cannot find jpeg job by jobId(%d)", __func__, evt->jobId)
630 qcamera_pp_data_t *job = (qcamera_pp_data_t *)m_ongoingPPQ.dequeue(); local
683 qcamera_jpeg_data_t * job = NULL; local
[all...] |
| /device/asus/flo/camera/QCamera2/HAL3/ |
| QCamera3PostProc.cpp | 223 * DESCRIPTION: function to prepare encoding job information
372 ALOGE("%s: No memory for jpeg job", __func__);
421 ALOGV("%s: meta queue is not empty, do next job", __func__);
432 ALOGE("%s: No memory for jpeg job", __func__);
466 ALOGV("%s: pp queue is not empty, do next job", __func__);
509 qcamera_pp_data_t *job = (qcamera_pp_data_t *)m_ongoingPPQ.dequeue(); local
511 if (job == NULL || job->src_frame == NULL) {
512 ALOGE("%s: Cannot find reprocess job", __func__);
519 ALOGE("%s: No memory for jpeg job", __func__)
555 qcamera_jpeg_data_t * job = NULL; local
[all...] |
| /device/lge/hammerhead/camera/QCamera2/HAL/ |
| QCameraPostProc.cpp | 213 // dataProc Thread need to process "stop" as sync call because abort jpeg job should be a sync call
222 * DESCRIPTION: function to prepare encoding job information
480 ALOGE("%s: No memory for jpeg job", __func__);
528 * NOTE : This event will also trigger DataProc thread to move to next job
529 * processing (i.e., send a new jpeg encoding job to mm-jpeg-interface
530 * if there is any pending job in jpeg input queue)
537 // find job by jobId
538 qcamera_jpeg_data_t *job = findJpegJobByJobId(evt->jobId); local
540 if (job == NULL) {
541 ALOGE("%s: Cannot find jpeg job by jobId(%d)", __func__, evt->jobId)
630 qcamera_pp_data_t *job = (qcamera_pp_data_t *)m_ongoingPPQ.dequeue(); local
683 qcamera_jpeg_data_t * job = NULL; local
[all...] |
| /device/lge/hammerhead/camera/QCamera2/HAL3/ |
| QCamera3PostProc.cpp | 242 * DESCRIPTION: function to prepare encoding job information
376 ALOGV("%s: meta queue is not empty, do next job", __func__);
385 ALOGE("%s: No memory for jpeg job", __func__);
419 ALOGI("%s: pp queue is not empty, do next job", __func__);
422 ALOGI("%s: pp queue is empty, not calling do next job", __func__);
487 qcamera_pp_data_t *job = (qcamera_pp_data_t *)m_ongoingPPQ.dequeue(); local
490 if (job == NULL || job->src_frame == NULL) {
491 ALOGE("%s: Cannot find reprocess job", __func__);
502 ALOGE("%s: No memory for jpeg job", __func__)
540 qcamera_jpeg_data_t * job = NULL; local
[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...] |
| /device/moto/shamu/camera/QCamera/stack/mm-camera-test/src/ |
| mm_qcamera_snapshot.c | 203 CDBG_ERROR("%s: NULL current job frames or not matching job ID (%d, %d)",
209 CDBG_ERROR("%s: job %d, status=%d, thumbnail_dropped=%d",
236 mm_jpeg_job job; local
272 memset(&job, 0, sizeof(job));
273 job.job_type = JPEG_JOB_TYPE_ENCODE;
274 job.encode_job.jpeg_cb = jpeg_encode_cb;
275 job.encode_job.userdata = (void*)pme;
276 job.encode_job.encode_parm.exif_data = NULL
[all...] |
