| /third_party/grpc/src/ruby/end2end/ |
| D | sig_int_during_channel_watch_client.rb | 25 server_port = ''
31 server_port = p
41 "localhost:#{server_port}", :this_channel_is_insecure)
49 child_thread_channel = GRPC::Core::Channel.new("localhost:#{server_port}",
58 main_channel = GRPC::Core::Channel.new("localhost:#{server_port}",
|
| D | call_credentials_returning_bad_metadata_doesnt_kill_background_thread_test.rb | 67 server_port = server_runner.run
109 "localhost:#{server_port}",
113 "localhost:#{server_port}",
117 "localhost:#{server_port}",
121 "localhost:#{server_port}",
125 "localhost:#{server_port}",
|
| D | call_credentials_returning_bad_metadata_doesnt_kill_background_thread_driver.rb | 76 server_port = server_runner.run
118 "localhost:#{server_port}",
122 "localhost:#{server_port}",
126 "localhost:#{server_port}",
130 "localhost:#{server_port}",
134 "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 | graceful_sig_handling_client.rb | 34 server_port = ''
40 server_port = p
48 stub = Echo::EchoServer::Stub.new("localhost:#{server_port}",
|
| D | graceful_sig_stop_client.rb | 49 server_port = ''
55 server_port = p
64 stub = Echo::EchoServer::Stub.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 | client_memory_usage_test.rb | 22 server_port = server_runner.run
24 _, client_pid = start_client('client_memory_usage_client.rb', server_port)
|
| /third_party/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 …]
|
| /third_party/mbedtls/programs/test/ |
| D | udp_proxy_wrapper.sh | 78 server_port=*) server_port_orig="${param#*=}";;
106 server_port=$(( server_port_orig + 1 ))
107 set -- "$@" "server_port=$server_port"
108 echo " * Intermediate port: $server_port"
|
| /third_party/libuv/test/ |
| D | test-getsockname.c | 29 static const int server_port = TEST_PORT; variable
133 check_sockname(&sockname, "127.0.0.1", server_port, "accepted socket"); in on_connection()
162 check_sockname(&peername, "127.0.0.1", server_port, "connected socket peer"); in on_connect()
175 ASSERT(0 == uv_ip4_addr("0.0.0.0", server_port, &addr)); in tcp_listener()
199 check_sockname(&sockname, "0.0.0.0", server_port, "server socket"); in tcp_listener()
216 ASSERT(0 == uv_ip4_addr("127.0.0.1", server_port, &server_addr)); in tcp_connector()
277 ASSERT(0 == uv_ip4_addr("0.0.0.0", server_port, &addr)); in udp_listener()
295 check_sockname(&sockname, "0.0.0.0", server_port, "udp listener socket"); in udp_listener()
314 ASSERT(0 == uv_ip4_addr("127.0.0.1", server_port, &server_addr)); in udp_sender()
|
| /third_party/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))
|
| /third_party/flutter/engine/flutter/runtime/ |
| D | dart_service_isolate.cc | 127 intptr_t server_port, in Startup() argument
176 bool auto_start = server_port >= 0; in Startup()
177 if (server_port < 0) { in Startup()
180 server_port = 0; in Startup()
184 Dart_NewInteger(server_port)); in Startup()
|
| /third_party/grpc/src/python/grpcio_tests/tests/qps/ |
| D | qps_worker.py | 27 def run_worker_server(driver_port, server_port): argument
29 servicer = worker_server.WorkerServer(server_port)
56 run_worker_server(args.driver_port, args.server_port)
|
| D | worker_server.py | 38 def __init__(self, server_port=None): argument
40 self._server_port = server_port
96 server_port = self._server_port
98 server_port = config.port
103 port = server.add_secure_port('[::]:{}'.format(server_port),
106 port = server.add_insecure_port('[::]:{}'.format(server_port))
|
| /third_party/mindspore/tests/ut/python/dataset/ |
| D | test_graphdata_distributed.py | 29 def graphdata_startserver(server_port): argument
34 ds.GraphData(DATASET_FILE, 1, 'server', port=server_port)
94 server_port = random.randint(10000, 60000)
96 p1 = Process(target=graphdata_startserver, args=(server_port,))
100 g = ds.GraphData(DATASET_FILE, 1, 'client', port=server_port)
|
| /third_party/gstreamer/gstplugins_base/gst/tcp/ |
| D | gsttcpserversink.c | 131 this->server_port = TCP_DEFAULT_PORT; in gst_tcp_server_sink_init()
260 sink->server_port = g_value_get_int (value); in gst_tcp_server_sink_set_property()
281 g_value_set_int (value, sink->server_port); in gst_tcp_server_sink_get_property()
313 tcp_create_socket (GST_ELEMENT (this), &cur_addr, this->server_port, in gst_tcp_server_sink_init_send()
340 if (this->server_port == 0) { in gst_tcp_server_sink_init_send()
345 bound_port = this->server_port; in gst_tcp_server_sink_init_send()
390 ("Failed to bind on host '%s:%d': %s", this->host, this->server_port, in gst_tcp_server_sink_init_send()
405 this->server_port, err->message)); in gst_tcp_server_sink_init_send()
|
| /third_party/ltp/testcases/kernel/syscalls/accept/ |
| D | accept02.c | 36 static int server_port; variable
97 server_addr->sin_port = server_port; in run()
129 server_port = TST_GET_UNUSED_PORT(AF_INET, SOCK_STREAM); in setup()
130 tst_res(TINFO, "Starting listener on port: %d", ntohs(server_port)); in setup()
|
| /third_party/grpc/test/cpp/qps/ |
| D | qps_worker.cc | 105 WorkerServiceImpl(int server_port, QpsWorker* worker) in WorkerServiceImpl() argument
106 : acquired_(false), server_port_(server_port), worker_(worker) {} in WorkerServiceImpl()
277 QpsWorker::QpsWorker(int driver_port, int server_port, in QpsWorker() argument
279 impl_.reset(new WorkerServiceImpl(server_port, this)); in QpsWorker()
296 driver_port, server_port); in QpsWorker()
300 driver_port, server_port); in QpsWorker()
|
| /third_party/gstreamer/gstplugins_base/gst-libs/gst/rtsp/ |
| D | gstrtsptransport.c | 198 transport->server_port.min = -1; in gst_rtsp_transport_init()
199 transport->server_port.max = -1; in gst_rtsp_transport_init()
556 if (parse_range (split[i] + 12, &transport->server_port)) { in gst_rtsp_transport_parse()
557 if (!IS_VALID_PORT_RANGE (transport->server_port)) in gst_rtsp_transport_parse()
714 && transport->server_port.min >= 0) { in gst_rtsp_transport_as_text()
715 if (transport->server_port.min < 65536 in gst_rtsp_transport_as_text()
716 && transport->server_port.max < 65536) { in gst_rtsp_transport_as_text()
718 if (transport->server_port.max > 0) in gst_rtsp_transport_as_text()
719 g_ptr_array_add (strs, range_as_text (&transport->server_port)); in gst_rtsp_transport_as_text()
722 transport->server_port.min)); in gst_rtsp_transport_as_text()
|