/external/tensorflow/tensorflow/python/distribute/ |
D | multi_worker_util.py | 25 def normalize_cluster_spec(cluster_spec): argument 49 def _validate_cluster_spec(cluster_spec, task_type, task_id): argument 75 def is_chief(cluster_spec, task_type, task_id): argument 104 def worker_count(cluster_spec, task_type): argument 125 def id_in_cluster(cluster_spec, task_type, task_id): argument
|
D | distribute_coordinator.py | 95 def _get_num_workers(cluster_spec): argument 114 cluster_spec, argument 281 def cluster_spec(self): member in _WorkerContext 328 cluster_spec, argument 363 def _split_cluster_for_evaluator(cluster_spec, task_type): argument 382 def _run_std_server(cluster_spec=None, argument 452 cluster_spec, session_config, rpc_layer): argument 495 cluster_spec, session_config, rpc_layer): argument 527 strategy, eval_strategy, session_config, cluster_spec, task_type, task_id): argument 633 cluster_spec=None, argument
|
D | estimator_training.py | 40 def _count_ps(cluster_spec): argument 49 def _count_worker(cluster_spec, chief_task_type): argument 59 def _get_global_id(cluster_spec, task_type, task_id, chief_task_type): argument
|
D | distribute_coordinator_test.py | 107 cluster_spec=None, argument 248 cluster_spec, **kwargs): argument 392 cluster_spec=None, argument 769 def _thread_fn(cluster_spec): argument 793 def _run_mock_server(cluster_spec=None, argument 909 def _mock_run_std_server(cluster_spec=None, argument
|
D | collective_all_reduce_strategy.py | 355 cluster_spec=None, argument
|
D | mirrored_strategy.py | 316 def _cluster_spec_to_device_list(cluster_spec, num_gpus_per_worker): argument 669 cluster_spec=None, argument
|
D | parameter_server_strategy.py | 461 cluster_spec=None, argument
|
/external/tensorflow/tensorflow/contrib/learn/python/learn/estimators/ |
D | run_config.py | 169 def cluster_spec(self): member in ClusterConfig 411 def _count_ps(cluster_spec): argument 416 def _count_worker(cluster_spec): argument 434 def _get_master(cluster_spec, task_type, task_id): argument
|
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
D | grpc_tensorflow_server.cc | 41 Status FillServerDef(const string& cluster_spec, const string& job_name, in FillServerDef() 99 tensorflow::string cluster_spec; in main() local
|
/external/tensorflow/tensorflow/python/distribute/cluster_resolver/ |
D | cluster_resolver.py | 92 def cluster_spec(self): member in ClusterResolver 185 def __init__(self, cluster_spec, master='', task_type=None, task_id=None, argument 206 def cluster_spec(self): member in SimpleClusterResolver 329 def cluster_spec(self): member in UnionClusterResolver
|
D | cluster_resolver_test.py | 35 def cluster_spec(self): member in MockBaseClusterResolver 126 def _verifyClusterSpecEquality(self, cluster_spec, expected_proto): argument
|
D | kubernetes_cluster_resolver.py | 122 def cluster_spec(self): member in KubernetesClusterResolver
|
D | slurm_cluster_resolver_test.py | 35 def _verifyClusterSpecEquality(self, cluster_spec, expected_proto): argument
|
D | kubernetes_cluster_resolver_test.py | 53 def _verifyClusterSpecEquality(self, cluster_spec, expected_proto): argument
|
D | slurm_cluster_resolver.py | 129 def cluster_spec(self): member in SlurmClusterResolver
|
D | tfconfig_cluster_resolver_test.py | 36 def _verifyClusterSpecEquality(self, cluster_spec, expected_proto): argument
|
D | gce_cluster_resolver.py | 106 def cluster_spec(self): member in GCEClusterResolver
|
D | gce_cluster_resolver_test.py | 32 def _verifyClusterSpecEquality(self, cluster_spec, expected_proto): argument
|
D | tfconfig_cluster_resolver.py | 124 def cluster_spec(self): member in TFConfigClusterResolver
|
D | tpu_cluster_resolver.py | 386 def cluster_spec(self): member in TPUClusterResolver
|
D | tpu_cluster_resolver_test.py | 96 def _verifyClusterSpecEquality(self, cluster_spec, expected_proto): argument
|
/external/tensorflow/tensorflow/python/debug/lib/ |
D | grpc_tensorflow_server.py | 45 def parse_cluster_spec(cluster_spec, cluster, verbose=False): argument
|
/external/tensorflow/tensorflow/contrib/distribute/python/ |
D | multi_worker_test_base.py | 289 def _run_between_graph_clients(self, client_fn, cluster_spec, num_gpus, *args, argument 397 def _run_task_in_thread(self, task_fn, cluster_spec, task_type, task_id, argument 418 def run_multiple_tasks_in_threads(self, task_fn, cluster_spec, *args, argument
|
D | keras_multi_worker_test.py | 253 def _run_standalone_client(test_obj, strategy, cluster_spec): argument
|
D | collective_all_reduce_strategy_test.py | 71 def create_test_objects(cluster_spec=None, argument
|