| /third_party/python/Tools/ccbench/ |
| D | ccbench.py | 187 def run_throughput_test(func, args, nthreads): argument
188 assert nthreads >= 1
197 if nthreads == 1:
221 for i in range(nthreads):
229 while len(ready) < nthreads:
234 start_cond.notify(nthreads)
245 nthreads = 1
247 while nthreads <= max_threads:
248 results = run_throughput_test(func, args, nthreads)
252 print("threads=%d: %d" % (nthreads, speed), end="")
[all …]
|
| /third_party/ltp/testcases/realtime/perf/latency/ |
| D | pthread_cond_many.c | 55 int nthreads = 0; variable
186 void test_signal(long iter, long nthreads) in test_signal() argument
197 stats_container_init(&dat, iter * nthreads); in test_signal()
199 pt = malloc(sizeof(*pt) * nthreads); in test_signal()
204 for (j = 0; j < nthreads; j++) { in test_signal()
208 for (i = 0; i < (iter - 1) * nthreads; i += nthreads) { in test_signal()
209 for (j = 0, k = i; j < nthreads; j++, k++) { in test_signal()
219 for (j = 0; j < nthreads; j++) { in test_signal()
231 for (i = 0; i < iter * nthreads; i++) { in test_signal()
271 nthreads = atoi(v); in parse_args()
[all …]
|
| /third_party/libuv/src/ |
| D | threadpool.c | 37 static unsigned int nthreads; variable
46 return (nthreads + 1) / 2; in slow_work_thread_threshold()
170 if (nthreads == 0) in uv__threadpool_cleanup()
178 for (i = 0; i < nthreads; i++) in uv__threadpool_cleanup()
189 nthreads = 0; in uv__threadpool_cleanup()
198 nthreads = ARRAY_SIZE(default_threads); in init_threads()
201 nthreads = atoi(val); in init_threads()
202 if (nthreads == 0) in init_threads()
203 nthreads = 1; in init_threads()
204 if (nthreads > MAX_THREADPOOL_SIZE) in init_threads()
[all …]
|
| /third_party/ltp/testcases/kernel/fs/fs_fill/ |
| D | fs_fill.c | 23 static unsigned int nthreads; variable
66 pthread_t threads[nthreads]; in testrun()
70 for (i = 0; i < nthreads; i++) in testrun()
84 for (i = 0; i < nthreads; i++) in testrun()
94 nthreads = tst_ncpus_conf() + 2; in setup()
95 workers = SAFE_MALLOC(sizeof(struct worker) * nthreads); in setup()
97 for (i = 0; i < nthreads; i++) { in setup()
103 tst_res(TINFO, "Running %i writer threads", nthreads); in setup()
|
| /third_party/libuv/test/ |
| D | benchmark-async.c | 35 unsigned int nthreads; member
75 static int test_async(int nthreads) { in test_async() argument
81 threads = calloc(nthreads, sizeof(threads[0])); in test_async()
84 for (i = 0; i < nthreads; i++) { in test_async()
86 ctx->nthreads = nthreads; in test_async()
99 for (i = 0; i < nthreads; i++) in test_async()
104 for (i = 0; i < nthreads; i++) { in test_async()
113 nthreads, in test_async()
|
| D | benchmark-async-pummel.c | 64 static int test_async_pummel(int nthreads) { in test_async_pummel() argument
70 tids = calloc(nthreads, sizeof(tids[0])); in test_async_pummel()
76 for (i = 0; i < nthreads; i++) in test_async_pummel()
86 for (i = 0; i < nthreads; i++) in test_async_pummel()
90 nthreads, in test_async_pummel()
|
| /third_party/grpc/test/core/gpr/ |
| D | cpu_test.cc | 59 int nthreads; member
94 ct->nthreads--; in worker_thread()
95 if (ct->nthreads == 0) { in worker_thread()
108 ct.nthreads = static_cast<int>(ct.ncores) * 3; in cpu_test()
115 uint32_t nthreads = ct.ncores * 3; in cpu_test() local
117 static_cast<grpc_core::Thread*>(gpr_malloc(sizeof(*thd) * nthreads)); in cpu_test()
119 for (i = 0; i < nthreads; i++) { in cpu_test()
128 for (i = 0; i < nthreads; i++) { in cpu_test()
|
| D | sync_test.cc | 138 int nthreads; /* number of threads */ member
163 static struct test* test_new(int nthreads, int64_t iterations, int incr_step) { in test_new() argument
165 m->nthreads = nthreads; in test_new()
167 gpr_malloc(sizeof(*m->threads) * nthreads)); in test_new()
171 m->done = nthreads; in test_new()
179 gpr_ref_init(&m->thread_refcount, nthreads); in test_new()
197 for (i = 0; i != m->nthreads; i++) { in test_create_threads()
210 for (int i = 0; i != m->nthreads; i++) { in test_wait()
268 if (m->counter != m->nthreads * m->iterations * m->incr_step) { in test()
270 static_cast<long>(m->counter), m->nthreads, in test()
[all …]
|
| /third_party/ltp/testcases/open_posix_testsuite/stress/threads/pthread_create/ |
| D | s-c1.c | 104 int nthreads; member
147 int nthreads, ctl, i, tmp; in main() local
197 nthreads = 0; in main()
247 pthread_create(&th[nthreads], in main()
258 nthreads++; in main()
268 if (nthreads > my_max) { in main()
298 if ((nthreads % RESOLUTION) == 0) { in main()
307 m_tmp->nthreads = in main()
308 nthreads; in main()
331 sc, nthreads, in main()
[all …]
|
| /third_party/glib/glib/ |
| D | gpoll.c | 368 guint nthreads, threads_remain; in g_poll() local
406 nthreads = nfds / MAXIMUM_WAIT_OBJECTS_PER_THREAD; in g_poll()
409 nthreads++; in g_poll()
411 if (nthreads > MAXIMUM_WAIT_OBJECTS_PER_THREAD) in g_poll()
414 nthreads = MAXIMUM_WAIT_OBJECTS_PER_THREAD; in g_poll()
424 threads_data = g_new0 (GWin32PollThreadData, nthreads); in g_poll()
425 for (i = 0; i < nthreads; i++) in g_poll()
430 if (i == (nthreads - 1) && threads_remain > 0) in g_poll()
450 ready = MsgWaitForMultipleObjectsEx (nthreads, thread_handles, timeout, in g_poll()
453 ready = WaitForMultipleObjects (nthreads, thread_handles, FALSE, timeout); in g_poll()
[all …]
|
| /third_party/ltp/testcases/open_posix_testsuite/stress/threads/pthread_cond_timedwait/ |
| D | s-c.c | 175 int nthreads; member
290 static long do_threads_test(int nthreads, mes_t * measure) in do_threads_test() argument
317 th = (pthread_t *) calloc(nthreads, sizeof(pthread_t)); in do_threads_test()
322 output("%d", nthreads); in do_threads_test()
396 for (i = 0; i < nthreads; i++) { in do_threads_test()
444 while (tnum < nthreads) { in do_threads_test()
495 for (i = 0; i < nthreads; i++) { in do_threads_test()
538 output("%5d threads; %d.%09d s (%i loops)\n", nthreads, ts_cumul.tv_sec, in do_threads_test()
617 m_tmp->nthreads = nth; in main()
737 Xavg += (double)cur->nthreads; in parse_measure()
[all …]
|
| /third_party/nghttp2/src/ |
| D | h2load.cc | 80 nthreads(1), in Config()
1844 << config.nthreads << R"( in print_help()
2074 config.nthreads = strtoul(optarg, nullptr, 10); in main()
2393 if (config.nthreads == 0) { in main()
2399 if (config.nthreads > std::thread::hardware_concurrency()) { in main()
2413 if (config.nclients < config.nthreads) { in main()
2424 if (config.rate < config.nthreads) { in main()
2615 workers.reserve(config.nthreads); in main()
2622 nreqs_per_thread = config.nreqs / config.nthreads; in main()
2623 nreqs_rem = config.nreqs % config.nthreads; in main()
[all …]
|
| D | h2load.h | 80 size_t nthreads; member
|
| /third_party/python/Python/ |
| D | traceback.c | 891 unsigned int nthreads; in _Py_DumpTracebackThreads() local
929 nthreads = 0; in _Py_DumpTracebackThreads()
933 if (nthreads != 0) in _Py_DumpTracebackThreads()
935 if (nthreads >= MAX_NTHREADS) { in _Py_DumpTracebackThreads()
945 nthreads++; in _Py_DumpTracebackThreads()
|
| /third_party/iowow/src/fs/tests/ |
| D | iwfs_test2.c | 538 void test_block_allocation_impl(int mmap_all, int nthreads, int numrec, int avgrecsz, int blkpow, c… in test_block_allocation_impl() argument
540 pthread_t *tlist = malloc(nthreads * sizeof(pthread_t)); in test_block_allocation_impl()
568 for (int i = 0; i < nthreads; ++i) { in test_block_allocation_impl()
571 for (int i = 0; i < nthreads; ++i) { in test_block_allocation_impl()
|
| /third_party/googletest/googletest/src/ |
| D | gtest-port.cc | 211 size_t nthreads = 0; in GetThreadCount() local
214 nthreads++; in GetThreadCount()
216 return nthreads; in GetThreadCount()
|
| /third_party/mesa3d/src/gtest/src/ |
| D | gtest-port.cc | 209 int nthreads = 0; in GetThreadCount() local
212 nthreads++; in GetThreadCount()
214 return nthreads; in GetThreadCount()
|
| /third_party/python/Lib/test/ |
| D | test_bz2.py | 502 nthreads = 10
507 threads = [threading.Thread(target=comp) for i in range(nthreads)]
|
| /third_party/mesa3d/src/gallium/drivers/r600/ |
| D | r600_state_common.c | 1691 unsigned nthreads = 128; in r600_setup_scratch_area_for_shader() local
1694 unsigned size = align(itemsize * nthreads * num_pipes * num_ses * 4, 256); in r600_setup_scratch_area_for_shader()
|
| /third_party/cef/tools/distrib/gtest/ |
| D | gtest-all.cc | 10539 size_t nthreads = 0; in GetThreadCount() local
10542 nthreads++; in GetThreadCount()
10544 return nthreads; in GetThreadCount()
|
| /third_party/libuv/ |
| D | ChangeLog | 1591 * unix,win: limit concurrent DNS calls to nthreads/2 (Anna Henningsen)
|
| /third_party/gstreamer/gstreamer/docs/random/old/ |
| D | ChangeLog.gstreamer | 4637 cothread_create returns NULL if nthreads == MAXTHREADS though not
|