| /device/google/marlin/camera/QCamera2/stack/mm-jpeg-interface/inc/ |
| mm_jpeg_inlines.h | 49 static inline mm_jpeg_job_session_t *mm_jpeg_get_session(mm_jpeg_obj *my_obj, uint32_t job_id)
52 int client_idx = GET_CLIENT_IDX(job_id);
53 int session_idx= GET_SESSION_IDX(job_id);
60 job_id);
114 static inline void mm_jpeg_remove_session_idx(mm_jpeg_obj *my_obj, uint32_t job_id)
116 int client_idx = GET_CLIENT_IDX(job_id);
117 int session_idx= GET_SESSION_IDX(job_id);
|
| /hardware/qcom/camera/msm8998/QCamera2/stack/mm-jpeg-interface/inc/ |
| mm_jpeg_inlines.h | 49 static inline mm_jpeg_job_session_t *mm_jpeg_get_session(mm_jpeg_obj *my_obj, uint32_t job_id)
52 int client_idx = GET_CLIENT_IDX(job_id);
53 int session_idx= GET_SESSION_IDX(job_id);
60 job_id);
114 static inline void mm_jpeg_remove_session_idx(mm_jpeg_obj *my_obj, uint32_t job_id)
116 int client_idx = GET_CLIENT_IDX(job_id);
117 int session_idx= GET_SESSION_IDX(job_id);
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| grpc_channel.h | 33 // Each job_id requires:
39 HostPortsJob(const string& job_id, const std::map<int, string>& host_ports)
40 : job_id(job_id), host_ports(host_ports) {}
41 const string job_id; member in struct:tensorflow::GrpcChannelSpec::HostPortsJob
45 Status AddHostPortsJob(const string& job_id,
48 Status AddHostPortsJob(const string& job_id,
|
| grpc_channel.cc | 87 Status GrpcChannelSpec::AddHostPortsJob(const string& job_id,
93 return AddHostPortsJob(job_id, host_ports_map);
97 const string& job_id, const std::map<int, string>& host_ports) {
98 if (!job_ids_.insert(job_id).second) {
100 "Duplicate job ID in cluster specification: ", job_id);
105 host_ports_jobs_.emplace_back(job_id, host_ports);
209 SparseGrpcChannelCache(const string& job_id,
212 : job_id_(job_id),
290 new SparseGrpcChannelCache(job.job_id, job.host_ports, channel_func));
|
| /external/autotest/frontend/migrations/ |
| 022_implement_sync_count.py | 20 INNER JOIN host_queue_entries AS hqe ON jobs.id = hqe.job_id
25 SELECT hqe.id, hqe.job_id, hqe.status, hqe.complete, hosts.hostname
29 for id, job_id, status, complete, hostname in hqes:
30 if job_id in synch_jobs or job_hqe_count[job_id] == 1:
|
| /external/autotest/venv/lucifer/cmd/ |
| job_reporter.py | 43 with leasing.obtain_lease(_lease_path(args.jobdir, args.job_id)):
106 _mark_handoff_completed(args.job_id)
116 job = models.Job.objects.get(id=args.job_id)
135 job = models.Job.objects.get(id=args.job_id)
140 '-abortsock', _abort_sock_path(args.jobdir, args.job_id),
156 def _mark_handoff_completed(job_id):
158 handoff = models.JobHandoff.objects.get(job_id=job_id)
163 def _abort_sock_path(jobdir, job_id):
164 return _lease_path(jobdir, job_id) + '.sock
[all...] |
| job_aborter.py | 101 logger.debug('Found handoff: %d', handoff.job_id)
102 if handoff.job_id not in active_leases:
103 logger.debug('Handoff %d is missing active lease', handoff.job_id)
104 job_ids.append(handoff.job_id)
|
| /external/libcups/cups/ |
| dest-job.c | 25 * The "job_id" is the number returned by cupsCreateDestJob.
37 int job_id) /* I - Job ID */
51 ippAddInteger(request, IPP_TAG_OPERATION, IPP_TAG_INTEGER, "job-id", job_id);
66 * "job_id" is the job ID returned by cupsCreateDestJob. Returns @code IPP_STATUS_OK@
77 int job_id) /* I - Job ID */
84 DEBUG_printf(("cupsCloseDestJob(http=%p, dest=%p(%s/%s), info=%p, job_id=%d)", (void *)http, (void *)dest, dest ? dest->name : NULL, dest ? dest->instance : NULL, (void *)info, job_id));
97 if (!http || !dest || !info || job_id <= 0)
135 job_id);
158 * in the variable pointed to by "job_id"
[all...] |
| notify.c | 38 ipp_attribute_t *job_id, /* notify-job-id */ local
58 job_id = ippFindAttribute(event, "notify-job-id", IPP_TAG_INTEGER);
68 if (job_id && printer_name && printer_uri && job_state)
107 job_id->values[0].integer,
|
| util.c | 57 int job_id) /* I - Job ID, @code CUPS_JOBID_CURRENT@ for the current job, or @code CUPS_JOBID_ALL@ for all jobs */
59 return (cupsCancelJob2(CUPS_HTTP_DEFAULT, name, job_id, 0)
82 int job_id, /* I - Job ID, @code CUPS_JOBID_CURRENT@ for the current job, or @code CUPS_JOBID_ALL@ for all jobs */
93 if (job_id < -1 || (!name && job_id == 0))
118 request = ippNewRequest(job_id < 0 ? IPP_OP_PURGE_JOBS : IPP_OP_CANCEL_JOB);
128 job_id);
130 else if (job_id > 0)
132 snprintf(uri, sizeof(uri), "ipp://localhost/jobs/%d", job_id);
140 if (purge && job_id >= 0
175 int job_id = 0; \/* job-id value *\/ local
805 int job_id; \/* New job ID *\/ local
[all...] |
| /external/autotest/site_utils/ |
| lxc_cleanup.py | 56 job_id = container.id.job_id
65 hqes = AFE.get_host_queue_entries(job_id=job_id)
67 logging.error('Failed to get hqe for job %s. Error: %s.', job_id, e)
76 'not orphaned.', job_id, container.name)
82 job_id)
86 job_id, container.name)
|
| job_history.py | 23 JOB_URL = LOG_BASE_URL + '%(job_id)s-%(owner)s/%(hostname)s'
125 def try_get(self, host_id, job_id, start_time, end_time):
129 @param job_id: ID of the test job that's related to the special task.
138 return self[host_id].try_get(job_id, start_time, end_time)
168 def try_get(self, job_id, start_time, end_time):
171 @param job_id: ID of the test job that's related to the special task.
181 task.queue_entry.job.id == job_id]
228 self.log_url = JOB_URL % {'job_id': hqe.job.id, 'owner': hqe.job.owner,
336 self.log_url = JOB_URL % {'job_id': hqe.job.id, 'owner': hqe.job.owner,
339 hqe = models.HostQueueEntry.objects.filter(job_id=hqe.job.id)[0
[all...] |
| /external/autotest/scheduler/ |
| rdb_lib.py | 31 jobs = [queue_entry.job_id for queue_entry in queue_entries]
45 job_id = queue_entry.job_id
47 for dep in self._job_deps.get(job_id, []):
53 job_acls = self._job_acls.get(job_id, [])
|
| /external/autotest/server/cros/dynamic_suite/ |
| reporting_utils.py | 191 def link_job(job_id, instance_server=None):
194 @param job_id: A string, representing the job id.
201 if not job_id:
208 return _job_view % (instance_server, job_id)
211 def _base_results_log(job_id, result_owner, hostname):
214 @param job_id: A string, representing the job id.
222 if job_id and result_owner and hostname:
223 path_to_object = '%s-%s/%s' % (job_id, result_owner,
229 def link_result_logs(job_id, result_owner, hostname):
232 @param job_id: A string, representing the job id
[all...] |
| reporting.py | 53 self.job_id = result.id
147 self.job_id, self.result_owner, self.hostname),
149 self.job_id, self.result_owner, self.hostname),
151 reporting_utils.link_job(self.job_id),
|
| tools.py | 285 def create_bug_keyvals(job_id, testname, bug_info):
291 @param job_id The afe job id of job which the test is associated to.
292 job_id will be a part of the key.
296 keyval_base = '%s_%s' % (job_id, testname) if job_id else testname
303 def get_test_failure_bug_info(keyvals, job_id, testname):
320 @param job_id The afe job id of the job that runs the test.
327 keyval_base = '%s_%s' % (job_id, testname) if job_id else testname
|
| /external/webrtc/third_party/gtest-parallel/ |
| gtest-parallel | 135 def handle_meta(self, job_id, args):
139 self.tests[job_id] = (binary, test.strip())
143 (binary, test) = self.tests[job_id]
146 self.failures.append(self.tests[job_id])
147 with open(self.outputs[job_id]) as f:
157 def logfile(self, job_id, name):
158 self.outputs[job_id] = name
182 def logfile(self, job_id, name):
183 with open(self.outputs[job_id]) as f:
185 self.log(str(job_id) + '> ' + line.rstrip()
[all...] |
| /device/google/marlin/camera/QCamera2/stack/mm-jpeg-interface/src/ |
| mm_jpeg_interface.c | 107 static int32_t mm_jpeg_intf_start_job(mm_jpeg_job_t* job, uint32_t* job_id)
112 NULL == job_id) {
124 rc = mm_jpeg_start_job(g_jpeg_obj, job, job_id);
213 static int32_t mm_jpeg_intf_abort_job(uint32_t job_id)
217 if (0 == job_id) {
230 rc = mm_jpeg_abort_job(g_jpeg_obj, job_id);
|
| mm_jpegdec_interface.c | 56 static int32_t mm_jpegdec_intf_start_job(mm_jpeg_job_t* job, uint32_t* job_id)
61 NULL == job_id) {
73 rc = mm_jpegdec_start_decode_job(g_jpegdec_obj, job, job_id);
162 static int32_t mm_jpegdec_intf_abort_job(uint32_t job_id)
166 if (0 == job_id) {
179 rc = mm_jpegdec_abort_job(g_jpegdec_obj, job_id);
|
| /hardware/qcom/camera/msm8998/QCamera2/stack/mm-jpeg-interface/src/ |
| mm_jpeg_interface.c | 107 static int32_t mm_jpeg_intf_start_job(mm_jpeg_job_t* job, uint32_t* job_id)
112 NULL == job_id) {
124 rc = mm_jpeg_start_job(g_jpeg_obj, job, job_id);
213 static int32_t mm_jpeg_intf_abort_job(uint32_t job_id)
217 if (0 == job_id) {
230 rc = mm_jpeg_abort_job(g_jpeg_obj, job_id);
|
| mm_jpegdec_interface.c | 56 static int32_t mm_jpegdec_intf_start_job(mm_jpeg_job_t* job, uint32_t* job_id)
61 NULL == job_id) {
73 rc = mm_jpegdec_start_decode_job(g_jpegdec_obj, job, job_id);
162 static int32_t mm_jpegdec_intf_abort_job(uint32_t job_id)
166 if (0 == job_id) {
179 rc = mm_jpegdec_abort_job(g_jpegdec_obj, job_id);
|
| /external/toolchain-utils/automation/server/ |
| job_manager.py | 104 def KillJob(self, job_id):
110 self._KillJob(job_id)
112 def GetJob(self, job_id):
114 if job_.id == job_id:
118 def _KillJob(self, job_id):
119 self._logger.info('Killing [Job: %d].', job_id)
121 if job_id in self.job_executer_mapping:
122 self.job_executer_mapping[job_id].Kill()
124 if job_.id == job_id:
|
| /external/autotest/contrib/ |
| always_failing_tests.py | 98 job_id = job.parent_job
99 if not job_id:
100 job_id = job
101 x = rgx.search(job_id.name)
103 print job_id.name
|
| /external/autotest/cli/ |
| query_keyvals | 9 usage = "usage: %prog [options] job_id"
68 for job_id in args:
69 query_filter["job_tag__startswith"] = "%s-" % job_id
|
| /external/toolchain-utils/automation/server/monitor/ |
| dashboard.py | 40 def __init__(self, job_id):
41 self._job = pickle.loads(GetServerConnection().GetJob(job_id))
181 def JobPageHandler(request, job_id):
182 job = JobInfo(int(job_id))
185 'job_id': job_id,
193 def LogPageHandler(request, job_id):
194 job = JobInfo(int(job_id))
196 ctx = MakeDefaultContext({'job_id': job_id, 'log_lines': job.GetLog()}
[all...] |
