| /src/sys/external/bsd/compiler_rt/dist/lib/tsan/tests/rtl/ |
| tsan_thread.cc | 50 pthread_t threads[kAlive] = {}; local 52 if (threads[i % kAlive]) 53 pthread_join(threads[i % kAlive], 0); 54 pthread_create(&threads[i % kAlive], 0, thread_alot_func, 0); 57 pthread_join(threads[i], 0);
|
| tsan_mutex.cc | 192 // Create reader threads. 193 pthread_t threads[kThreadCount]; local 195 pthread_create(&threads[t], 0, singleton_thread, &singleton); 197 pthread_join(threads[t], 0);
|
| /src/external/bsd/zstd/dist/contrib/pzstd/utils/test/ |
| WorkQueueTest.cpp | 96 std::vector<std::thread> threads; local 98 threads.emplace_back(Popper{&queue, results.data(), &mutex}); 106 for (auto& thread : threads) {
|
| /src/external/gpl3/binutils/dist/gprofng/src/ |
| DbeThread.h | 53 Vector<pthread_t> *threads; member in class:DbeThreadPool
|
| /src/external/gpl3/binutils.old/dist/gprofng/src/ |
| DbeThread.h | 53 Vector<pthread_t> *threads; member in class:DbeThreadPool
|
| /src/external/apache2/llvm/dist/libcxx/utils/google-benchmark/src/ |
| benchmark_api_internal.h | 35 int threads; // Number of concurrent threads to us member in struct:benchmark::internal::BenchmarkInstance
|
| /src/external/apache2/llvm/dist/llvm/utils/benchmark/src/ |
| benchmark_api_internal.h | 33 int threads; // Number of concurrent threads to us member in struct:benchmark::internal::Benchmark::Instance
|
| /src/sys/arch/x86/x86/ |
| cpu_topology.c | 191 const u_int threads = __SHIFTOUT(descs[1], local 195 smt_bits = ilog2(threads);
|
| /src/sys/external/bsd/compiler_rt/dist/lib/sanitizer_common/tests/ |
| sanitizer_mutex_test.cc | 107 pthread_t threads[kThreads]; local 109 PTHREAD_CREATE(&threads[i], 0, lock_thread<SpinMutex>, &data); 111 PTHREAD_JOIN(threads[i], 0); 118 pthread_t threads[kThreads]; local 120 PTHREAD_CREATE(&threads[i], 0, try_thread<SpinMutex>, &data); 122 PTHREAD_JOIN(threads[i], 0); 129 pthread_t threads[kThreads]; local 131 PTHREAD_CREATE(&threads[i], 0, lock_thread<BlockingMutex>, &data); 133 PTHREAD_JOIN(threads[i], 0);
|
| /src/sys/external/bsd/compiler_rt/dist/lib/tsan/tests/unit/ |
| tsan_mutex_test.cc | 99 pthread_t threads[kThreads]; local 101 pthread_create(&threads[i], 0, write_mutex_thread<Mutex>, &data); 103 pthread_join(threads[i], 0); 109 pthread_t threads[kThreads]; local 111 pthread_create(&threads[i], 0, read_mutex_thread<Mutex>, &data); 113 pthread_join(threads[i], 0); 119 pthread_t threads[kThreads]; local 121 pthread_create(&threads[i], 0, write_mutex_thread<SpinMutex>, &data); 123 pthread_join(threads[i], 0);
|
| /src/tests/lib/libc/stdlib/ |
| t_getenv_thread.c | 144 atf_tc_set_md_var(tc, "descr", "Test getenv_r(3) with threads"); 150 pthread_t threads[THREADED_NUM_THREADS]; local 158 ATF_CHECK(pthread_create(&threads[i++], NULL, thread_getenv_r, 163 ATF_CHECK(pthread_join(threads[j], NULL) == 0); 175 pthread_t threads[THREADED_NUM_THREADS]; local 183 ATF_CHECK(pthread_create(&threads[i++], NULL, thread_putenv, 188 ATF_CHECK(pthread_join(threads[j], NULL) == 0); 200 pthread_t threads[THREADED_NUM_THREADS]; local 208 ATF_CHECK(pthread_create(&threads[i++], NULL, thread_setenv, 213 ATF_CHECK(pthread_join(threads[j], NULL) == 0) 225 pthread_t threads[THREADED_NUM_THREADS]; local [all...] |
| /src/tests/lib/libpthread/ |
| t_sem.c | 159 pthread_t threads[NTHREADS]; local 190 PTHREAD_REQUIRE(pthread_create(&threads[i], NULL, 201 PTHREAD_REQUIRE(pthread_join(threads[i], NULL));
|
| h_resolv.c | 146 pthread_t *threads; local 180 if ((threads = malloc(nthreads * sizeof(pthread_t))) == NULL) 186 threads[i] = run(&nleft[i]); 208 pthread_join(threads[i], NULL); 209 free(threads);
|
| t_once.c | 113 pthread_t threads[NTHREADS]; local 121 PTHREAD_REQUIRE(pthread_create(&threads[i], NULL, once2_threadfunc, &id[i])); 125 PTHREAD_REQUIRE(pthread_join(threads[i], NULL));
|
| /src/external/bsd/libevent/dist/ |
| iocp-internal.h | 81 /** Number of threads ever open on the port. */ 83 /** True iff we're shutting down all the threads on this port */ 85 /** How often the threads on this port check for shutdown and other 88 /* The threads that are waiting for events. */ 89 HANDLE *threads; member in struct:event_iocp_port 90 /** Number of threads currently open on this port. */ 162 /** Create an IOCP, and launch its worker threads. Internal use only. 170 fd will happen on one of the iocp's worker threads. 176 /** Tell all threads serving an iocp to stop. Wait for up to waitMsec for all 177 the threads to finish whatever they're doing. If waitMsec is -1, wai [all...] |
| /src/external/bsd/ntp/dist/sntp/libevent/ |
| iocp-internal.h | 82 /** Number of threads ever open on the port. */ 84 /** True iff we're shutting down all the threads on this port */ 86 /** How often the threads on this port check for shutdown and other 89 /* The threads that are waiting for events. */ 90 HANDLE *threads; member in struct:event_iocp_port 91 /** Number of threads currently open on this port. */ 163 /** Create an IOCP, and launch its worker threads. Internal use only. 171 fd will happen on one of the iocp's worker threads. 177 /** Tell all threads serving an iocp to stop. Wait for up to waitMsec for all 178 the threads to finish whatever they're doing. If waitMsec is -1, wai [all...] |
| /src/lib/libcrypt/ |
| pw_gensalt.c | 175 uint32_t threads = 0; local 208 threads = tmp; 225 threads < ARGON2_MIN_THREADS) { 226 estimate_argon2_params(atype, &time, &memory, &threads); 229 snprintf(dst, dlen, "m=%d,t=%d,p=%d", memory, time, threads);
|
| crypt-argon2.c | 165 uint32_t threads = 1; local 216 if (argon2_hash(time, memory, threads, 239 *ethreads = threads; 244 threads = 1; 309 * threads (p) 334 ctx->threads = tmp; 422 ctx.threads, pw, strlen(pw), ctx.salt, ctx.saltlen,
|
| /src/sys/external/bsd/compiler_rt/dist/lib/sanitizer_common/ |
| sanitizer_stoptheworld_mac.cc | 58 thread_array_t threads; local 60 kern_return_t err = task_threads(mach_task_self(), &threads, &num_threads); 62 VReport(1, "Failed to get threads for task (errno %d).\n", err); 68 if (threads[i] == thread_self) continue; 70 thread_suspend(threads[i]); 71 suspended_threads_list.Append(threads[i]);
|
| /src/external/apache2/argon2/dist/phc-winner-argon2/src/ |
| core.h | 79 uint32_t threads; member in struct:Argon2_instance_t 87 * work between threads. 211 * threads
|
| run.c | 55 printf("\t-p N\t\tSets parallelism to N threads (default %d)\n", 88 @threads actual parallelism 95 uint32_t m_cost, uint32_t lanes, uint32_t threads, 134 result = argon2_hash(t_cost, m_cost, threads, pwd, pwdlen, salt, saltlen, 175 uint32_t threads = THREADS_DEF; local 272 threads = input; 273 lanes = threads; 332 run(outlen, pwd, pwdlen, salt, t_cost, m_cost, lanes, threads, type,
|
| /src/external/bsd/top/dist/ |
| machine.h | 64 unsigned int threads : 1; member in struct:statics::__anon5851 109 int threads; /* show threads separately */ member in struct:process_select
|
| /src/external/bsd/zstd/dist/examples/ |
| streaming_compression_thread_pool.c | 34 fprintf (stderr, "Starting compression of %s with level %d, using %d threads\n", args->fname, args->cLevel, nbThreads); 154 fprintf (stderr, "All threads use its own thread pool\n"); 157 pthread_t *threads = malloc_orDie(argc * sizeof(pthread_t)); local 169 pthread_create (&threads[i], NULL, compressFile_orDie, &args[i]); 173 pthread_join (threads[i], NULL);
|
| /src/external/gpl3/gcc.old/dist/libsanitizer/sanitizer_common/ |
| sanitizer_stoptheworld_mac.cpp | 57 thread_array_t threads; local 59 kern_return_t err = task_threads(mach_task_self(), &threads, &num_threads); 61 VReport(1, "Failed to get threads for task (errno %d).\n", err); 67 if (threads[i] == thread_self) continue; 69 thread_suspend(threads[i]); 70 suspended_threads_list.Append(threads[i]);
|
| /src/sys/external/bsd/compiler_rt/dist/lib/asan/tests/ |
| asan_interface_test.cc | 125 pthread_t threads[kManyThreadsNumThreads]; local 128 PTHREAD_CREATE(&threads[i], 0, 132 PTHREAD_JOIN(threads[i], 0);
|