| /external/grpc-grpc/src/ruby/spec/ |
| D | client_server_spec.rb | 71 server_thread = Thread.new do
86 server_thread.join
109 server_thread = Thread.new do
124 server_thread.join
154 server_thread = Thread.new do
169 server_thread.join
197 server_thread = Thread.new do
213 server_thread.join
232 server_thread = Thread.new do
246 server_thread.join
[all …]
|
| /external/grpc-grpc/src/ruby/end2end/ |
| D | sig_handling_client.rb | 76 server_thread = Thread.new do
82 server_thread.join
|
| /external/tensorflow/tensorflow/python/debug/lib/ |
| D | session_debug_grpc_test.py | 51 (_, _, _, server_thread,
62 server_thread.join()
65 (_, _, _, server_thread,
69 server_thread.join()
75 (_, _, _, server_thread,
79 server_thread.join()
85 (_, _, _, server_thread,
90 server_thread.join()
447 (_, debug_server_url, _, server_thread,
452 self._servers_and_threads.append((server, server_thread))
[all …]
|
| D | grpc_debug_test_server.py | 411 server_thread = threading.Thread(target=delay_then_run_server)
412 server_thread.start()
425 return server_port, debug_server_url, server_dump_dir, server_thread, server
|
| D | source_remote_test.py | 187 (_, _, _, server_thread,
195 server_thread.join()
|
| /external/grpc-grpc/test/core/surface/ |
| D | sequential_connectivity_test.cc | 70 grpc_core::Thread server_thread("grpc_server", server_thread_func, &sta); in run_test() local
71 server_thread.Start(); in run_test()
96 server_thread.Join(); in run_test()
|
| D | concurrent_connectivity_test.cc | 96 void server_thread(void* vargs) { in server_thread() function
199 grpc_core::Thread server2("grpc_wave_2_server", server_thread, &args); in run_concurrent_connectivity_test()
|
| /external/autotest/client/site_tests/platform_MetricsUploader/ |
| D | platform_MetricsUploader.py | 66 self.server_thread = threading.Thread(target=self.serve_forever)
67 self.server_thread.start()
76 self.server_thread.join()
|
| /external/grpc-grpc/test/core/transport/chttp2/ |
| D | settings_timeout_test.cc | 224 ServerThread server_thread(server_address_string); in TEST() local
225 server_thread.Start(); in TEST()
238 server_thread.Shutdown(); in TEST()
|
| /external/ltp/testcases/kernel/syscalls/accept/ |
| D | accept02.c | 40 static void *server_thread(void *arg) in server_thread() function
97 SAFE_PTHREAD_CREATE(&server_thr, NULL, server_thread, NULL); in run()
|
| /external/grpc-grpc/src/ruby/stress/ |
| D | stress_client.rb | 57 server_thread = Thread.new { server.run_till_terminated }
58 [server, service, server_thread]
|
| /external/linux-kselftest/tools/testing/selftests/net/ |
| D | tcp_inq.c | 100 pthread_t server_thread; in main() local
136 if (pthread_create(&server_thread, NULL, start_server, in main()
|
| /external/linux-kselftest/tools/testing/selftests/bpf/prog_tests/ |
| D | sockopt_inherit.c | 65 static void *server_thread(void *arg) in server_thread() function
196 if (CHECK_FAIL(pthread_create(&tid, NULL, server_thread, in run_test()
|
| D | tcp_rtt.c | 209 static void *server_thread(void *arg) in server_thread() function
261 if (CHECK_FAIL(pthread_create(&tid, NULL, server_thread, in test_tcp_rtt()
|
| /external/flatbuffers/grpc/tests/ |
| D | grpctest.cpp | 139 std::thread server_thread(RunServer); in grpc_server_test() local
174 server_thread.join(); in grpc_server_test()
|
| /external/grpc-grpc/test/core/handshake/ |
| D | server_ssl_common.cc | 70 static void server_thread(void* arg) { in server_thread() function
142 grpc_core::Thread thd("grpc_ssl_test", server_thread, &port, &ok); in server_ssl_test()
|
| D | verify_peer_options.cc | 50 static void server_thread(void* arg) { in server_thread() function
123 grpc_core::Thread thd("grpc_client_ssl_test", server_thread, &port, &ok); in verify_peer_options_test()
|
| D | client_ssl.cc | 137 static void server_thread(void* arg) { in server_thread() function
235 grpc_core::Thread thd("grpc_client_ssl_test", server_thread, &args, &ok); in client_ssl_test()
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/ |
| D | _cancel_many_calls_test.py | 167 server_thread = threading.Thread(target=_serve, args=server_thread_args)
168 server_thread.start()
|
| /external/grpc-grpc/src/ruby/spec/generic/ |
| D | client_stub_spec.rb | 804 server_thread = Thread.new do
813 server_thread.join
838 server_thread = Thread.new do
847 server_thread.join
943 server_thread = Thread.new do
958 server_thread.join
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | utils.py | 200 server_thread = threading.Thread(
202 server_thread.start()
208 server_thread.join()
|
| /external/python/cpython3/Lib/test/ |
| D | test_ftplib.py | 1012 self.server_thread = threading.Thread(target=self.server)
1013 self.server_thread.daemon = True
1014 self.server_thread.start()
1023 self.server_thread.join()
1025 self.server_thread = None
|
| /external/grpc-grpc/test/core/network_benchmarks/ |
| D | low_level_ping_pong.cc | 255 static void server_thread(thread_args* args) { in server_thread() function
276 server_thread(args); in server_thread_wrap()
|
| /external/python/cpython2/Doc/library/ |
| D | socketserver.rst | 597 server_thread = threading.Thread(target=server.serve_forever)
599 server_thread.daemon = True
600 server_thread.start()
601 print "Server loop running in thread:", server_thread.name
|
| /external/python/cpython3/Doc/library/ |
| D | socketserver.rst | 635 server_thread = threading.Thread(target=server.serve_forever)
637 server_thread.daemon = True
638 server_thread.start()
639 print("Server loop running in thread:", server_thread.name)
|