| /external/tensorflow/tensorflow/python/distribute/cluster_resolver/ |
| D | cluster_resolver.py | 115 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
136 task_id=None, argument
242 def task_id(self): member in ClusterResolver
287 def task_id(self, task_id): member in ClusterResolver
324 def __init__(self, cluster_spec, master='', task_type=None, task_id=None, argument
349 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
377 def task_id(self): member in SimpleClusterResolver
385 def task_id(self, task_id): member in SimpleClusterResolver
394 task_id=None, argument
573 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
[all …]
|
| D | tfconfig_cluster_resolver.py | 86 task_id=None, argument
114 def task_id(self): member in TFConfigClusterResolver
126 def task_id(self, task_id): member in TFConfigClusterResolver
146 task_id=None, argument
164 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
|
| D | gce_cluster_resolver.py | 74 task_id=0, argument
174 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
192 def task_id(self): member in GCEClusterResolver
202 def task_id(self, task_id): member in GCEClusterResolver
|
| D | sagemaker_cluster_resolver.py | 96 task_id=None, argument
124 def task_id(self): member in SageMakerClusterResolver
136 def task_id(self, task_id): argument
154 def num_accelerators(self, task_type=None, task_id=None, config_proto=None): argument
171 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
|
| D | slurm_cluster_resolver.py | 373 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
397 task_id=None, argument
|
| /external/libbrillo/brillo/message_loops/ |
| D | message_loop_test.cc | 84 TaskId task_id = in TYPED_TEST() local
94 TaskId task_id = in TYPED_TEST() local
105 TaskId task_id = in TYPED_TEST() local
127 TaskId task_id; in TYPED_TEST() local
131 [](bool* cancel_result, MessageLoop* loop, TaskId* task_id) { in TYPED_TEST()
|
| D | base_message_loop.cc | 84 TaskId task_id = NextTaskId(); in PostDelayedTask() local
100 bool BaseMessageLoop::CancelTask(TaskId task_id) { in CancelTask()
172 void BaseMessageLoop::OnRanPostedTask(MessageLoop::TaskId task_id) { in OnRanPostedTask()
|
| D | message_loop_utils.cc | 16 MessageLoop::TaskId task_id = loop->PostDelayedTask( in MessageLoopRunUntil() local
|
| /external/tensorflow/tensorflow/python/distribute/ |
| D | multi_worker_util.py | 58 task_id): argument
112 def is_chief(cluster_spec=None, task_type=None, task_id=None): argument
152 def collective_leader(cluster_spec, task_type, task_id): argument
207 def id_in_cluster(cluster_spec, task_type, task_id): argument
|
| D | multi_process_runner.py | 255 def _continuously_readline_from_sub(self, pipe_r, task_type, task_id): argument
270 task_id, argument
419 task_id, argument
477 def get_process_id(self, task_type, task_id): argument
483 def get_process_exit_code(self, task_type, task_id): argument
501 def process_exists(self, task_type, task_id): argument
680 def terminate(self, task_type, task_id): argument
770 def _message_checking_func(self, task_type, task_id): argument
1010 def _pool_runner_worker(task_type, task_id, initializer, conn): argument
1039 def _run_contained(task_type, task_id, fn, args, kwargs): argument
[all …]
|
| D | parameter_server_strategy_test.py | 75 task_id=None, argument
115 def _get_test_objects(self, task_type, task_id, num_gpus): argument
123 def _test_device_assignment_distributed(self, task_type, task_id, num_gpus): argument
223 self, task_type, task_id, num_gpus): argument
372 def _test_simple_increment(self, task_type, task_id, num_gpus): argument
436 def _test_minimize_loss_graph(self, task_type, task_id, num_gpus): argument
524 task_id, argument
|
| D | collective_all_reduce_strategy_test.py | 72 task_id=None, argument
106 def _get_test_object(self, task_type, task_id, num_gpus=0): argument
114 def _test_minimize_loss_graph(self, task_type, task_id, num_gpus): argument
186 def _test_variable_initialization(self, task_type, task_id, num_gpus): argument
216 task_id, argument
349 def _worker_fn(task_type, task_id, required_gpus): argument
|
| D | distribute_coordinator.py | 116 task_id, argument
291 def task_id(self): member in _WorkerContext
330 task_id, argument
387 task_id=None, argument
530 strategy, eval_strategy, session_config, cluster_spec, task_type, task_id): argument
638 task_id=None, argument
|
| D | multi_worker_test_base.py | 318 def kill_task(self, task_type, task_id): argument
333 def start_task(self, task_type, task_id): argument
544 def _run_client(self, client_fn, task_type, task_id, num_gpus, eager_mode, argument
705 def _run_task_in_thread(self, task_fn, cluster_spec, task_type, task_id, argument
767 def _run_task_in_process(self, cmd_args, cluster_spec, task_type, task_id): argument
|
| /external/bcc/libbpf-tools/ |
| D | klockstat.bpf.c | 30 u64 task_id; member
36 u64 task_id; member
63 static bool tracing_task(u64 task_id) in tracing_task()
77 u64 task_id; in lock_contended() local
112 u64 task_id; in lock_aborted() local
127 u64 task_id; in lock_acquired() local
193 u64 task_id; in lock_released() local
|
| /external/libchrome/base/task/ |
| D | cancelable_task_tracker_unittest.cc | 112 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( in TEST_F() local
130 CancelableTaskTracker::TaskId task_id = in TEST_F() local
149 CancelableTaskTracker::TaskId task_id = in TEST_F() local
168 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTaskAndReply( in TEST_F() local
189 CancelableTaskTracker::TaskId task_id = in TEST_F() local
360 void TryCancel(CancelableTaskTracker::TaskId task_id, in TryCancel()
372 CancelableTaskTracker::TaskId task_id = in TEST_F() local
391 CancelableTaskTracker::TaskId task_id = in TEST_F() local
|
| /external/uwb/src/gki/ulinux/ |
| D | uwb_gki_ulinux.cc | 61 uint8_t task_id; /* GKI task id */ member
155 uint8_t phUwb_GKI_create_task(TASKPTR task_entry, uint8_t task_id, in phUwb_GKI_create_task()
248 uint8_t task_id; in phUwb_GKI_shutdown() local
554 uint8_t phUwb_GKI_send_event(uint8_t task_id, uint16_t event) { in phUwb_GKI_send_event()
592 uint8_t phUwb_GKI_isend_event(uint8_t task_id, uint16_t event) { in phUwb_GKI_isend_event()
671 uint8_t task_id; in phUwb_GKI_exception() local
744 void phUwb_GKI_exit_task(uint8_t task_id) { in phUwb_GKI_exit_task()
|
| /external/tensorflow/tensorflow/python/keras/distribute/ |
| D | distribute_coordinator_utils.py | 81 task_id, argument
256 def task_id(self): member in _WorkerContext
295 task_id, argument
351 task_id=None, argument
420 task_type, task_id): argument
454 task_id=None, argument
|
| /external/tensorflow/tensorflow/core/data/service/ |
| D | journal.proto | 96 int64 task_id = 1; field
116 int64 task_id = 1; field
126 int64 task_id = 1; field
134 int64 task_id = 1; field
|
| D | common.proto | 24 int64 task_id = 4; field
51 int64 task_id = 2; field
|
| /external/uwb/src/gki/common/ |
| D | uwb_gki_time.cc | 167 uint8_t task_id = phUwb_GKI_get_taskid(); in phUwb_GKI_start_timer() local
265 uint8_t task_id = phUwb_GKI_get_taskid(); in phUwb_GKI_stop_timer() local
340 uint8_t task_id; in phUwb_GKI_timer_update() local
|
| /external/tensorflow/tensorflow/lite/delegates/gpu/common/memory_management/ |
| D | greedy_by_breadth_assignment.cc | 37 TaskId task_id; member
57 for (size_t task_id = 0; task_id < task_profiles.size(); ++task_id) { in GreedyByBreadthAssignment() local
|
| /external/libchrome/base/ |
| D | deferred_sequenced_task_runner_unittest.cc | 28 int task_id) in ExecuteTaskOnDestructor()
39 void ExecuteTask(int task_id) { in ExecuteTask()
44 void PostExecuteTask(int task_id) { in PostExecuteTask()
|
| /external/autotest/client/site_tests/platform_PrinterPpds/ |
| D | test_multithreaded_processor.py | 33 def _thread(self, task_id): argument
|
| /external/tensorflow/tensorflow/python/distribute/cluster_resolver/tpu/ |
| D | tpu_cluster_resolver.py | 230 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
346 task_id=None, argument
|