| /third_party/grpc/test/core/gpr/ |
| D | cpu_test.cc | 116 grpc_core::Thread* thd = in cpu_test() local
117 static_cast<grpc_core::Thread*>(gpr_malloc(sizeof(*thd) * nthreads)); in cpu_test()
120 thd[i] = grpc_core::Thread("grpc_cpu_test", &worker_thread, &ct); in cpu_test()
121 thd[i].Start(); in cpu_test()
129 thd[i].Join(); in cpu_test()
131 gpr_free(thd); in cpu_test()
|
| /third_party/grpc/test/core/gprpp/ |
| D | fork_test.cc | 83 for (auto& thd : thds) { in test_thd_count() local
84 thd.Join(); in test_thd_count()
118 grpc_core::Thread thd = in test_exec_count() local
123 thd.Start(); in test_exec_count()
128 thd.Join(); // This ensure that the call got un-blocked in test_exec_count()
|
| /third_party/ltp/testcases/misc/math/float/ |
| D | main.c | 325 int thd; in handle_signals() local
377 for (thd = 0; thd < indice; thd++) { in handle_signals()
382 "%d)", thd, indice); in handle_signals()
384 pthread_cancel(threads[thd]); in handle_signals()
|
| /third_party/grpc/src/cpp/thread_manager/ |
| D | thread_manager.cc | 97 void ThreadManager::MarkAsCompleted(WorkerThread* thd) { in MarkAsCompleted() argument
100 completed_threads_.push_back(thd); in MarkAsCompleted()
123 for (auto thd : completed_threads) delete thd; in CleanupCompletedThreads() local
|
| /third_party/grpc/src/ruby/end2end/ |
| D | killed_client_thread_client.rb | 33 thd = Thread.new do
40 thd.join
|
| D | sig_int_during_channel_watch_client.rb | 48 thd = Thread.new do
66 thd.join
|
| D | multiple_killed_watching_threads_test.rb | 24 thd = Thread.new do
32 thd.kill
|
| D | multiple_killed_watching_threads_driver.rb | 24 thd = Thread.new do
32 thd.kill
|
| D | channel_closing_client.rb | 48 thd = Thread.new do
66 thd.join
|
| D | grpc_class_init_client.rb | 62 thd = Thread.new do
66 thd.join
|
| /third_party/grpc/test/core/iomgr/ |
| D | pollset_windows_starvation_test.cc | 69 grpc_core::Thread thd( in main() local
106 thd.Start(); in main()
107 threads.push_back(std::move(thd)); in main()
|
| D | resolve_address_posix_test.cc | 50 grpc_core::Thread thd; member
72 args->thd.Join(); in args_finish()
117 args->thd = grpc_core::Thread("grpc_poll_pollset", actually_poll, args); in poll_pollset_until_request_done()
118 args->thd.Start(); in poll_pollset_until_request_done()
|
| /third_party/grpc/src/core/lib/iomgr/ |
| D | timer_manager.cc | 33 grpc_core::Thread thd; member
73 to_gc->thd.Join(); in gc_completed_threads()
92 ct->thd = grpc_core::Thread("grpc_global_timer", timer_thread, ct); in start_timer_thread_and_unlock()
93 ct->thd.Start(); in start_timer_thread_and_unlock()
|
| D | executor.cc | 160 thd_state_[i].thd = grpc_core::Thread(); in SetThreading()
164 thd_state_[0].thd = in SetThreading()
166 thd_state_[0].thd.Start(); in SetThreading()
187 thd_state_[i].thd.Join(); in SetThreading()
370 thd_state_[cur_thread_count].thd = grpc_core::Thread( in Enqueue()
372 thd_state_[cur_thread_count].thd.Start(); in Enqueue()
|
| /third_party/grpc/src/ruby/pb/test/ |
| D | xds_client.rb | 304 keep_open_threads.each { |thd| thd.join }
417 client_threads.each { |thd| thd.join }
|
| /third_party/grpc/test/core/handshake/ |
| D | server_ssl_common.cc | 178 grpc_core::Thread thd("grpc_ssl_test", server_thread, &s, &ok); in server_ssl_test() local
180 thd.Start(); in server_ssl_test()
275 thd.Join(); in server_ssl_test()
|
| D | client_ssl.cc | 238 grpc_core::Thread thd("grpc_client_ssl_test", server_thread, &args, &ok); in client_ssl_test() local
240 thd.Start(); in client_ssl_test()
306 thd.Join(); in client_ssl_test()
|
| D | verify_peer_options.cc | 148 grpc_core::Thread thd("grpc_client_ssl_test", server_thread, &port, &ok); in verify_peer_options_test() local
150 thd.Start(); in verify_peer_options_test()
203 thd.Join(); in verify_peer_options_test()
|
| /third_party/grpc/test/core/end2end/tests/ |
| D | connectivity.cc | 79 grpc_core::Thread thd("grpc_connectivity", child_thread, &ce); in test_connectivity() local
80 thd.Start(); in test_connectivity()
97 thd.Join(); in test_connectivity()
|
| /third_party/grpc/src/ruby/stress/ |
| D | stress_client.rb | 94 threads.each { |thd| thd.join; }
|
| /third_party/grpc/test/cpp/common/ |
| D | time_jump_test.cc | 112 std::thread thd = std::thread([]() { in TEST_P() local
131 thd.join(); in TEST_P()
|
| /third_party/alsa-utils/bat/ |
| D | bat.c | 47 static void get_snr_thd_db(struct bat *bat, char *thd) in get_snr_thd_db() argument
53 thd_db = strtof(thd, &ptrf); in get_snr_thd_db()
56 fprintf(bat->err, _("Invalid threshold '%s':%d\n"), thd, err); in get_snr_thd_db()
63 static void get_snr_thd_pc(struct bat *bat, char *thd) in get_snr_thd_pc() argument
69 thd_pc = strtof(thd, &ptrf); in get_snr_thd_pc()
72 fprintf(bat->err, _("Invalid threshold '%s':%d\n"), thd, err); in get_snr_thd_pc()
|
| /third_party/grpc/src/core/lib/profiling/ |
| D | basic_timers.cc | 46 int thd; member
154 entry->tm.tv_sec, entry->tm.tv_nsec, entry->thd, entry->type, in write_log()
259 entry->thd = g_thread_id; in gpr_timers_log_add()
|
| /third_party/grpc/test/cpp/end2end/ |
| D | cfstream_test.cc | 385 std::thread thd = std::thread([this, &rpcs_sent]() { in TEST_P() local
425 thd.join(); in TEST_P()
434 std::thread thd = std::thread([this, &rpcs_sent]() { in TEST_P() local
482 thd.join(); in TEST_P()
|
| /third_party/grpc/tools/profiling/latency_profile/ |
| D | profile_analyzer.py | 167 thd = inf['thd'] variable
168 cs = builder[thd]
174 del builder[thd]
|