| /external/grpc-grpc/test/core/gpr/ |
| D | mpscq_test.cc | 80 grpc_core::Thread thds[100]; in test_mt() local
81 thd_args ta[GPR_ARRAY_SIZE(thds)]; in test_mt()
84 for (size_t i = 0; i < GPR_ARRAY_SIZE(thds); i++) { in test_mt()
88 thds[i] = grpc_core::Thread("grpc_mt_test", test_thread, &ta[i]); in test_mt()
89 thds[i].Start(); in test_mt()
94 while (num_done != GPR_ARRAY_SIZE(thds)) { in test_mt()
106 for (auto& th : thds) { in test_mt()
149 grpc_core::Thread thds[50]; in test_mt_multipop() local
151 thd_args ta[GPR_ARRAY_SIZE(thds)]; in test_mt_multipop()
154 for (size_t i = 0; i < GPR_ARRAY_SIZE(thds); i++) { in test_mt_multipop()
[all …]
|
| D | arena_test.cc | 101 grpc_core::Thread thds[CONCURRENT_TEST_THREADS]; in concurrent_test() local
104 thds[i] = in concurrent_test()
106 thds[i].Start(); in concurrent_test()
111 for (auto& th : thds) { in concurrent_test()
|
| /external/grpc-grpc/test/core/gprpp/ |
| D | thd_test.cc | 55 grpc_core::Thread thds[NUM_THREADS]; in test1() local
61 for (auto& th : thds) { in test1()
70 for (auto& th : thds) { in test1()
80 grpc_core::Thread thds[NUM_THREADS]; in test2() local
81 for (auto& th : thds) { in test2()
87 for (auto& th : thds) { in test2()
|
| D | fork_test.cc | 68 grpc_core::Thread thds[CONCURRENT_TEST_THREADS]; in test_thd_count() local
77 thds[i] = in test_thd_count()
79 thds[i].Start(); in test_thd_count()
83 for (auto& thd : thds) { in test_thd_count()
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | combiner_test.cc | 100 grpc_core::Thread thds[100]; in test_execute_many() local
101 thd_args ta[GPR_ARRAY_SIZE(thds)]; in test_execute_many()
102 for (size_t i = 0; i < GPR_ARRAY_SIZE(thds); i++) { in test_execute_many()
106 thds[i] = grpc_core::Thread("grpc_execute_many", execute_many_loop, &ta[i]); in test_execute_many()
107 thds[i].Start(); in test_execute_many()
109 for (size_t i = 0; i < GPR_ARRAY_SIZE(thds); i++) { in test_execute_many()
112 thds[i].Join(); in test_execute_many()
|
| D | ev_epollsig_linux_test.cc | 261 grpc_core::Thread thds[10]; in test_threading() local
262 for (auto& th : thds) { in test_threading()
281 for (auto& th : thds) { in test_threading()
|
| /external/grpc-grpc/src/ruby/end2end/ |
| D | grpc_class_init_client.rb | 23 thds = []
25 thds << Thread.new do
34 thds.each(&:join)
|
| /external/jemalloc_new/test/unit/ |
| D | mtx.c | 36 thd_t thds[NTHREADS]; in TEST_BEGIN() local
42 thd_create(&thds[i], thd_start, (void *)&arg); in TEST_BEGIN()
45 thd_join(thds[i], NULL); in TEST_BEGIN()
|
| D | prof_accum.c | 54 thd_t thds[NTHREADS]; in TEST_BEGIN() local
69 thd_create(&thds[i], thd_start, (void *)&thd_args[i]); in TEST_BEGIN()
72 thd_join(thds[i], NULL); in TEST_BEGIN()
|
| D | prof_thread_name.c | 97 thd_t thds[NTHREADS]; in TEST_BEGIN() local
105 thd_create(&thds[i], thd_start, (void *)&thd_args[i]); in TEST_BEGIN()
108 thd_join(thds[i], NULL); in TEST_BEGIN()
|
| D | prof_reset.c | 184 thd_t thds[NTHREADS]; in TEST_BEGIN() local
203 thd_create(&thds[i], thd_start, (void *)&thd_args[i]); in TEST_BEGIN()
206 thd_join(thds[i], NULL); in TEST_BEGIN()
|
| /external/jemalloc/test/unit/ |
| D | mtx.c | 39 thd_t thds[NTHREADS]; in TEST_BEGIN() local
45 thd_create(&thds[i], thd_start, (void *)&arg); in TEST_BEGIN()
47 thd_join(thds[i], NULL); in TEST_BEGIN()
|
| D | prof_accum.c | 64 thd_t thds[NTHREADS]; in TEST_BEGIN() local
79 thd_create(&thds[i], thd_start, (void *)&thd_args[i]); in TEST_BEGIN()
82 thd_join(thds[i], NULL); in TEST_BEGIN()
|
| D | prof_thread_name.c | 107 thd_t thds[NTHREADS]; in TEST_BEGIN() local
115 thd_create(&thds[i], thd_start, (void *)&thd_args[i]); in TEST_BEGIN()
118 thd_join(thds[i], NULL); in TEST_BEGIN()
|
| D | prof_reset.c | 200 thd_t thds[NTHREADS]; in TEST_BEGIN() local
219 thd_create(&thds[i], thd_start, (void *)&thd_args[i]); in TEST_BEGIN()
222 thd_join(thds[i], NULL); in TEST_BEGIN()
|
| /external/jemalloc/test/integration/ |
| D | MALLOCX_ARENA.c | 50 thd_t thds[NTHREADS]; in TEST_BEGIN() local
54 thd_create(&thds[i], thd_start, in TEST_BEGIN()
59 thd_join(thds[i], NULL); in TEST_BEGIN()
|
| D | thread_arena.c | 47 thd_t thds[NTHREADS]; in TEST_BEGIN() local
63 thd_create(&thds[i], thd_start, in TEST_BEGIN()
69 thd_join(thds[i], (void *)&join_ret); in TEST_BEGIN()
|
| /external/jemalloc_new/test/integration/ |
| D | MALLOCX_ARENA.c | 48 thd_t thds[NTHREADS]; in TEST_BEGIN() local
52 thd_create(&thds[i], thd_start, in TEST_BEGIN()
57 thd_join(thds[i], NULL); in TEST_BEGIN()
|
| D | thread_arena.c | 51 thd_t thds[NTHREADS]; in TEST_BEGIN() local
69 thd_create(&thds[i], thd_start, in TEST_BEGIN()
75 thd_join(thds[i], (void *)&join_ret); in TEST_BEGIN()
|
| /external/grpc-grpc/src/ruby/spec/ |
| D | channel_connection_spec.rb | 106 thds = []
108 thds << Thread.new do
121 thds.each(&:join)
|