/external/grpc-grpc/test/core/iomgr/ |
D | pollset_set_test.cc | 209 const int num_ps = GPR_ARRAY_SIZE(pollsets); in pollset_set_test_basic() local 213 init_test_pollsets(pollsets, num_ps); in pollset_set_test_basic() 251 for (int i = 0; i < num_ps; i++) { in pollset_set_test_basic() 282 cleanup_test_pollsets(pollsets, num_ps); in pollset_set_test_basic() 311 const int num_ps = 1; in pollset_set_test_dup_fds() local 315 init_test_pollsets(&pollset, num_ps); in pollset_set_test_dup_fds() 354 cleanup_test_pollsets(&pollset, num_ps); in pollset_set_test_dup_fds() 381 const int num_ps = GPR_ARRAY_SIZE(pollsets); in pollset_set_test_empty_pollset() local 385 init_test_pollsets(pollsets, num_ps); in pollset_set_test_empty_pollset() 418 cleanup_test_pollsets(pollsets, num_ps); in pollset_set_test_empty_pollset()
|
/external/tensorflow/tensorflow/python/distribute/ |
D | multi_worker_test_base.py | 89 num_ps, argument 103 ps_ports = [pick_unused_port() for _ in range(num_ps)] 108 if num_ps > 0: 126 for i in range(num_ps): 157 num_ps, argument 201 num_ps=num_ps, 354 num_ps, argument 361 num_ps=num_ps, 375 num_ps=0, argument 428 if num_ps: [all …]
|
D | parameter_server_strategy_v2_test.py | 51 num_workers=2, num_ps=3) 150 num_workers=2, num_ps=2) 430 num_ps=1, 443 num_workers=1, num_ps=1, worker_name="some_arbitrary_name") 454 num_workers=1, num_ps=1, ps_name="some_arbitrary_name") 465 num_workers=1, num_ps=1) 476 num_workers=1, num_ps=1) 490 num_workers=0, num_ps=1) 502 num_workers=1, num_ps=0)
|
D | distribute_coordinator_test.py | 172 NUM_WORKERS, num_ps=NUM_PS) 200 num_ps=0, argument 213 if num_ps: 215 "localhost:%s" % portpicker.pick_unused_port() for _ in range(num_ps) 610 num_workers=NUM_WORKERS, num_ps=NUM_PS) 624 num_workers=NUM_WORKERS, num_ps=NUM_PS)
|
D | multi_worker_test_base_test.py | 33 num_workers=2, num_ps=1, has_chief=True, rpc_layer="grpc")
|
D | device_util_test.py | 86 has_chief=False, num_workers=1, num_ps=0, has_eval=False))
|
D | multi_process_runner_test.py | 84 num_workers=2, num_ps=3, has_chief=True)) 97 multi_worker_test_base.create_cluster_spec(num_workers=1, num_ps=1), 213 has_chief=True, num_workers=2, num_ps=2),
|
D | collective_all_reduce_strategy_test.py | 269 num_workers=3, num_ps=0) 411 num_workers=3, num_ps=0, has_chief=True)
|
D | parameter_server_strategy_test.py | 577 num_workers=3, num_ps=2) 745 num_workers=3, num_ps=2) 828 num_workers=3, num_ps=2, has_chief=True)
|
D | strategy_combinations.py | 192 num_ps=0,
|
D | combinations.py | 522 num_ps=0,
|
/external/tensorflow/tensorflow/python/training/ |
D | sync_replicas_optimizer_test.py | 97 num_ps = 2 98 workers, _ = create_local_cluster(num_workers=num_workers, num_ps=num_ps) 189 num_ps = 2 190 workers, _ = create_local_cluster(num_workers=num_workers, num_ps=num_ps)
|
D | localhost_cluster_performance_test.py | 40 workers, _ = test.create_local_cluster(num_workers=2, num_ps=2) 67 test.create_local_cluster(num_workers=1, num_ps=10) 83 workers, _ = test.create_local_cluster(num_workers=1, num_ps=100)
|
/external/tensorflow/tensorflow/python/keras/distribute/ |
D | parameter_server_training_test.py | 65 def make_cluster(num_workers, num_ps): argument 67 num_workers=num_workers, num_ps=num_ps, rpc_layer="grpc") 74 def make_coordinator(num_workers, num_ps): argument 77 make_cluster(num_workers, num_ps))) 86 cls.coordinator = make_coordinator(num_workers=3, num_ps=2)
|
/external/tensorflow/tensorflow/python/distribute/coordinator/ |
D | fault_tolerance_test.py | 104 def setUp(self, num_workers, num_ps): argument 113 num_workers=num_workers, num_ps=num_ps, rpc_layer="grpc") 129 self.num_ps = num_ps 503 for i in range(self.num_ps):
|
D | cluster_coordinator_test.py | 431 def make_coordinator(num_workers, num_ps): argument 434 num_workers=num_workers, num_ps=num_ps, rpc_layer='grpc') 450 cls.coordinator = make_coordinator(num_workers=3, num_ps=2) 738 cls.coordinator = make_coordinator(num_workers=3, num_ps=2) 755 cls.coordinator = make_coordinator(num_workers=3, num_ps=2) 770 cls.coordinator = make_coordinator(num_workers=3, num_ps=2) 889 cls.coordinator = make_coordinator(num_workers=3, num_ps=2) 901 cls.coordinator = make_coordinator(num_workers=1, num_ps=1)
|
D | metric_utils_test.py | 43 num_workers=1, num_ps=1, rpc_layer=self.get_rpc_layer())
|
/external/tensorflow/tensorflow/tools/api/golden/v2/ |
D | tensorflow.__internal__.distribute.multi_process_runner.pbtxt | 17 …argspec: "args=[\'has_chief\', \'num_workers\', \'num_ps\', \'has_eval\'], varargs=None, keywords=…
|
D | tensorflow.test.pbtxt | 25 …argspec: "args=[\'num_workers\', \'num_ps\', \'protocol\', \'worker_config\', \'ps_config\'], vara…
|
/external/tensorflow/tensorflow/python/keras/utils/ |
D | dataset_creator_test.py | 54 num_workers=2, num_ps=1, rpc_layer="grpc")
|
/external/tensorflow/tensorflow/tools/api/golden/v1/ |
D | tensorflow.test.pbtxt | 37 …argspec: "args=[\'num_workers\', \'num_ps\', \'protocol\', \'worker_config\', \'ps_config\'], vara…
|
/external/tensorflow/tensorflow/python/kernel_tests/ |
D | list_ops_test.py | 833 worker = test_util.create_local_cluster(num_workers=1, num_ps=1)[0][0] 847 worker = test_util.create_local_cluster(num_workers=1, num_ps=1)[0][0] 862 worker = test_util.create_local_cluster(num_workers=1, num_ps=1)[0][0] 876 worker = test_util.create_local_cluster(num_workers=1, num_ps=1)[0][0]
|
/external/tensorflow/tensorflow/python/distribute/integration_test/ |
D | saved_model_test.py | 497 num_workers=2, num_ps=2)
|
/external/tensorflow/tensorflow/python/framework/ |
D | test_util.py | 3289 num_ps, argument 3347 ps_ports = [portpicker.pick_unused_port() for _ in range(num_ps)] 3370 start=True) for ix in range(num_ps)
|
/external/tensorflow/tensorflow/python/eager/ |
D | remote_test.py | 569 workers, ps = test_util.create_local_cluster(num_workers=2, num_ps=2)
|