| /external/autotest/venv/lucifer/ |
| leasing_unittest.py | 177 def _abort_socket(tmpdir, job_id):
186 path = os.path.join(str(tmpdir), '%d.sock' % job_id)
206 def _make_lease(tmpdir, job_id):
207 return _make_lease_file(str(tmpdir), job_id)
210 def _make_lease_file(jobdir, job_id):
214 @param job_id: Job ID
216 path = os.path.join(jobdir, str(job_id))
|
| /external/autotest/scheduler/ |
| rdb_testing_utils.py | 120 def create_special_task(cls, job_id=None, host_id=None,
123 if job_id:
124 queue_entry = cls.get_hqes(job_id=job_id)[0]
172 def assign_job_to_shard(cls, job_id, shard_hostname):
180 job_filter = models.Job.objects.filter(id=job_id, shard__isnull=True)
257 def add_host_to_job(cls, host, job_id, activate=0):
261 @param job_id: The job to which we need to add the host.
267 hqe = models.HostQueueEntry.objects.get(job_id=job_id)
[all...] |
| monitor_db_unittest.py | 162 'job_id')
164 joins='INNER JOIN afe_jobs ON (job_id=afe_jobs.id)',
190 def _record_job_scheduled(self, job_id, host_id):
191 record = (job_id, host_id)
194 (job_id, host_id))
198 def _assert_job_scheduled_on(self, job_id, host_id):
199 record = (job_id, host_id)
203 (job_id, host_id, self._jobs_scheduled))
207 def _assert_job_scheduled_on_number_of(self, job_id, host_ids, number):
211 record = (job_id, host_id
[all...] |
| /external/autotest/client/site_tests/graphics_dEQP/scripts/ |
| process_logs.py | 37 Logfile = namedtuple('Logfile', 'job_id name gs_path')
62 job_id = gs_path.split('/')[3].split('-')[0]
64 name = os.path.join('logs', job_id + '_graphics_dEQP.DEBUG')
65 logs.append(Logfile(job_id, name, gs_path))
74 job_id = name.split('_')[0]
75 logs.append(Logfile(job_id, name, name))
77 job_id = name.split('_')[0]
78 logs.append(Logfile(job_id, name, name))
|
| /external/toolchain-utils/automation/server/ |
| server.py | 61 def GetJob(self, job_id):
62 self._logger.info('Received GetJob(%d) request.', job_id)
64 return pickle.dumps(self.job_manager.GetJob(job_id))
|
| /external/autotest/contrib/ |
| log_distiller.py | 3 Usage: ./cron_scripts/log_distiller.py job_id path_to_logfile
4 If the job_id is a suite it will find all subjobs.
6 The job_id needs to be in the afe database.
316 self.job_id = kwargs['job_id']
320 (self.filter_command, self.job_id))
355 'The job_id needs to be in the afe database.')
358 job_id = int(sys.argv[1])
360 suite_jobs = rpc.run('get_jobs', id=job_id)
362 suite_jobs = rpc.run('get_jobs', parent_job=job_id)
[all...] |
| compare_suite.py | 30 JOB_URL = LOG_BASE_URL + '%(job_id)s-%(owner)s/%(hostname)s'
46 hosts/hostname/job_id-repair/debug/autoserv.DEBUG.
135 self.log = JOB_URL % {'job_id': job.id, 'owner': job.owner,
159 if not task.queue_entry or task.queue_entry.job_id != self.id:
338 for job_id in job_ids:
339 suite_job = models.Job.objects.filter(id=job_id)[0]
341 test_jobs = models.Job.objects.filter(parent_job_id=job_id)
343 print 'No child job found for suite job: %d' % job_id
|
| /external/autotest/utils/ |
| tko_publish.py | 75 job_id = int(os.path.basename(jobdir).split('-')[0])
76 job = [job for job in finished_jobs if job.id == job_id]
|
| /external/autotest/cli/ |
| job.py | 74 for job_id in self.jobs:
75 if job_id.isdigit():
76 job_ids.append(job_id)
78 job_names.append(job_id)
192 job_id = qe['job']['id']
194 hosts_status.setdefault(job_id,
199 job_id = job['id']
200 if hosts_status.has_key(job_id):
201 this_job = hosts_status[job_id]
348 job_id = self.execute_rpc(op='create_job', **self.data
[all...] |
| /device/google/marlin/camera/QCamera2/stack/common/ |
| mm_jpeg_interface.h | 371 int (*start_job)(mm_jpeg_job_t* job, uint32_t* job_id);
374 int (*abort_job)(uint32_t job_id);
390 int (*start_job)(mm_jpeg_job_t* job, uint32_t* job_id);
393 int (*abort_job)(uint32_t job_id);
|
| /hardware/qcom/camera/msm8998/QCamera2/stack/common/ |
| mm_jpeg_interface.h | 374 int (*start_job)(mm_jpeg_job_t* job, uint32_t* job_id);
377 int (*abort_job)(uint32_t job_id);
393 int (*start_job)(mm_jpeg_job_t* job, uint32_t* job_id);
396 int (*abort_job)(uint32_t job_id);
|
| /external/autotest/site_utils/ |
| test_push.py | 184 job_id = rpc_utils.create_job_common(
189 while not TKO.get_job_test_statuses_from_db(job_id):
191 AFE.run('abort_host_queue_entries', job=job_id)
196 verify_test_results(job_id, EXPECTED_TEST_RESULTS_POWERWASH)
387 hqes = [models.HostQueueEntry.objects.filter(job_id=job_id)[0]
388 for job_id in job_ids]
425 def verify_test_results(job_id, expected_results):
428 @param job_id: id of the running jobs. For suite job, it is suite_job_id.
433 test_views = site_utils.get_test_views_from_tko(job_id, TKO
[all...] |
| run_suite.py | [all...] |
| diagnosis_utils.py | 333 def diagnose_job(self, job_id, instance_server):
338 @param job_id: The id of the suite job to get information about.
344 parent_job_id=job_id, summary=True,
|
| run_suite_unittest.py | 118 for job_id in missing_results:
120 ('get_detailed_test_views', job_id), [])
143 for job_id in child_job_ids:
145 new_job.id = job_id
146 new_job.name = 'test.%d' % job_id
|
| /packages/services/BuiltInPrintService/jni/ipphelper/ |
| ippstatus_monitor.c | 284 int job_id = -1; local
327 job_id = ippGetInteger(attr, 0);
328 LOGD("_cancel got job-id: %d", job_id);
356 if (job_id == -1) {
367 ippAddInteger(request, IPP_TAG_OPERATION, IPP_TAG_INTEGER, "job-id", job_id);
|
| /device/google/marlin/camera/QCamera2/stack/mm-jpeg-interface/inc/ |
| mm_jpeg.h | 350 uint32_t job_id; member in struct:__anon2552
356 uint32_t job_id; member in struct:__anon2553
497 mm_jpeg_queue_t* queue, uint32_t job_id);
501 mm_jpeg_queue_t* queue, uint32_t job_id);
|
| /hardware/qcom/camera/msm8998/QCamera2/stack/mm-jpeg-interface/inc/ |
| mm_jpeg.h | 366 uint32_t job_id; member in struct:__anon49368
372 uint32_t job_id; member in struct:__anon49369
513 mm_jpeg_queue_t* queue, uint32_t job_id);
517 mm_jpeg_queue_t* queue, uint32_t job_id);
|
| /external/libcups/cups/ |
| cups.h | 337 extern int cupsCancelJob(const char *name, int job_id);
450 int job_id, int purge) _CUPS_API_1_4;
471 int job_id, const char *docname,
486 int job_id) _CUPS_API_1_6;
492 cups_dinfo_t *info, int job_id)
523 cups_dinfo_t *info, int *job_id,
562 cups_dinfo_t *info, int job_id,
|
| /external/libcups/filter/ |
| testclient.c | 42 int job_id; /* Job ID for submitted job */ member in struct:_client_monitor_s
334 monitor.job_id = ippGetInteger(attr, 0);
336 printf("CREATED JOB %d, sending %s of type %s\n", monitor.job_id, printfile, printformat);
342 ippAddInteger(request, IPP_TAG_OPERATION, IPP_TAG_INTEGER, "job-id", monitor.job_id);
806 if (monitor->job_id > 0)
814 ippAddInteger(request, IPP_TAG_OPERATION, IPP_TAG_INTEGER, "job-id", monitor->job_id);
828 printf("JOB %d: %s (%s)\n", monitor->job_id, ippEnumString("job-state", job_state), job_state_reasons);
|
| /external/autotest/frontend/afe/ |
| rpc_interface_unittest.py | 88 job_id = rpc_interface.create_job(name='dummy', priority=self._PRIORITY,
93 return models.Job.objects.get(id=job_id)
786 job_id = rpc_interface.create_job(name='test',
[all...] |
| /device/google/marlin/camera/QCamera2/stack/mm-jpeg-interface/src/ |
| mm_jpegdec.c | 666 p_session = mm_jpeg_get_session(my_obj, job_node->dec_info.job_id);
669 job_node->dec_info.job_id);
682 p_session->jobId = job_node->dec_info.job_id;
730 uint32_t *job_id)
740 *job_id = 0;
775 *job_id = job->decode_job.session_id |
780 node->dec_info.job_id = *job_id;
1088 p_session = mm_jpeg_get_session(my_obj, node->dec_info.job_id);
1093 node->dec_info.job_id);
[all...] |
| /hardware/qcom/camera/msm8998/QCamera2/stack/mm-jpeg-interface/src/ |
| mm_jpegdec.c | 666 p_session = mm_jpeg_get_session(my_obj, job_node->dec_info.job_id);
669 job_node->dec_info.job_id);
682 p_session->jobId = job_node->dec_info.job_id;
730 uint32_t *job_id)
740 *job_id = 0;
775 *job_id = job->decode_job.session_id |
780 node->dec_info.job_id = *job_id;
1088 p_session = mm_jpeg_get_session(my_obj, node->dec_info.job_id);
1093 node->dec_info.job_id);
[all...] |
| /external/autotest/server/lib/ |
| suite_report.py | 114 entry['job_id'] = int(job.id)
153 if hqe.job_id is not None:
154 entry['job_id'] = hqe.job_id
|
| /packages/services/BuiltInPrintService/jni/lib/ |
| printer.c | 40 wJob_t job_id; member in struct:__anon53064
258 print_job->job_id = WPRINT_BAD_JOB_HANDLE;
|
