| /third_party/node/deps/base64/base64/lib/ |
| D | lib_openmp.c | 27 int num_threads, i; in base64_encode_openmp() local
36 num_threads = omp_get_num_threads(); in base64_encode_openmp()
41 len = srclen / (num_threads * 3); in base64_encode_openmp()
43 last_len = srclen - num_threads * len; in base64_encode_openmp()
53 for (i = 0; i < num_threads; i++) in base64_encode_openmp()
66 …base64_stream_encode(&state, src + num_threads * len, last_len, out + num_threads * len * 4 / 3, &… in base64_encode_openmp()
69 base64_stream_encode_final(&state, out + num_threads * len * 4 / 3 + s, &t); in base64_encode_openmp()
85 int num_threads, result = 0, i; in base64_decode_openmp() local
96 num_threads = omp_get_num_threads(); in base64_decode_openmp()
101 len = srclen / (num_threads * 4); in base64_decode_openmp()
[all …]
|
| /third_party/mesa3d/src/util/ |
| D | u_queue.c | 286 while (thread_index < queue->num_threads && queue->num_queued == 0) in util_queue_thread_func()
290 if (thread_index >= queue->num_threads) { in util_queue_thread_func()
316 if (queue->num_threads == 0) { in util_queue_thread_func()
363 util_queue_adjust_num_threads(struct util_queue *queue, unsigned num_threads) in util_queue_adjust_num_threads() argument
365 num_threads = MIN2(num_threads, queue->max_threads); in util_queue_adjust_num_threads()
366 num_threads = MAX2(num_threads, 1); in util_queue_adjust_num_threads()
369 unsigned old_num_threads = queue->num_threads; in util_queue_adjust_num_threads()
371 if (num_threads == old_num_threads) { in util_queue_adjust_num_threads()
376 if (num_threads < old_num_threads) { in util_queue_adjust_num_threads()
377 util_queue_kill_threads(queue, num_threads, true); in util_queue_adjust_num_threads()
[all …]
|
| D | u_queue.h | 216 unsigned num_threads; /* decreasing this number will terminate threads */ member
230 unsigned num_threads,
252 util_queue_adjust_num_threads(struct util_queue *queue, unsigned num_threads);
|
| /third_party/mesa3d/src/gallium/drivers/llvmpipe/ |
| D | lp_cs_tpool.c | 87 lp_cs_tpool_create(unsigned num_threads) in lp_cs_tpool_create() argument
98 assert (num_threads <= LP_MAX_THREADS); in lp_cs_tpool_create()
99 for (unsigned i = 0; i < num_threads; i++) { in lp_cs_tpool_create()
101 num_threads = i; /* previous thread is max */ in lp_cs_tpool_create()
105 pool->num_threads = num_threads; in lp_cs_tpool_create()
120 for (unsigned i = 0; i < pool->num_threads; i++) { in lp_cs_tpool_destroy()
135 if (pool->num_threads == 0) { in lp_cs_tpool_queue_task()
154 task->iter_per_thread = num_iters / pool->num_threads; in lp_cs_tpool_queue_task()
155 task->iter_remainder = num_iters % pool->num_threads; in lp_cs_tpool_queue_task()
|
| D | lp_query.c | 100 unsigned num_threads = MAX2(1, screen->num_threads); in llvmpipe_get_query_result() local
124 for (i = 0; i < num_threads; i++) { in llvmpipe_get_query_result()
130 for (i = 0; i < num_threads; i++) { in llvmpipe_get_query_result()
136 for (i = 0; i < num_threads; i++) { in llvmpipe_get_query_result()
144 for (i = 0; i < num_threads; i++) { in llvmpipe_get_query_result()
189 for (i = 0; i < num_threads; i++) { in llvmpipe_get_query_result()
214 unsigned num_threads = MAX2(1, screen->num_threads); in llvmpipe_get_query_result_resource() local
247 for (i = 0; i < num_threads; i++) { in llvmpipe_get_query_result_resource()
253 for (i = 0; i < num_threads; i++) { in llvmpipe_get_query_result_resource()
265 for (i = 0; i < num_threads; i++) { in llvmpipe_get_query_result_resource()
[all …]
|
| D | lp_rast.c | 1108 if (rast->num_threads == 0) { in lp_rast_queue_scene()
1134 for (i = 0; i < rast->num_threads; i++) { in lp_rast_queue_scene()
1146 if (rast->num_threads == 0) { in lp_rast_finish()
1153 for (i = 0; i < rast->num_threads; i++) { in lp_rast_finish()
1243 for (unsigned i = 0; i < rast->num_threads; i++) { in create_rast_threads()
1248 rast->num_threads = i; /* previous thread is max */ in create_rast_threads()
1261 lp_rast_create(unsigned num_threads) in lp_rast_create() argument
1276 for (i = 0; i < MAX2(1, num_threads); i++) { in lp_rast_create()
1287 rast->num_threads = num_threads; in lp_rast_create()
1294 if (rast->num_threads > 0) { in lp_rast_create()
[all …]
|
| D | lp_screen.c | 1000 screen->rast = lp_rast_create(screen->num_threads); in llvmpipe_screen_late_init()
1006 screen->cs_tpool = lp_cs_tpool_create(screen->num_threads); in llvmpipe_screen_late_init()
1077 screen->num_threads = util_get_cpu_caps()->nr_cpus > 1 ? util_get_cpu_caps()->nr_cpus : 0; in llvmpipe_create_screen()
1079 screen->num_threads = MIN2(screen->num_threads, 2); in llvmpipe_create_screen()
1081 screen->num_threads = debug_get_num_option("LP_NUM_THREADS", screen->num_threads); in llvmpipe_create_screen()
1082 screen->num_threads = MIN2(screen->num_threads, LP_MAX_THREADS); in llvmpipe_create_screen()
|
| D | lp_cs_tpool.h | 49 unsigned num_threads; member
73 struct lp_cs_tpool *lp_cs_tpool_create(unsigned num_threads);
|
| /third_party/ltp/testcases/misc/math/float/ |
| D | main.c | 59 int num_threads = DEFAULT_NUM_THREADS; variable
151 num_threads = atoi(optarg); in main()
182 if (num_threads <= 0) { in main()
185 num_threads = 1; in main()
188 if (nb_func * num_threads > PTHREAD_THREADS_MAX - 2) in main()
189 while (nb_func * num_threads > PTHREAD_THREADS_MAX - 2) in main()
190 num_threads--; in main()
194 argv[0], nb_func, num_threads); in main()
207 threads = malloc(nb_func * num_threads * sizeof(pthread_t)); in main()
211 tabcom = malloc((sizeof(TH_DATA *) * nb_func * num_threads)); in main()
[all …]
|
| /third_party/skia/third_party/externals/harfbuzz/test/api/ |
| D | test-multithread.c | 37 static int num_threads = 30; variable
99 pthread_t *threads = calloc (num_threads, sizeof (pthread_t)); in test_body()
100 hb_buffer_t **buffers = calloc (num_threads, sizeof (hb_buffer_t *)); in test_body()
104 for (i = 0; i < num_threads; i++) in test_body()
114 for (i = 0; i < num_threads; i++) in test_body()
131 num_threads = atoi (argv[2]); in main()
|
| /third_party/skia/third_party/externals/abseil-cpp/absl/synchronization/ |
| D | blocking_counter_benchmark.cc | 61 int num_threads = state.range(0); in BM_BlockingCounter_Wait() local
62 absl::synchronization_internal::ThreadPool pool(num_threads); in BM_BlockingCounter_Wait()
64 absl::BlockingCounter counter{num_threads}; in BM_BlockingCounter_Wait()
65 pool.Schedule([num_threads, &counter, &pool]() { in BM_BlockingCounter_Wait()
66 for (int i = 0; i < num_threads; ++i) { in BM_BlockingCounter_Wait()
|
| D | barrier.h | 53 explicit Barrier(int num_threads) in Barrier() argument
54 : num_to_block_(num_threads), num_to_exit_(num_threads) {} in Barrier()
|
| /third_party/alsa-lib/test/ |
| D | pcm-multi-thread.c | 42 static int num_threads = 1; variable
158 num_threads = atoi(optarg); in parse_options()
159 if (num_threads < 1 || num_threads > MAX_THREADS) { in parse_options()
231 for (i = 0; i < num_threads; i++) { in main()
257 for (i = 0; i < num_threads; i++) in main()
259 for (i = 0; i < num_threads; i++) in main()
|
| /third_party/ltp/testcases/kernel/io/ltp-aiodio/ |
| D | aio-stress.c | 82 static int num_threads = 1; variable
958 static int setup_shared_mem(int num_threads, int num_files, int depth, int reclen) in setup_shared_mem() argument
965 total_ram = num_files * depth * padded_reclen + num_threads; in setup_shared_mem()
1014 for (i = 0; i < num_threads; i++) { in global_thread_throughput()
1047 if (num_threads > 1) { in worker()
1112 if (num_threads > 1) { in worker()
1137 static int run_workers(struct thread_info *t, int num_threads) in run_workers() argument
1143 pthread_barrier_init(&worker_barrier, NULL, num_threads); in run_workers()
1145 for (i = 0; i < num_threads; i++) in run_workers()
1148 for (i = 0; i < num_threads; i++) { in run_workers()
[all …]
|
| /third_party/benchmark/src/ |
| D | counter.cc | 21 double num_threads) { in Finish() argument
27 v /= num_threads; in Finish()
43 double num_threads) { in Finish() argument
45 c.second.value = Finish(c.second, iterations, cpu_time, num_threads); in Finish()
|
| D | thread_manager.h | 14 explicit ThreadManager(int num_threads) in ThreadManager() argument
15 : alive_threads_(num_threads), start_stop_barrier_(num_threads) {} in ThreadManager()
|
| /third_party/ltp/testcases/kernel/sched/pthreads/ |
| D | pth_str02.c | 68 int num_threads = DEFAULT_NUM_THREADS; variable
92 tst_resm(TINFO, "Creating %d threads", num_threads); in main()
121 if (test_limit || (num < num_threads)) { in thread()
184 num_threads = atoi(optarg); in parse_args()
|
| /third_party/libuv/test/ |
| D | benchmark-thread.c | 30 static volatile int num_threads; variable
35 num_threads++; in thread_entry()
58 ASSERT(num_threads == NUM_THREADS); in BENCHMARK_IMPL()
|
| /third_party/musl/libc-test/src/functionalext/supplement/network/ |
| D | getaddrinfo.c | 302 static void do_test_concurrently(void *(*test) (void *arg), size_t num_threads) in do_test_concurrently() argument
304 pthread_t *threads = (pthread_t *) malloc(sizeof(pthread_t) * num_threads); in do_test_concurrently()
311 while (last < num_threads) { in do_test_concurrently()
331 size_t num_threads = 16; in main() local
332 do_test_concurrently(test_all_cases, num_threads); in main()
|
| /third_party/python/Lib/test/ |
| D | test_thread.py | 158 def __init__(self, num_threads): argument
159 self.num_threads = num_threads
168 if self.waiting == self.num_threads:
169 self.waiting = self.num_threads - 1
|
| /third_party/vixl/tools/ |
| D | thread_pool.py | 42 def Multithread(function, list_of_args, num_threads=1, init_function=None): argument
49 pool = multiprocessing.Pool(num_threads)
|
| /third_party/skia/third_party/externals/abseil-cpp/absl/synchronization/internal/ |
| D | thread_pool.h | 35 explicit ThreadPool(int num_threads) { in ThreadPool() argument
36 for (int i = 0; i < num_threads; ++i) { in ThreadPool()
|
| /third_party/mesa3d/src/gallium/drivers/r600/ |
| D | evergreen_compute.c | 1058 int num_threads; in evergreen_init_atom_start_compute_cs() local
1074 num_threads = 128; in evergreen_init_atom_start_compute_cs()
1078 num_threads = 128; in evergreen_init_atom_start_compute_cs()
1082 num_threads = 128; in evergreen_init_atom_start_compute_cs()
1087 num_threads = 128; in evergreen_init_atom_start_compute_cs()
1091 num_threads = 128; in evergreen_init_atom_start_compute_cs()
1095 num_threads = 128; in evergreen_init_atom_start_compute_cs()
1099 num_threads = 128; in evergreen_init_atom_start_compute_cs()
1103 num_threads = 128; in evergreen_init_atom_start_compute_cs()
1107 num_threads = 128; in evergreen_init_atom_start_compute_cs()
[all …]
|
| /third_party/python/Lib/concurrent/futures/ |
| D | thread.py | 190 num_threads = len(self._threads)
191 if num_threads < self._max_workers:
193 num_threads)
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/src/ |
| D | scheduler_test.cpp | 132 constexpr auto num_threads = sizeof(void*) > 4 ? 1000 : 100; in TEST_P() local
135 marl::WaitGroup wg(num_threads); in TEST_P()
138 for (int i = 0; i < num_threads; i++) { in TEST_P()
|