| /external/tensorflow/tensorflow/python/distribute/cluster_resolver/ |
| 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 …]
|
| 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
|
| 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): argument
|
| 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
|
| D | slurm_cluster_resolver.py | 369 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
393 task_id=None, argument
|
| /external/cronet/base/task/ |
| 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
150 CancelableTaskTracker::TaskId task_id = in TEST_F() local
235 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( in TEST_F() local
333 void TryCancel(CancelableTaskTracker::TaskId task_id, in TryCancel()
345 CancelableTaskTracker::TaskId task_id = in TEST_F() local
364 CancelableTaskTracker::TaskId task_id = in TEST_F() local
|
| 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/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()
|
| /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/tensorflow/tensorflow/python/distribute/ |
| 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
|
| 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 | 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
|
| 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
|
| 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
|
| 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
|
| /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/tensorflow/tensorflow/python/keras/distribute/ |
| 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
|
| /external/tensorflow/tensorflow/core/data/service/ |
| 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
|
| D | common.proto | 30 int64 task_id = 4; field
64 int64 task_id = 2; field
|
| /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/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | bounded_executor_test.cc | 35 std::function<void()> MakeTask(int task_id, absl::Duration sleep_duration) { in MakeTask()
41 void Run(int task_id, absl::Duration sleep_duration) { in Run()
|
| /external/autotest/client/site_tests/platform_PrinterPpds/ |
| D | test_multithreaded_processor.py | 36 def _thread(self, task_id): argument
|
| /external/cronet/testing/merge_scripts/ |
| D | standard_isolated_script_merge.py | 69 def find_shard_output_path(index, task_id, jsons_to_merge): argument
|