| /third_party/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 …]
|
| /third_party/grpc/src/ruby/end2end/ |
| D | graceful_sig_handling_client.rb | 52 server_thread = Thread.new do
58 server_thread.join
|
| D | graceful_sig_stop_client.rb | 68 server_thread = Thread.new do
74 server_thread.join
|
| D | sig_handling_client.rb | 76 server_thread = Thread.new do
82 server_thread.join
|
| /third_party/grpc/test/core/surface/ |
| D | sequential_connectivity_test.cc | 100 grpc_core::Thread server_thread("grpc_server", server_thread_func, &sta); in run_test() local
101 server_thread.Start(); in run_test()
127 server_thread.Join(); in run_test()
|
| D | concurrent_connectivity_test.cc | 109 void server_thread(void* vargs) { in server_thread() function
207 grpc_core::Thread server2("grpc_wave_2_server", server_thread, &args); in run_concurrent_connectivity_test()
|
| /third_party/grpc/test/core/transport/chttp2/ |
| D | settings_timeout_test.cc | 228 ServerThread server_thread(server_address_string.c_str()); in TEST() local
229 server_thread.Start(); in TEST()
242 server_thread.Shutdown(); in TEST()
|
| /third_party/ltp/testcases/kernel/syscalls/accept/ |
| D | accept02.c | 43 static void *server_thread(void *arg) in server_thread() function
100 SAFE_PTHREAD_CREATE(&server_thr, NULL, server_thread, NULL); in run()
|
| /third_party/grpc/src/ruby/stress/ |
| D | stress_client.rb | 57 server_thread = Thread.new { server.run_till_terminated }
58 [server, service, server_thread]
|
| /third_party/flatbuffers/grpc/tests/ |
| D | grpctest.cpp | 140 std::thread server_thread(RunServer); in grpc_server_test() local
175 server_thread.join(); in grpc_server_test()
|
| /third_party/grpc/test/core/handshake/ |
| D | server_ssl_common.cc | 100 void server_thread(void* arg) { in server_thread() function
178 grpc_core::Thread thd("grpc_ssl_test", server_thread, &s, &ok); in server_ssl_test()
|
| D | client_ssl.cc | 140 static void server_thread(void* arg) { in server_thread() function
238 grpc_core::Thread thd("grpc_client_ssl_test", server_thread, &args, &ok); in client_ssl_test()
|
| D | verify_peer_options.cc | 53 static void server_thread(void* arg) { in server_thread() function
148 grpc_core::Thread thd("grpc_client_ssl_test", server_thread, &port, &ok); in verify_peer_options_test()
|
| /third_party/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
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/_cython/ |
| D | _cancel_many_calls_test.py | 165 server_thread = threading.Thread(target=_serve, args=server_thread_args)
166 server_thread.start()
|
| /third_party/grpc/src/ruby/pb/test/ |
| D | xds_client.rb | 357 server_thread = Thread.new {
415 server_thread.join
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | utils.py | 201 server_thread = threading.Thread(
203 server_thread.start()
209 server_thread.join()
|
| /third_party/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()
|
| /third_party/python/Lib/test/ |
| D | test_ftplib.py | 1045 self.server_thread = threading.Thread(target=self.server)
1046 self.server_thread.daemon = True
1047 self.server_thread.start()
1056 self.server_thread.join()
1058 self.server_thread = None
|
| /third_party/glib/gio/tests/ |
| D | proxy-test.c | 69 GThread *server_thread; member
709 data->server_thread = g_thread_new ("server", echo_server_thread, data); in create_server()
1384 g_thread_join (server.server_thread); in main()
|
| D | socket.c | 114 GThreadFunc server_thread, in create_server_full() argument
183 data->thread = g_thread_new ("server", server_thread, data); in create_server_full()
196 GThreadFunc server_thread, in create_server() argument
200 return create_server_full (family, G_SOCKET_TYPE_STREAM, server_thread, v4mapped, error); in create_server()
|
| /third_party/python/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)
|