Home
last modified time | relevance | path

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

12345678910>>...16

/src/crypto/openssl/Configurations/
H A D10-main.conf295 cppflags => add(threads("-D_REENTRANT")),
298 lflags => add(threads("-mt")),
350 cppflags => add(threads("-D_REENTRANT")),
352 lflags => add(threads("-mt")),
384 cppflags => threads("-D_SGI_MP_SOURCE"),
386 ex_libs => add(threads("-lpthread")),
486 cflags => add(threads("-pthread")),
488 ex_libs => add("-ldld", threads("-pthread")),
506 cflags => add(threads("-pthread")),
507 ex_libs => add("-ldl", threads("-pthread")),
[all …]
H A D50-cppbuilder.conf14 threads("-tM"),
41 ? ($disabled{threads} ? "cw32.lib" : "cw32mt.lib")
42 : ($disabled{threads} ? "cw32i.lib" : "cw32mti.lib")));
73 threads("-tM"),
100 ? ($disabled{threads} ? "cw64.a" : "cw64mt.a")
101 : ($disabled{threads} ? "cw64i.a" : "cw64mti.a")));
/src/sys/amd64/vmm/
H A Dx86.c91 uint16_t cores, maxcpus, sockets, threads; in x86_emulate_cpuid() local
146 vm_get_topology(vm, &sockets, &cores, &threads, in x86_emulate_cpuid()
158 width = MIN(0xF, log2(threads * cores)); in x86_emulate_cpuid()
159 logical_cpus = MIN(0xFF, threads * cores - 1); in x86_emulate_cpuid()
244 vm_get_topology(vm, &sockets, &cores, &threads, in x86_emulate_cpuid()
248 logical_cpus = threads; in x86_emulate_cpuid()
253 logical_cpus = threads; in x86_emulate_cpuid()
258 logical_cpus = threads * cores; in x86_emulate_cpuid()
263 logical_cpus = sockets * threads * cores; in x86_emulate_cpuid()
292 vm_get_topology(vm, &sockets, &cores, &threads, in x86_emulate_cpuid()
[all …]
/src/contrib/netbsd-tests/lib/libpthread_dbg/
H A Dt_threads.c78 pthread_t threads[MAX_THREADS]; in ATF_TC_BODY() local
90 (pthread_create(&threads[i], NULL, busyFunction1, NULL)); in ATF_TC_BODY()
139 pthread_t threads[MAX_THREADS]; in ATF_TC_BODY() local
153 (pthread_create(&threads[i], NULL, busyFunction2, NULL)); in ATF_TC_BODY()
209 pthread_t threads[MAX_THREADS]; in ATF_TC_BODY() local
223 (pthread_create(&threads[i], NULL, busyFunction3, NULL)); in ATF_TC_BODY()
282 pthread_t threads[MAX_THREADS]; in ATF_TC_BODY() local
295 (pthread_create(&threads[i], NULL, busyFunction4, NULL)); in ATF_TC_BODY()
300 (pthread_setname_np(threads[i], "test_%d", (void*)i)); in ATF_TC_BODY()
363 pthread_t threads[MAX_THREADS]; in ATF_TC_BODY() local
[all …]
/src/contrib/netbsd-tests/lib/libc/stdlib/
H A Dt_getenv_thread.c150 pthread_t threads[THREADED_NUM_THREADS]; in ATF_TC_BODY() local
158 ATF_CHECK(pthread_create(&threads[i++], NULL, thread_getenv_r, in ATF_TC_BODY()
163 ATF_CHECK(pthread_join(threads[j], NULL) == 0); in ATF_TC_BODY()
175 pthread_t threads[THREADED_NUM_THREADS]; in ATF_TC_BODY() local
183 ATF_CHECK(pthread_create(&threads[i++], NULL, thread_putenv, in ATF_TC_BODY()
188 ATF_CHECK(pthread_join(threads[j], NULL) == 0); in ATF_TC_BODY()
200 pthread_t threads[THREADED_NUM_THREADS]; in ATF_TC_BODY() local
208 ATF_CHECK(pthread_create(&threads[i++], NULL, thread_setenv, in ATF_TC_BODY()
213 ATF_CHECK(pthread_join(threads[j], NULL) == 0); in ATF_TC_BODY()
225 pthread_t threads[THREADED_NUM_THREADS]; in ATF_TC_BODY() local
[all …]
/src/contrib/libder/tests/
H A Dfuzz_parallel.c78 pthread_t *threads; in LLVMFuzzerTestOneInput() local
92 threads = malloc(sizeof(*threads) * frame->frame_threads); in LLVMFuzzerTestOneInput()
93 if (threads == NULL) in LLVMFuzzerTestOneInput()
100 if (pthread_create(&threads[nthreads], NULL, thread_main, in LLVMFuzzerTestOneInput()
106 pthread_join(threads[i], NULL); in LLVMFuzzerTestOneInput()
108 free(threads); in LLVMFuzzerTestOneInput()
/src/crypto/openssl/test/recipes/30-test_evp_data/
H A Devpkdf_argon2.txt86 Ctrl.threads = threads:2
95 Ctrl.threads = threads:2
120 # Expected fail on condition violation: threads > avail threads
123 Ctrl.threads = threads:2
140 # Expected fail on condition violation: threads >= 1
142 Ctrl.lanes = threads:0
145 # Expected fail on condition violation: threads <= 0xFFFFFF
147 Ctrl.lanes = threads:0x1000000
/src/contrib/xz/src/liblzma/common/
H A Dstream_encoder_mt.c166 worker_thread *threads; member
449 mythread_sync(coder->threads[i].mutex) { in threads_stop()
450 coder->threads[i].state = THR_STOP; in threads_stop()
451 mythread_cond_signal(&coder->threads[i].cond); in threads_stop()
460 mythread_sync(coder->threads[i].mutex) { in threads_stop()
461 while (coder->threads[i].state != THR_IDLE) in threads_stop()
462 mythread_cond_wait(&coder->threads[i].cond, in threads_stop()
463 &coder->threads[i].mutex); in threads_stop()
477 mythread_sync(coder->threads[i].mutex) { in threads_end()
478 coder->threads[i].state = THR_EXIT; in threads_end()
[all …]
H A Doutqueue.c19 #define GET_BUFS_LIMIT(threads) (2 * (threads)) argument
23 lzma_outq_memusage(uint64_t buf_size_max, uint32_t threads) in lzma_outq_memusage() argument
33 if (threads > LZMA_THREADS_MAX || buf_size_max > limit) in lzma_outq_memusage()
36 return GET_BUFS_LIMIT(threads) in lzma_outq_memusage()
113 uint32_t threads) in lzma_outq_init() argument
115 if (threads > LZMA_THREADS_MAX) in lzma_outq_init()
118 const uint32_t bufs_limit = GET_BUFS_LIMIT(threads); in lzma_outq_init()
/src/tools/test/stress2/misc/
H A Df_offset.sh52 3. there are several threads or processes that operate on the same
127 pthread_t threads[3];
141 if ((r = pthread_create(&threads[0], NULL, t1, 0)) != 0)
143 if ((r = pthread_create(&threads[1], NULL, t2, 0)) != 0)
145 if ((r = pthread_create(&threads[2], NULL, t3, 0)) != 0)
148 if ((r = pthread_join(threads[0], NULL)) != 0)
150 if ((r = pthread_join(threads[1], NULL)) != 0)
152 if ((r = pthread_join(threads[2], NULL)) != 0)
H A Dcontext2.sh56 * Pass a token thru pipes to NTHREADS+1 threads in a circular list.
96 pthread_t threads[NTHREADS];
108 if ((r = pthread_create(&threads[i], NULL, thr_routine,
124 if ((r = pthread_cancel(threads[i])) != 0)
127 if ((r = pthread_join(threads[i], NULL)) != 0)
H A Ddevfs2.sh93 pthread_t threads[2];
97 if ((r = pthread_create(&threads[0], NULL, thr1, 0)) != 0)
99 if ((r = pthread_create(&threads[1], NULL, thr2, 0)) != 0)
103 if ((r = pthread_join(threads[i], NULL)) != 0)
H A Dpthread8.sh94 pthread_t *threads;
104 threads = calloc(ncpus, sizeof(pthread_t));
105 if (threads == NULL)
125 error = pthread_create(&threads[i], NULL, runner, &ra);
134 pthread_join(threads[i], NULL);
H A Dkevent2.sh137 pthread_t threads[2];
154 if ((r = pthread_create(&threads[0], NULL, thr1, 0)) != 0)
156 if ((r = pthread_create(&threads[1], NULL, thr2, 0)) != 0)
159 if ((r = pthread_join(threads[0], NULL)) != 0)
161 if ((r = pthread_join(threads[1], NULL)) != 0)
H A Dkevent.sh139 pthread_t threads[2];
158 if ((r = pthread_create(&threads[0], NULL, thr1, 0)) != 0)
160 if ((r = pthread_create(&threads[1], NULL, thr2, 0)) != 0)
163 if ((r = pthread_join(threads[0], NULL)) != 0)
165 if ((r = pthread_join(threads[1], NULL)) != 0)
/src/tools/test/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 ((r = pthread_join(threads[i], NULL)) != 0) in test()
/src/contrib/libarchive/libarchive/
H A Darchive_write_add_filter_zstd.c60 int threads; member
137 data->threads = 0; in archive_write_add_filter_zstd()
271 intmax_t threads; in archive_compressor_zstd_options() local
272 if (string_to_number(value, &threads) != ARCHIVE_OK) { in archive_compressor_zstd_options()
277 if (threads == 0) { in archive_compressor_zstd_options()
278 threads = sysconf(_SC_NPROCESSORS_ONLN); in archive_compressor_zstd_options()
282 if (threads == 0) { in archive_compressor_zstd_options()
285 threads = (intmax_t)winCores; in archive_compressor_zstd_options()
288 if (threads < 0 || threads > INT_MAX) { in archive_compressor_zstd_options()
291 data->threads = (int)threads; in archive_compressor_zstd_options()
[all …]
/src/contrib/llvm-project/lldb/source/Plugins/Trace/intel-pt/
H A DTraceIntelPTBundleLoader.cpp128 for (const JSONThread &thread : process.threads) in ParseProcess()
129 parsed_process->threads.push_back(ParseThread(*process_sp, thread)); in ParseProcess()
135 if (!process.threads.empty()) in ParseProcess()
163 parsed_process->threads.push_back(thread_sp); in ParseKernel()
249 "threads": [ in GetSchema()
337 for (JSONThread &thread : process.threads) in AugmentThreadsFromContextSwitches()
348 proc->second->threads.push_back({tid, /*ipt_trace=*/std::nullopt}); in AugmentThreadsFromContextSwitches()
373 std::vector<ThreadPostMortemTraceSP> threads; in CreateTraceIntelPTInstance() local
377 threads.insert(threads.end(), parsed_process.threads.begin(), in CreateTraceIntelPTInstance()
378 parsed_process.threads.end()); in CreateTraceIntelPTInstance()
[all …]
/src/sbin/nvmecontrol/
H A Dperftest.c53 uint32_t threads; member
62 .threads = 0,
76 OPT("threads", 'n', arg_uint32, opt, threads,
160 if (opt.threads <= 0 || opt.threads > 128) { in perftest()
161 fprintf(stderr, "Bad number of threads %d\n", opt.threads); in perftest()
164 io_test.num_threads = opt.threads; in perftest()
/src/crypto/openssl/demos/kdf/
H A Dargon2.c83 unsigned int threads; in main() local
109 threads = parallel_cost; in main()
114 threads = 1; in main()
116 threads = max_threads; in main()
130 *p++ = OSSL_PARAM_construct_uint(OSSL_KDF_PARAM_THREADS, &threads); in main()
/src/sys/contrib/openzfs/tests/zfs-tests/tests/perf/
H A Dperf.shlib45 typeset threads=$1
53 suffix="$suffix.$threads-threads.$filesystems-filesystems"
63 typeset threads=$4
69 log_note "Running with $threads $sync_str threads, $iosize ios"
73 verify_threads_per_fs "$threads" "$threads_per_fs"
82 # of the number of threads.
85 populate_perf_filesystems $((threads / threads_per_fs))
114 export FILESIZE=$((TOTAL_SIZE / threads))
115 export NUMJOBS=$threads
131 typeset suffix=$(get_suffix "$threads" "$sync" "$iosize")
[all …]
/src/contrib/llvm-project/lldb/source/API/
H A DSBThreadCollection.cpp33 SBThreadCollection::SBThreadCollection(const ThreadCollectionSP &threads) in SBThreadCollection() argument
34 : m_opaque_sp(threads) {} in SBThreadCollection()
38 void SBThreadCollection::SetOpaque(const lldb::ThreadCollectionSP &threads) { in SetOpaque() argument
39 m_opaque_sp = threads; in SetOpaque()
/src/sys/contrib/zstd/lib/common/
H A Dpool.c37 ZSTD_pthread_t* threads; member
145 … ctx->threads = (ZSTD_pthread_t*)ZSTD_customMalloc(numThreads * sizeof(ZSTD_pthread_t), customMem); in POOL_create_advanced()
149 if (!ctx->threads || !ctx->queue) { POOL_free(ctx); return NULL; } in POOL_create_advanced()
153 if (ZSTD_pthread_create(&ctx->threads[i], NULL, &POOL_thread, ctx)) { in POOL_create_advanced()
178 ZSTD_pthread_join(ctx->threads[i], NULL); /* note : could fail */ in POOL_join()
189 ZSTD_customFree(ctx->threads, ctx->customMem); in POOL_free()
217 ZSTD_memcpy(threadPool, ctx->threads, ctx->threadCapacity * sizeof(*threadPool)); in POOL_resize_internal()
218 ZSTD_customFree(ctx->threads, ctx->customMem); in POOL_resize_internal()
219 ctx->threads = threadPool; in POOL_resize_internal()
/src/sys/contrib/openzfs/module/zstd/lib/common/
H A Dpool.c38 ZSTD_pthread_t* threads; member
144 … ctx->threads = (ZSTD_pthread_t*)ZSTD_customCalloc(numThreads * sizeof(ZSTD_pthread_t), customMem); in POOL_create_advanced()
148 if (!ctx->threads || !ctx->queue) { POOL_free(ctx); return NULL; } in POOL_create_advanced()
152 if (ZSTD_pthread_create(&ctx->threads[i], NULL, &POOL_thread, ctx)) { in POOL_create_advanced()
177 ZSTD_pthread_join(ctx->threads[i]); /* note : could fail */ in POOL_join()
188 ZSTD_customFree(ctx->threads, ctx->customMem); in POOL_free()
227 ZSTD_memcpy(threadPool, ctx->threads, ctx->threadCapacity * sizeof(ZSTD_pthread_t)); in POOL_resize_internal()
228 ZSTD_customFree(ctx->threads, ctx->customMem); in POOL_resize_internal()
229 ctx->threads = threadPool; in POOL_resize_internal()
/src/contrib/llvm-project/compiler-rt/lib/sanitizer_common/
H A Dsanitizer_stoptheworld_win.cpp94 const HANDLE threads = CreateToolhelp32Snapshot(TH32CS_SNAPTHREAD, 0); in RunThread() local
95 CHECK(threads != INVALID_HANDLE_VALUE); in RunThread()
101 if (!Thread32First(threads, &thread_entry)) in RunThread()
136 } while (Thread32Next(threads, &thread_entry)); in RunThread()
138 CloseHandle(threads); in RunThread()

12345678910>>...16