| /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/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);
|
| sanitizer_thread_registry_test.cc | 71 // Create a bunch of threads.
81 // Finish, create and start more threads.
108 // Detach and finish and join remaining threads.
204 pthread_t threads[kNumShards]; local
209 PTHREAD_CREATE(&threads[i], 0, RunThread, &args[i]);
212 PTHREAD_JOIN(threads[i], 0);
215 // of "threads" in thread_registry.
|
| /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/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]);
|
| sanitizer_stoptheworld_linux_libcdep.cc | 69 // thread in the caller process with ptrace. This suspends the threads, and
71 // supplied to StopTheWorld() is run in the tracer task while the threads are
80 // 1. calling a library function while threads are suspended could cause a
141 // Currently this check takes linear time, however the number of threads is
213 InternalMmapVector<tid_t> threads; local
214 threads.reserve(128);
217 switch (thread_lister.ListThreads(&threads)) {
227 for (tid_t tid : threads)
244 // This really only works correctly if all the threads are suspended at this
255 // Signal handler to wake up suspended threads when the tracer thread dies
[all...] |
| /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);
|
| /src/sys/external/bsd/compiler_rt/dist/lib/tsan/rtl/ |
| tsan_report.h | 116 Vector<ReportThread*> threads; member in class:__tsan::ReportDesc
|
| /src/sys/external/isc/libsodium/dist/src/libsodium/crypto_pwhash/argon2/ |
| argon2-core.h | 104 uint32_t threads; member in struct:Argon2_instance_t
111 * work between threads.
272 * threads
|
| argon2.h | 27 /* Minimum and maximum number of threads */
145 * number of parallel threads that will be run.
182 uint32_t threads; /* maximum number of threads */ member in struct:Argon2_Context
201 * @param parallelism Number of threads and compute lanes
222 * @param parallelism Number of threads and compute lanes
243 * @param parallelism Number of threads and compute lanes
262 * @param parallelism Number of threads and compute lanes
|
| /src/sys/fs/nfs/common/ |
| nfs_fha.h | 60 * avoid contention between threads over single files.
69 struct svcthread_list threads; member in struct:fha_hash_entry
|
| /src/sys/external/bsd/drm2/dist/drm/i915/selftests/ |
| i915_request.c | 434 struct task_struct **threads; local
440 * threads. A very simple test to only catch the most egregious of bugs.
444 threads = kcalloc(ncpus, sizeof(*threads), GFP_KERNEL);
445 if (!threads)
463 threads[n] = kthread_run(__igt_breadcrumbs_smoketest,
465 if (IS_ERR(threads[n])) {
466 ret = PTR_ERR(threads[n]);
471 get_task_struct(threads[n]);
474 yield(); /* start all threads before we begin *
1328 struct task_struct **threads; local
[all...] |
| /src/sys/external/bsd/drm2/dist/drm/i915/gt/ |
| selftest_hangcheck.c | 794 struct active_engine threads[I915_NUM_ENGINES] = {}; local
811 memset(threads, 0, sizeof(threads));
815 threads[tmp].resets =
824 threads[tmp].engine = other;
825 threads[tmp].flags = flags;
827 tsk = kthread_run(active_engine, &threads[tmp],
834 threads[tmp].task = tsk;
838 yield(); /* start all threads before we begin */
920 reported -= threads[engine->id].resets
[all...] |
| /src/sys/dev/ |
| smbiosvar.h | 241 uint8_t threads; /* threads per socket */ member in struct:smbios_processor
|
| /src/sys/stand/efiboot/ |
| smbios.h | 236 uint8_t threads; /* threads per socket */ member in struct:smbios_processor
|
| /src/usr.sbin/cpuctl/arch/ |
| i386.c | 1926 const u_int threads = ((descs[1] >> 8) & 0xff) + 1; local
1927 smt_bits = ilog2(threads);
|
