| /aosp_15_r20/external/tensorflow/tensorflow/python/distribute/cluster_resolver/ |
| H A D | cluster_resolver.py | 111 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
132 task_id=None, argument
238 def task_id(self): member in ClusterResolver
283 def task_id(self, task_id): member in ClusterResolver
320 def __init__(self, cluster_spec, master='', task_type=None, task_id=None, argument
345 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
373 def task_id(self): member in SimpleClusterResolver
381 def task_id(self, task_id): member in SimpleClusterResolver
390 task_id=None, argument
569 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
[all …]
|
| H A D | tfconfig_cluster_resolver.py | 82 task_id=None, argument
110 def task_id(self): member in TFConfigClusterResolver
122 def task_id(self, task_id): member in TFConfigClusterResolver
142 task_id=None, argument
160 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
|
| H A D | sagemaker_cluster_resolver.py | 92 task_id=None, argument
120 def task_id(self): member in SageMakerClusterResolver
132 def task_id(self, task_id): member in SageMakerClusterResolver
150 def num_accelerators(self, task_type=None, task_id=None, config_proto=None): argument
167 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
|
| H A D | gce_cluster_resolver.py | 70 task_id=0, argument
170 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
188 def task_id(self): member in GCEClusterResolver
198 def task_id(self, task_id): member in GCEClusterResolver
|
| /aosp_15_r20/system/nfc/src/gki/ulinux/ |
| H A D | gki_ulinux.cc | 65 uint8_t task_id; /* GKI task id */ member
185 uint8_t GKI_create_task(TASKPTR task_entry, uint8_t task_id, int8_t* taskname, in GKI_create_task()
284 uint8_t task_id; in GKI_shutdown() local
539 uint8_t task_id; in GKI_stop() local
757 uint8_t GKI_send_event(uint8_t task_id, uint16_t event) { in GKI_send_event()
795 uint8_t GKI_isend_event(uint8_t task_id, uint16_t event) { in GKI_isend_event()
843 int8_t* GKI_map_taskname(uint8_t task_id) { in GKI_map_taskname()
912 uint8_t task_id; in GKI_exception() local
1055 uint8_t GKI_suspend_task(uint8_t task_id) { in GKI_suspend_task()
1078 uint8_t GKI_resume_task(uint8_t task_id) { in GKI_resume_task()
[all …]
|
| /aosp_15_r20/external/cronet/base/task/ |
| H A D | cancelable_task_tracker_unittest.cc | 73 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( in TEST_F() local
91 CancelableTaskTracker::TaskId task_id = in TEST_F() local
110 CancelableTaskTracker::TaskId task_id = in TEST_F() local
129 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTaskAndReply( in TEST_F() local
144 CancelableTaskTracker::TaskId task_id = in TEST_F() local
231 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( in TEST_F() local
336 CancelableTaskTracker::TaskId task_id = in TEST_F() local
360 CancelableTaskTracker::TaskId task_id = in TEST_F()
|
| H A 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()
|
| /aosp_15_r20/external/tensorflow/tensorflow/python/distribute/ |
| H A 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 …]
|
| H A D | parameter_server_strategy_test.py | 71 task_id=None, argument
111 def _get_test_objects(self, task_type, task_id, num_gpus): argument
119 def _test_device_assignment_distributed(self, task_type, task_id, num_gpus): argument
219 self, task_type, task_id, num_gpus): argument
368 def _test_simple_increment(self, task_type, task_id, num_gpus): argument
432 def _test_minimize_loss_graph(self, task_type, task_id, num_gpus): argument
520 task_id, argument
|
| H A D | multi_worker_util.py | 54 task_id): argument
108 def is_chief(cluster_spec=None, task_type=None, task_id=None): argument
148 def collective_leader(cluster_spec, task_type, task_id): argument
228 def id_in_cluster(cluster_spec, task_type, task_id): argument
|
| H A D | distribute_coordinator.py | 112 task_id, argument
287 def task_id(self): member in _WorkerContext
326 task_id, argument
383 task_id=None, argument
526 strategy, eval_strategy, session_config, cluster_spec, task_type, task_id): argument
634 task_id=None, argument
|
| H A D | collective_all_reduce_strategy_test.py | 73 task_id=None, argument
112 task_id, argument
138 def _test_minimize_loss_graph(self, task_type, task_id, num_gpus): argument
211 def _test_variable_initialization(self, task_type, task_id, num_gpus): argument
240 task_id, argument
369 def _worker_fn(task_type, task_id, required_gpus): argument
|
| H A D | multi_worker_test_base.py | 286 def kill_task(self, task_type, task_id): argument
301 def start_task(self, task_type, task_id): argument
511 def _run_client(self, client_fn, task_type, task_id, num_gpus, eager_mode, argument
672 def _run_task_in_thread(self, task_fn, cluster_spec, task_type, task_id, argument
734 def _run_task_in_process(self, cmd_args, cluster_spec, task_type, task_id): argument
|
| H A D | distribute_coordinator_test.py | 101 task_id=None): argument
399 task_id=None, argument
789 task_id=None, argument
905 task_id=None, argument
|
| /aosp_15_r20/external/libchrome/base/task/ |
| H A 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
|
| /aosp_15_r20/external/libbrillo/brillo/message_loops/ |
| H A 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()
|
| H A 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()
|
| /aosp_15_r20/external/tensorflow/tensorflow/python/keras/distribute/ |
| H A D | distribute_coordinator_utils.py | 77 task_id, argument
252 def task_id(self): member in _WorkerContext
291 task_id, argument
347 task_id=None, argument
416 task_type, task_id): argument
450 task_id=None, argument
|
| /aosp_15_r20/external/bcc/libbpf-tools/ |
| H A D | klockstat.bpf.c | 31 u64 task_id; member
37 u64 task_id; member
72 static bool tracing_task(u64 task_id) in tracing_task()
86 u64 task_id; in lock_contended() local
122 u64 task_id; in lock_aborted() local
137 u64 task_id; in lock_acquired() local
216 u64 task_id; in lock_released() local
|
| /aosp_15_r20/external/tensorflow/tensorflow/core/data/service/ |
| H A D | journal.proto | 102 int64 task_id = 1; field
122 int64 task_id = 1; field
134 int64 task_id = 1; field
144 int64 task_id = 1; field
|
| H A D | dispatcher_state_test.cc | 134 Status CreateTask(int64_t task_id, int64_t iteration_id, in CreateTask()
144 Status FinishTask(int64_t task_id, DispatcherState& state) { in FinishTask()
425 int64_t task_id = state.NextAvailableTaskId(); in TEST() local
440 int64_t task_id = state.NextAvailableTaskId(); in TEST() local
564 int64_t task_id = 4; in TEST() local
|
| H A D | dispatcher_state.cc | 253 int64_t task_id = create_pending_task.task_id(); in CreatePendingTask() local
288 int64_t task_id = create_task.task_id(); in CreateTask() local
301 int64_t task_id = finish_task.task_id(); in FinishTask() local
|
| /aosp_15_r20/system/nfc/src/gki/common/ |
| H A D | gki_buffer.cc | 597 void GKI_send_msg(uint8_t task_id, uint8_t mbox, void* msg) { in GKI_send_msg()
656 uint8_t task_id = GKI_get_taskid(); in GKI_read_mbox() local
1121 void GKI_change_buf_owner(void* p_buf, uint8_t task_id) { in GKI_change_buf_owner()
1139 void GKI_isend_msg(uint8_t task_id, uint8_t mbox, void* msg) { in GKI_isend_msg()
|
| H A D | gki_time.cc | 187 uint8_t task_id = GKI_get_taskid(); in GKI_start_timer() local
291 uint8_t task_id = GKI_get_taskid(); in GKI_stop_timer() local
367 uint8_t task_id; in GKI_timer_update() local
|
| /aosp_15_r20/external/libchrome/base/ |
| H A 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()
|