| /device/google/cuttlefish_common/guest/monitoring/vsoc_service/java/com/android/google/gce/gceservice/ |
| H A D | JobExecutor.java | 42 /** Schedule job for (periodic) execution.
47 * Note: iteration time is |delaySeconds| + total time needed to execute job.
49 public void schedule(final JobBase job, final GceFuture<?>... futures) { argument
76 "Could not start job %s.", job.getClass().getName()),
78 job.onDependencyFailed(e);
85 job.onDependencyStraggling(mFutures);
92 String jobName = job.getClass().getName();
96 int delaySeconds = job.execute();
104 job
[all...] |
| /device/google/marlin/camera/QCamera2/stack/mm-jpeg-interface/src/ |
| H A D | mm_jpegdec_interface.c | 46 * @job: jpeg job object
47 * @jobId: job id
53 * start the jpeg job
56 static int32_t mm_jpegdec_intf_start_job(mm_jpeg_job_t* job, uint32_t* job_id) argument
60 if (NULL == job ||
62 LOGE("invalid parameters for job or jobId");
73 rc = mm_jpegdec_start_decode_job(g_jpegdec_obj, job, job_id);
153 * @jobId: job id
159 * Abort the jpeg job
[all...] |
| H A D | mm_jpeg_interface.c | 97 * @job: jpeg job object
98 * @jobId: job id
104 * start the jpeg job
107 static int32_t mm_jpeg_intf_start_job(mm_jpeg_job_t* job, uint32_t* job_id) argument
111 if (NULL == job ||
113 LOGE("invalid parameters for job or jobId");
124 rc = mm_jpeg_start_job(g_jpeg_obj, job, job_id);
204 * @jobId: job id
210 * Abort the jpeg job
[all...] |
| H A D | mm_jpegdec.c | 62 * Destroy the job based paramenters
81 * Finalize the job
89 /*Destroy job related params*/
92 /*remove the job*/
100 /* wake up jobMgr thread to work on new job if there is any */
108 * @data: job session
145 * @data: job session
185 * @p_session: job session
229 * @p_session: job session
274 * @p_session: job sessio
728 mm_jpegdec_start_decode_job(mm_jpeg_obj *my_obj, mm_jpeg_job_t *job, uint32_t *job_id) argument
[all...] |
| H A D | mm_jpeg.c | 106 * @data: job session
166 * @data: job session
217 * @p_session: job session
288 * @p_session: job session
343 * @p_session: job session
420 * @p_session: job session
477 * @p_session: job session
519 * @p_session: job session
543 * @p_session: job session
581 * @p_jpeg_session: job sessio
2327 mm_jpeg_start_job(mm_jpeg_obj *my_obj, mm_jpeg_job_t *job, uint32_t *job_id) argument
[all...] |
| /device/google/marlin/camera/QCamera2/stack/mm-camera-test/src/ |
| H A D | mm_qcamera_snapshot.c | 49 LOGE(" NULL current job frames or not matching job ID (%d, %d)",
55 LOGE(" job %d, status=%d", jobId, status);
86 mm_jpeg_job_t job; local
97 memset(&job, 0, sizeof(job));
98 job.job_type = JPEG_JOB_TYPE_ENCODE;
99 job.encode_job.session_id = test_obj->current_jpeg_sess_id;
103 job.encode_job.rotation = 0;
105 job
[all...] |
| /device/google/marlin/camera/QCamera2/stack/mm-jpeg-interface/test/ |
| H A D | mm_jpegdec_test.c | 93 mm_jpeg_job_t job; member in struct:__anon1198
244 mm_jpeg_decode_job_t *p_job_params = &p_obj->job.decode_job;
406 &jpeg_obj.job.decode_job.session_id);
407 if (jpeg_obj.job.decode_job.session_id == 0) {
413 jpeg_obj.job.job_type = JPEG_JOB_TYPE_DECODE;
415 LOGE("Starting decode job");
421 rc = jpeg_obj.ops.start_job(&jpeg_obj.job, &jpeg_obj.job_id[i]);
440 jpeg_obj.ops.destroy_session(jpeg_obj.job.decode_job.session_id);
|
| H A D | mm_jpeg_test.c | 129 mm_jpeg_job_t job; member in struct:__anon1196
176 LOGE("Cannot find job ID!!!");
306 mm_jpeg_encode_job_t *p_job_params = &p_obj->job.encode_job;
484 &jpeg_obj->job.encode_job.session_id);
485 if (jpeg_obj->job.encode_job.session_id == 0) {
492 jpeg_obj->job.job_type = JPEG_JOB_TYPE_ENCODE;
493 jpeg_obj->job.encode_job.src_index = (int32_t) i;
494 jpeg_obj->job.encode_job.dst_index = (int32_t) i;
495 jpeg_obj->job.encode_job.thumb_index = (uint32_t) i;
498 jpeg_obj->job
[all...] |
| /device/google/marlin/camera/QCamera2/HAL/ |
| H A D | QCameraPostProc.cpp | 323 // dataProc Thread need to process "stop" as sync call because abort jpeg job should be a sync call
460 * DESCRIPTION: function to prepare encoding job information
956 LOGE("No memory for pproc job");
1026 LOGE("No memory for jpeg job");
1096 * NOTE : This event will also trigger DataProc thread to move to next job
1097 * processing (i.e., send a new jpeg encoding job to mm-jpeg-interface
1098 * if there is any pending job in jpeg input queue)
1134 // Release jpeg job data
1140 LOGH("[KPI Perf] : jpeg job %d", evt->jobId);
1248 // wait up data proc thread to do next job,
1280 qcamera_pp_data_t *job = (qcamera_pp_data_t *)m_ongoingPPQ.dequeue(); local
1473 qcamera_jpeg_data_t * job = NULL; local
1727 releaseJpegJobData(qcamera_jpeg_data_t *job) argument
1791 qcamera_jpeg_data_t *job = pme->findJpegJobByJobId(job_data->jobId); local
3350 qcamera_jpeg_data_t * job = (qcamera_jpeg_data_t *) data; local
[all...] |
| /device/google/marlin/camera/QCamera2/HAL3/ |
| H A D | QCamera3Channel.cpp | 3134 * @status : status of jpeg job
3136 * @jobId : jpeg job Id
3159 qcamera_hal3_jpeg_data_t *job = obj->m_postprocessor.findJpegJobByJobId(jobId); local
3161 if ((job == NULL) || (status == JPEG_JOB_STATUS_ERROR)) {
3166 if (NULL != job) {
3167 uint32_t bufIdx = (uint32_t)job->jpeg_settings->out_buf_index;
3265 if (job->src_reproc_frame)
3266 src_frame = job->src_reproc_frame;
3268 src_frame = job->src_frame;
3292 // release internal data for jpeg job
[all...] |
| H A D | QCamera3PostProc.cpp | 313 * DESCRIPTION: function to prepare encoding job information
406 * DESCRIPTION: function to prepare encoding job information
577 LOGD("meta queue is not empty, do next job");
622 LOGE("No memory for jpeg job");
660 LOGD("pp queue is not empty, do next job");
663 LOGD("pp queue is empty, not calling do next job");
708 qcamera_hal3_pp_data_t *job = (qcamera_hal3_pp_data_t *)m_ongoingPPQ.dequeue(); local
709 if (job == NULL || ((NULL == job->src_frame) && (NULL == job
793 qcamera_hal3_jpeg_data_t * job = NULL; local
949 releaseJpegJobData(qcamera_hal3_jpeg_data_t *job) argument
[all...] |