| /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/autotest/client/site_tests/platform_AddPrinter/ |
| D | platform_AddPrinter.py | 52 self.server_thread = Thread(target = printer.start,
54 self.server_thread.start();
121 self.server_thread.join(_FAKE_SERVER_JOIN_TIMEOUT)
122 if self.server_thread.isAlive():
|
| /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
|
| /external/grpc-grpc/src/ruby/end2end/ |
| D | sig_handling_client.rb | 76 server_thread = Thread.new do
82 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/v8/tools/ |
| D | adb-d8.py | 218 server_thread = threading.Thread(target=server.serve_forever)
219 server_thread.daemon = True
220 server_thread.start()
|
| /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/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 | 110 pthread_t server_thread; in main() local
146 if (pthread_create(&server_thread, NULL, start_server, in main()
|
| /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/flatbuffers/grpc/tests/ |
| D | grpctest.cpp | 141 std::thread server_thread(RunServer); in grpc_server_test() local
177 server_thread.join(); in grpc_server_test()
|
| /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/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/python/cpython3/Lib/test/test_asyncio/ |
| D | utils.py | 189 server_thread = threading.Thread(
191 server_thread.start()
197 server_thread.join()
|
| /external/python/cpython3/Lib/test/ |
| D | test_ftplib.py | 984 self.server_thread = threading.Thread(target=self.server)
985 self.server_thread.daemon = True
986 self.server_thread.start()
995 self.server_thread.join()
997 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 | 633 server_thread = threading.Thread(target=server.serve_forever)
635 server_thread.daemon = True
636 server_thread.start()
637 print("Server loop running in thread:", server_thread.name)
|