| /external/autotest/site_utils/sponge_lib/ |
| D | autotest_job_info.py | 33 self._job = job
35 self.create_task_info(test) for test in self._job.tests)
44 return job_directories.get_job_id_or_task_id(self._job.dir)
49 return self._job.label
54 return self._job.user
59 return self._job.keyval_dict.get('job_started', time.time())
64 return self._job.keyval_dict.get('job_finished', time.time())
69 return self._job.machine
74 return self._job.keyval_dict.get('drone', socket.gethostname())
79 return self._job.keyval_dict
[all …]
|
| D | acts_job_info.py | 130 return self._job.user.strip("'").strip('"')
|
| /external/autotest/site_utils/ |
| D | gs_offloader_unittest.py | 576 self._job = self.make_job(self.REGULAR_JOBLIST[0])
632 self._job.queue_args[0],
633 self._job.queue_args[1],
634 self._job.queue_args[2])
637 os.path.isdir(self._job.queue_args[0]))
639 self._job.queue_args[0])
648 self._job.queue_args)
657 self._job.queue_args)
664 self._job = self.make_job(os.path.join(should_remove, '1'))
666 self._job.queue_args)
[all …]
|
| /external/autotest/server/site_tests/tast/ |
| D | tast_unittest.py | 66 self._job = FakeServerJob(make_subdir('job'), make_subdir('tmp'))
72 self._test = tast.tast(self._job, self._bin_dir, self._out_dir)
255 if self._job.post_run_hook:
256 self._job.post_run_hook()
276 if not os.path.exists(os.path.join(self._job.resultdir,
279 return utils.read_keyval(self._job.resultdir)
289 status_string(self._job.status_entries))
300 status_string(self._job.status_entries))
309 status_string(self._job.status_entries))
318 status_string(self._job.status_entries))
[all …]
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | pool.py | 262 self._taskqueue.put((((result._job, i, func, (x,), {})
269 self._taskqueue.put((((result._job, i, mapstar, (x,), {})
280 self._taskqueue.put((((result._job, i, func, (x,), {})
287 self._taskqueue.put((((result._job, i, mapstar, (x,), {})
297 self._taskqueue.put(([(result._job, None, func, args, kwds)], None))
317 self._taskqueue.put((((result._job, i, mapstar, (x,), {})
544 self._job = job_counter.next()
548 cache[self._job] = self
584 del self._cache[self._job]
602 del cache[self._job]
[all …]
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | pool.py | 402 self._guarded_task_generation(result._job, func, iterable),
415 self._guarded_task_generation(result._job,
431 self._guarded_task_generation(result._job, func, iterable),
443 self._guarded_task_generation(result._job,
457 self._taskqueue.put(([(result._job, 0, func, args, kwds)], None))
489 self._guarded_task_generation(result._job,
747 self._job = next(job_counter)
751 self._cache[self._job] = self
780 del self._cache[self._job]
802 del self._cache[self._job]
[all …]
|
| /external/grpc-grpc/tools/run_tests/python_utils/ |
| D | dockerjob.py | 116 self._job = jobset.Job(
130 self._job.suppress_failure_message()
135 return self._job.state() == jobset._RUNNING
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/python_utils/ |
| D | dockerjob.py | 132 self._job = jobset.Job(spec,
151 self._job.suppress_failure_message()
156 return self._job.state() == jobset._RUNNING
|
| /external/grpc-grpc/tools/run_tests/ |
| D | run_performance_tests.py | 52 self._job = None
56 self._job = jobset.Job(
61 return self._job and self._job.state() == jobset._RUNNING
64 if self._job:
65 self._job.kill()
66 self._job = None
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/ |
| D | run_performance_tests.py | 57 self._job = None
61 self._job = jobset.Job(self._spec,
68 return self._job and self._job.state() == jobset._RUNNING
71 if self._job:
72 self._job.kill()
73 self._job = None
|
| /external/tensorflow/tensorflow/python/framework/ |
| D | device_spec.py | 124 self._job = _as_str_or_none(job)
130 job=self._job, replica=self._replica, task=self._task,
267 return self._job
408 self._job = _as_str_or_none(job)
|
| /external/mesa3d/src/intel/vulkan/tests/ |
| D | state_pool_no_free.c | 42 static void *alloc_states(void *_job) in alloc_states() argument
44 struct job *job = _job; in alloc_states()
|
| D | block_pool_no_free.c | 42 static void *alloc_blocks(void *_job) in alloc_blocks() argument
44 struct job *job = _job; in alloc_blocks()
|
| /external/autotest/client/bin/ |
| D | job.py | 84 self._job = weakref.proxy(job_) # avoid a circular reference
89 return self._job._record_indent
93 self._job._record_indent += 1
97 self._job._record_indent -= 1
|
| /external/toybox/toys/pending/ |
| D | crond.c | 44 typedef struct _job { struct
45 struct _job *next, *prev; argument
|
| /external/mesa3d/src/broadcom/vulkan/ |
| D | v3dv_private.h | 2022 #define v3dv_return_if_oom(_cmd_buffer, _job) do { \ argument
2026 const struct v3dv_job *__job = _job; \
|
| D | v3dv_queue.c | 303 event_wait_thread_func(void *_job) in event_wait_thread_func() argument
305 struct v3dv_job *job = (struct v3dv_job *) _job; in event_wait_thread_func()
|
| /external/autotest/server/ |
| D | server_job.py | 197 self._job = job
210 self._hook(self._job, entry)
|