Home
last modified time | relevance | path

Searched refs:threads (Results 1 – 25 of 102) sorted by relevance

12345

/dragonfly/contrib/xz/src/liblzma/common/
H A Dstream_encoder_mt.c146 worker_thread *threads; member
426 coder->threads[i].state = THR_STOP; in threads_stop()
439 &coder->threads[i].mutex); in threads_stop()
454 coder->threads[i].state = THR_EXIT; in threads_end()
465 lzma_free(coder->threads, allocator); in threads_end()
929 *progress_out += coder->threads[i] in get_progress()
1007 coder->threads = NULL; in stream_encoder_mt_init()
1019 assert(options->threads > 0); in stream_encoder_mt_init()
1023 coder->threads = NULL; in stream_encoder_mt_init()
1029 coder->threads = lzma_alloc( in stream_encoder_mt_init()
[all …]
H A Doutqueue.c24 uint64_t buf_size_max, uint32_t threads) in get_options() argument
26 if (threads > LZMA_THREADS_MAX || buf_size_max > BUF_SIZE_MAX) in get_options()
34 *bufs_count = threads * 2; in get_options()
42 lzma_outq_memusage(uint64_t buf_size_max, uint32_t threads) in lzma_outq_memusage() argument
47 if (get_options(&bufs_alloc_size, &bufs_count, buf_size_max, threads) in lzma_outq_memusage()
58 uint64_t buf_size_max, uint32_t threads) in lzma_outq_init() argument
65 buf_size_max, threads)); in lzma_outq_init()
H A Doutqueue.h68 extern uint64_t lzma_outq_memusage(uint64_t buf_size_max, uint32_t threads);
92 uint64_t buf_size_max, uint32_t threads);
/dragonfly/test/testcases/threads/umtx_errno/
H A Dumtx_errno.c48 pthread_t *threads; in main() local
58 threads = malloc(sizeof(pthread_t) * (nthreads + 1)); in main()
59 if (threads == NULL) { in main()
80 ret = pthread_create(&threads[i], NULL, tester, NULL); in main()
82 threads[i] = 0; in main()
89 if (threads[i] != 0) in main()
90 pthread_join(threads[i], NULL); in main()
/dragonfly/test/testcases/mem/mmap_1/
H A Dmmap_1.c21 pthread_t *threads; in main() local
30 threads = malloc(nthreads * sizeof(pthread_t)); in main()
31 if (threads == NULL) in main()
38 pthread_create(&threads[i], NULL, tester, NULL); in main()
44 pthread_join(threads[i], NULL); in main()
/dragonfly/test/stress/stress2/testcases/thr2/
H A Dthr2.c71 pthread_t threads[NTHREADS]; in test() local
76 if ((r = pthread_create(&threads[i], NULL, thr1, 0)) != 0) in test()
80 if (pthread_join(threads[i], NULL) != 0) in test()
84 if ((r = pthread_create(&threads[i], NULL, thr2, 0)) != 0) in test()
89 if (pthread_join(threads[i], NULL) != 0) in test()
/dragonfly/test/libpthread/
H A Dsem_d.c62 pthread_t threads[NTHREADS]; in main() local
106 pthread_create(&threads[i], NULL, entry, (void *) &sem_a); in main()
114 pthread_join(threads[i], NULL); in main()
118 pthread_create(&threads[i], NULL, entry, (void *) &sem_a); in main()
126 pthread_join(threads[i], NULL); in main()
/dragonfly/contrib/gcc-8.0/libgomp/
H A Dteam.c112 pool->threads[thr->ts.team_id] = thr; in gomp_thread_start()
280 free (pool->threads); in gomp_free_thread()
465 pool->threads in gomp_team_start()
466 = gomp_realloc (pool->threads, in gomp_team_start()
560 if (pool->threads[j]->place in gomp_team_start()
562 && (pool->threads[j]->place in gomp_team_start()
566 l = pool->threads[j]->place - 1 in gomp_team_start()
571 pool->threads[j] = NULL; in gomp_team_start()
601 pool->threads[i] = nthr; in gomp_team_start()
604 nthr = pool->threads[i]; in gomp_team_start()
[all …]
/dragonfly/test/stress/stress2/misc/
H A Ddevfs2.sh94 pthread_t threads[2];
98 if ((r = pthread_create(&threads[0], NULL, thr1, 0)) != 0)
100 if ((r = pthread_create(&threads[1], NULL, thr2, 0)) != 0)
104 if (pthread_join(threads[i], NULL) != 0)
H A Dkevent.sh138 pthread_t threads[2];
157 if ((r = pthread_create(&threads[0], NULL, thr1, 0)) != 0)
159 if ((r = pthread_create(&threads[1], NULL, thr2, 0)) != 0)
162 if (pthread_join(threads[0], NULL) != 0)
164 if (pthread_join(threads[1], NULL) != 0)
H A Dkevent2.sh140 pthread_t threads[2];
159 if ((r = pthread_create(&threads[0], NULL, thr1, 0)) != 0)
161 if ((r = pthread_create(&threads[1], NULL, thr2, 0)) != 0)
164 if (pthread_join(threads[0], NULL) != 0)
166 if (pthread_join(threads[1], NULL) != 0)
H A Dmmap3.sh50 Stress mmap by having max 18 threads mapping random areas within
139 pthread_t threads[THREADS];
149 if ((r = pthread_create(&threads[i], NULL, thr, (void *)&nr[i])) != 0)
154 if (pthread_join(threads[i], NULL) != 0)
H A Dkinfo3.sh98 pthread_t threads[5];
105 if ((r = pthread_create(&threads[i], NULL, thr, 0)) != 0)
109 if (pthread_join(threads[i], NULL) != 0)
H A Dmmap2.sh157 pthread_t threads[THREADS];
166 if ((r = pthread_create(&threads[i], NULL, thr, (void *)&nr[i])) != 0)
171 if (pthread_join(threads[i], NULL) != 0)
/dragonfly/contrib/zstd/lib/common/
H A Dpool.c37 ZSTD_pthread_t* threads; member
143 … ctx->threads = (ZSTD_pthread_t*)ZSTD_customMalloc(numThreads * sizeof(ZSTD_pthread_t), customMem); in POOL_create_advanced()
147 if (!ctx->threads || !ctx->queue) { POOL_free(ctx); return NULL; } in POOL_create_advanced()
151 if (ZSTD_pthread_create(&ctx->threads[i], NULL, &POOL_thread, ctx)) { in POOL_create_advanced()
176 ZSTD_pthread_join(ctx->threads[i], NULL); /* note : could fail */ in POOL_join()
187 ZSTD_customFree(ctx->threads, ctx->customMem); in POOL_free()
215 ZSTD_memcpy(threadPool, ctx->threads, ctx->threadCapacity * sizeof(*threadPool)); in POOL_resize_internal()
216 ZSTD_customFree(ctx->threads, ctx->customMem); in POOL_resize_internal()
217 ctx->threads = threadPool; in POOL_resize_internal()
/dragonfly/contrib/libarchive/libarchive/
H A Darchive_write_add_filter_zstd.c53 int threads; member
111 data->threads = 0; in archive_write_add_filter_zstd()
210 int threads = atoi(value); in archive_compressor_zstd_options() local
217 if (threads < minimum) { in archive_compressor_zstd_options()
221 data->threads = threads; in archive_compressor_zstd_options()
271 ZSTD_CCtx_setParameter(data->cstream, ZSTD_c_nbWorkers, data->threads); in archive_compressor_zstd_open()
387 if (data->threads != 0) { in archive_compressor_zstd_open()
390 archive_string_sprintf(&as2, " --threads=%d", data->threads); in archive_compressor_zstd_open()
H A Darchive_write_add_filter_xz.c103 uint32_t threads; member
155 data->threads = 1; in common_setup()
235 if (data->threads != 1) { in archive_compressor_xz_init_stream()
237 mt_options.threads = data->threads; in archive_compressor_xz_init_stream()
394 data->threads = (int)strtoul(value, &endptr, 10); in archive_compressor_xz_options()
396 data->threads = 1; in archive_compressor_xz_options()
399 if (data->threads == 0) { in archive_compressor_xz_options()
401 data->threads = lzma_cputhreads(); in archive_compressor_xz_options()
403 data->threads = 1; in archive_compressor_xz_options()
/dragonfly/test/stress/stress2/testcases/thr1/
H A Dthr1.c62 pthread_t threads[NTHREADS]; in test() local
67 if ((r = pthread_create(&threads[i], NULL, thr_routine, 0)) != 0) in test()
71 if (pthread_join(threads[i], NULL) != 0) in test()
/dragonfly/contrib/binutils-2.34/gold/
H A Dworkqueue.cc128 bool threads = options.threads(); in Workqueue() local
130 threads = false; in Workqueue()
132 if (!threads) in Workqueue()
503 Workqueue::set_thread_count(int threads) in set_thread_count() argument
507 this->threader_->set_thread_count(threads); in set_thread_count()
/dragonfly/contrib/binutils-2.27/gold/
H A Dworkqueue.cc128 bool threads = options.threads(); in Workqueue() local
130 threads = false; in Workqueue()
132 if (!threads) in Workqueue()
503 Workqueue::set_thread_count(int threads) in set_thread_count() argument
507 this->threader_->set_thread_count(threads); in set_thread_count()
/dragonfly/contrib/gdb-7/gdb/python/
H A Dpy-inferior.c48 struct threadlist_entry *threads; member
165 inf_obj->threads = NULL; in inferior_to_inferior_object()
208 for (thread = ((inferior_object *)inf_obj)->threads; thread; in find_thread_object()
246 entry->next = inf_obj->threads; in add_thread_object()
248 inf_obj->threads = entry; in add_thread_object()
271 for (entry = &inf_obj->threads; *entry != NULL; entry = in delete_thread_object()
315 for (i = 0, entry = inf_obj->threads; i < inf_obj->nthreads; in infpy_threads()
751 for (th_entry = inf_obj->threads; th_entry != NULL;) in py_free_inferior()
/dragonfly/tools/tools/crypto/
H A Dcryptotest.c428 runtests(struct alg *alg, int count, int size, u_long cmd, int threads, int profile) in runtests() argument
445 region = mmap(NULL, threads * sizeof (struct timeval), in runtests()
464 if (threads > 1) { in runtests()
465 for (i = 0; i < threads; i++) in runtests()
476 for (i = 0; i < threads; i++) in runtests()
482 t /= threads; in runtests()
487 nops *= threads; in runtests()
/dragonfly/contrib/gcc-4.7/libgomp/
H A Dteam.c108 pool->threads[thr->ts.team_id] = thr; in gomp_thread_start()
193 pool->threads = NULL; in gomp_new_thread_pool()
224 struct gomp_thread *nthr = pool->threads[i]; in gomp_free_thread()
245 free (pool->threads); in gomp_free_thread()
348 nthr = pool->threads[i]; in gomp_team_start()
376 pool->threads in gomp_team_start()
377 = gomp_realloc (pool->threads, in gomp_team_start()
/dragonfly/usr.bin/top/
H A Dmachine.h63 unsigned int threads : 1; member
108 int threads; /* show threads separately */ member
/dragonfly/contrib/xz/
H A DREADME.DRAGONFLY12 --enable-symbol-versions --enable-threads=no
15 --enable-symbol-versions --enable-threads=posix

12345