| /external/grpc-grpc/src/ruby/spec/generic/ |
| D | client_stub_spec.rb | 173 server_port = create_test_server
175 stub = GRPC::ClientStub.new("localhost:#{server_port}",
182 server_port = create_test_server
183 host = "localhost:#{server_port}"
218 server_port = create_test_server
219 alt_host = "localhost:#{server_port}"
230 server_port = create_test_server
231 host = "localhost:#{server_port}"
240 server_port = create_secure_test_server
259 stub = GRPC::ClientStub.new("localhost:#{server_port}",
[all …]
|
| /external/grpc-grpc/src/ruby/end2end/ |
| D | sig_int_during_channel_watch_client.rb | 24 server_port = ''
30 server_port = p
37 child_thread_channel = GRPC::Core::Channel.new("localhost:#{server_port}",
46 main_channel = GRPC::Core::Channel.new("localhost:#{server_port}",
|
| D | killed_client_thread_client.rb | 23 server_port = ''
29 server_port = p
34 stub = Echo::EchoServer::Stub.new("localhost:#{server_port}",
|
| D | channel_state_client.rb | 20 server_port = ''
26 server_port = p
30 ch = GRPC::Core::Channel.new("localhost:#{server_port}", {},
|
| D | client_memory_usage_client.rb | 21 server_port = ''
29 server_port = p
34 stub = Echo::EchoServer::Stub.new("localhost:#{server_port}", :this_channel_is_insecure)
|
| D | forking_client_client.rb | 22 server_port = ''
28 server_port = p
33 stub = Echo::EchoServer::Stub.new("localhost:#{server_port}",
|
| D | channel_closing_client.rb | 34 server_port = ''
40 server_port = p
44 ch = GRPC::Core::Channel.new("localhost:#{server_port}", {},
|
| D | sig_handling_client.rb | 49 server_port = ''
55 server_port = p
72 stub = Echo::EchoServer::Stub.new("localhost:#{server_port}",
|
| D | client_memory_usage_driver.rb | 22 server_port = server_runner.run
24 _, client_pid = start_client('client_memory_usage_client.rb', server_port)
|
| D | channel_state_driver.rb | 24 server_port = server_runner.run
26 _, client_pid = start_client('channel_state_client.rb', server_port)
|
| D | forking_client_driver.rb | 22 server_port = server_runner.run
25 server_port)
|
| D | sig_int_during_channel_watch_driver.rb | 25 server_port = server_runner.run
28 server_port)
|
| D | channel_closing_driver.rb | 25 server_port = server_runner.run
28 server_port)
|
| D | sig_handling_driver.rb | 51 server_port = server_runner.run
53 control_stub, client_pid = start_client('sig_handling_client.rb', server_port)
|
| D | killed_client_thread_driver.rb | 53 server_port = server_runner.run
56 server_port)
|
| /external/grpc-grpc/test/http2_test/ |
| D | http2_server_health_check.py | 27 server_port = args.server_port variable
28 conn = hyper.HTTP20Connection('%s:%d' % (server_host, server_port))
|
| /external/v8/tools/ |
| D | adb-d8.py | 97 def AdbForwardDeviceToLocal(adb, device_port, server_port, verbose): argument
100 device_port, server_port))
105 "tcp:{}".format(server_port)
225 server_ip, server_port = server.server_address
227 AdbForwardDeviceToLocal(adb, device_port, server_port, verbose)
|
| /external/grpc-grpc/test/core/end2end/fixtures/ |
| D | proxy.cc | 35 server_port(nullptr), in grpc_end2end_proxy()
46 char* server_port; member
91 int server_port = grpc_pick_unused_port_or_die(); in grpc_end2end_proxy_create() local
96 gpr_join_host_port(&proxy->server_port, "localhost", server_port); in grpc_end2end_proxy_create()
99 proxy->server_port); in grpc_end2end_proxy_create()
103 proxy->client = def->create_client(proxy->server_port, client_args); in grpc_end2end_proxy_create()
135 gpr_free(proxy->server_port); in grpc_end2end_proxy_destroy()
448 return proxy->server_port; in grpc_end2end_proxy_get_server_port()
|
| /external/tensorflow/tensorflow/python/debug/lib/ |
| D | grpc_debug_test_server.py | 220 def __init__(self, server_port, dump_dir, toggle_watch_on_core_metadata=None): argument
238 self, server_port,
398 server_port = portpicker.pick_unused_port()
399 debug_server_url = "grpc://localhost:%d" % server_port
403 server_port=server_port,
423 "Failed to start test gRPC debug server at port %d" % server_port)
425 return server_port, debug_server_url, server_dump_dir, server_thread, server
|
| /external/grpc-grpc/tools/run_tests/ |
| D | run_interop_tests.py | 835 server_port, argument
866 '--server_port=%s' % server_port,
1390 (server_host, server_port) = server[1].split(':')
1391 server_addresses[server_name] = (server_host, server_port)
1394 (server_host, server_port) = server_address
1408 server_port,
1424 server_port,
1437 server_port = _DEFAULT_SERVER_PORT + offset variable
1439 server_port = http2_server_job.mapped_port(server_port) variable
1445 server_port,
[all …]
|
| /external/grpc-grpc/src/php/tests/interop/ |
| D | metrics_client.php | 23 $server_port = (count($parts) == 2) ? $parts[1] : ''; variable
26 if (@!socket_connect($socket, $server_host, $server_port)) {
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/http2/ |
| D | negative_http2_client.py | 146 def _stub(server_host, server_port): argument
147 target = '{}:{}'.format(server_host, server_port)
155 stub = _stub(args.server_host, args.server_port)
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | qps_worker.cc | 101 WorkerServiceImpl(int server_port, QpsWorker* worker) in WorkerServiceImpl() argument
102 : acquired_(false), server_port_(server_port), worker_(worker) {} in WorkerServiceImpl()
271 QpsWorker::QpsWorker(int driver_port, int server_port, in QpsWorker() argument
273 impl_.reset(new WorkerServiceImpl(server_port, this)); in QpsWorker()
|
| /external/ltp/testcases/network/stress/udp/uni-basic/ |
| D | udp4-uni-basic01 | 275 server_port=`find_portbundle udp 1025 1`
283 ns-udpserver -b -f $IP_VER -p $server_port -o $info_file
301 …OST ${LTPROOT}/testcases/bin/ns-udpclient -b -f $IP_VER -S $lhost_addr -p $server_port' ; echo $?'`
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | http_proxy.cc | 130 char* server_port; in proxy_mapper_map_name() local
132 &server_host, &server_port)) { in proxy_mapper_map_name()
161 gpr_free(server_port); in proxy_mapper_map_name()
|