| /freebsd/contrib/netbsd-tests/lib/libpthread_dbg/ |
| H A D | t_threads.c | 78 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()
167 "counted threads (%d) != expected threads (%zu)", 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()
237 "counted threads (%d) != expected threads (%zu)", 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()
[all …]
|
| /freebsd/sys/contrib/openzfs/man/man4/ |
| H A D | spl.4 | 28 The number of threads created for the spl_kmem_cache task queue.
31 For the majority of systems and workloads only a small number of threads are
133 Kick stuck taskq to spawn threads.
136 it will kick it to spawn more threads.
141 Bind taskq threads to specific CPUs.
142 When enabled all taskq threads will be distributed evenly
152 New threads will be created on demand up to a maximum allowed number
154 Threads which are no longer needed will be promptly destroyed.
159 Allow newly created taskq threads to set a non-default scheduler priority.
161 to all threads created by that taskq.
[all …]
|
| /freebsd/tools/tools/crypto/ |
| H A D | cryptorun.sh | 7 # Threads and buffer sizes move in powers of two from 1, for threads,
16 threads=1
23 while [ "$threads" -le "$max_threads" ]; do
24 echo "Testing with $threads processes."
26 $crypto -t $threads -a $1 $iterations $size
30 threads=$(($threads * 2))
|
| /freebsd/share/man/man9/ |
| H A D | kern_yield.9 | 73 context switch that yielding would be a useful service to other threads.
93 high-priority realtime or interrupt threads.
94 Kernel worker threads and timesharing threads are not guaranteed to preempt
96 Thus, threads executing in the kernel are expected to behave cooperatively
97 with respect to other threads in the system.
98 The yield functions are mostly intended to be used by threads which perform a
106 The scheduler aims to identify threads which monopolize the CPU, and will
108 Threads which regularly yield the processor will be given the chance to run
111 other threads on the CPU's runqueue, a call to
124 Otherwise, threads which have been given the chance to run could end up waiting
|
| /freebsd/contrib/llvm-project/lldb/source/Plugins/Trace/intel-pt/ |
| H A D | TraceIntelPTBundleLoader.cpp | 128 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()
139 // its threads. in ParseProcess()
157 // Add cpus as fake threads in ParseKernel()
163 parsed_process->threads.push_back(thread_sp); in ParseKernel()
190 // its threads. in ParseKernel()
249 "threads": [ in GetSchema()
250 // A list of known threads for the given process. When context switch in GetSchema()
251 // data is provided, LLDB will automatically create threads fo in GetSchema()
371 std::vector<ThreadPostMortemTraceSP> threads; CreateTraceIntelPTInstance() local
[all...] |
| /freebsd/sys/contrib/openzfs/module/zstd/lib/common/ |
| H A D | pool.c | 36 /* Keep track of the threads */
37 ZSTD_pthread_t* threads; member
47 /* The number of threads working on jobs */
78 * a few threads will be shutdown while !queueEmpty, in POOL_thread()
79 * but enough threads will remain active to finish the queue */ in POOL_thread()
139 ctx->threads = (ZSTD_pthread_t*)ZSTD_malloc(numThreads * sizeof(ZSTD_pthread_t), customMem); in POOL_create_advanced()
143 if (!ctx->threads || !ctx->queue) { POOL_free(ctx); return NULL; } in POOL_create_advanced()
144 /* Initialize the threads */ in POOL_create_advanced()
147 if (ZSTD_pthread_create(&ctx->threads[i], NULL, &POOL_thread, ctx)) { in POOL_create_advanced()
159 Shutdown the queue, wake any sleeping threads, and join all of the threads.
[all …]
|
| /freebsd/sys/contrib/zstd/lib/common/ |
| H A D | pool.c | 36 /* Keep track of the threads */
37 ZSTD_pthread_t* threads; member
47 /* The number of threads working on jobs */
78 * a few threads will be shutdown while !queueEmpty, in POOL_thread()
79 * but enough threads will remain active to finish the queue */ in POOL_thread()
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()
150 /* Initialize the threads */ in POOL_create_advanced()
153 if (ZSTD_pthread_create(&ctx->threads[i], NULL, &POOL_thread, ctx)) { in POOL_create_advanced()
165 Shutdown the queue, wake any sleeping threads, and join all of the threads.
[all …]
|
| /freebsd/contrib/netbsd-tests/lib/libc/stdlib/ |
| H A D | t_getenv_thread.c | 144 atf_tc_set_md_var(tc, "descr", "Test getenv_r(3) with threads"); in ATF_TC_HEAD()
150 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()
[all …]
|
| /freebsd/contrib/ofed/opensm/include/complib/ |
| H A D | cl_threadpool.h | 62 * The Thread Pool manages a user specified number of threads.
65 * invoking a user specified callback function. All threads in the thread
112 * Number of threads running.
135 * The cl_thread_pool_init function creates the threads to be
151 * [in] Number of threads to be managed by the thread pool.
162 * [in] Name to associate with the threads. The name may be up to 16
163 * characters, including a terminating null character. All threads
172 * CL_ERROR if the threads could not be created.
175 * cl_thread_pool_init creates and starts the specified number of threads.
176 * If thread_count is zero, the thread pool creates as many threads as there
[all …]
|
| /freebsd/sys/contrib/openzfs/tests/zfs-tests/tests/perf/ |
| H A D | perf.shlib | 44 typeset threads=$1
52 suffix="$suffix.$threads-threads.$filesystems-filesystems"
62 typeset threads=$4
68 log_note "Running with $threads $sync_str threads, $iosize ios"
72 verify_threads_per_fs $threads $threads_per_fs
81 # of the number of threads.
84 populate_perf_filesystems $((threads / threads_per_fs))
113 export FILESIZE=$((TOTAL_SIZE / threads))
114 export NUMJOBS=$threads
130 typeset suffix=$(get_suffix $threads $sync $iosize)
[all …]
|
| /freebsd/contrib/llvm-project/llvm/include/llvm/Support/ |
| H A D | ThreadPool.h | 36 /// asynchronous parallel execution on a defined number of threads.
43 /// It is also possible for worker threads to submit new tasks and wait for
46 /// available threads are used up by tasks waiting for a task that has no thread
60 /// Blocking wait for all the threads to complete and the queue to be empty.
65 /// Blocking wait for only all the threads in the given group to complete.
120 /// A ThreadPool implementation using std::threads.
122 /// The pool keeps a vector of threads alive, waiting on a condition variable
127 /// execution resources (threads, cores, CPUs)
132 /// Blocking destructor: the pool will wait for all the threads to complete.
135 /// Blocking wait for all the threads to complete and the queue to be empty.
[all …]
|
| /freebsd/contrib/llvm-project/compiler-rt/lib/sanitizer_common/ |
| H A D | sanitizer_stoptheworld_win.cpp | 93 // Take a snapshot of all Threads in RunThread()
94 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()
141 // relevant Threads, new Threads could have potentially been created. So in RunThread()
142 // continue to find and suspend new Threads until we don't find any. in RunThread()
145 // Now all Threads of this Process except of this Thread should be suspended. in RunThread()
149 // Resume all Threads in RunThread()
|
| /freebsd/contrib/llvm-project/lldb/source/Target/ |
| H A D | ThreadList.cpp | 230 // The ShouldStop method of the threads can do a whole lot of work, figuring in ShouldStop()
233 // FIXME: It is possible that running code could cause new threads in ShouldStop()
236 // any interesting operations on those threads yet. in ShouldStop()
261 // It is possible the threads we were allowing to run all exited and then in ShouldStop()
263 // all threads: in ShouldStop()
274 "ThreadList::%s: %" PRIu64 " threads, %" PRIu64 in ShouldStop()
275 " unsuspended threads", in ShouldStop()
293 // Now we run through all the threads and get their stop info's. We want to in ShouldStop()
319 // and a bunch of threads hit the breakpoint, but not the thread which we in ShouldStop()
320 // are waiting for. All the threads that are not "supposed" to hit the in ShouldStop()
[all …]
|
| /freebsd/contrib/llvm-project/compiler-rt/lib/tsan/benchmarks/ |
| H A D | vts_many_threads_bench.cpp | 3 // 1) Spawn M + N threads (M >> N)
4 // We'll call the 'M' threads as 'garbage threads'.
5 // 2) Make sure all threads have created thus no TIDs were reused
6 // 3) Join the garbage threads
7 // 4) Do many sync operations on the remaining N threads
58 // Wait for the main thread to join the garbage threads. in Thread()
105 printf("All threads started! Killing the garbage threads.\n"); in main()
111 printf("Resuming the main threads.\n"); in main()
|
| /freebsd/share/man/man3/ |
| H A D | pthread_barrier_destroy.3 | 51 The number of threads that must call
53 before any of the waiting threads can be
64 function will synchronize calling threads at
66 The threads will be blocked from
68 a sufficient number of threads calls this function.
69 The number of threads that must call it before
74 Once the threads have been released the barrier will be reset.
92 is successful, all but one of the threads will return zero.
|
| /freebsd/sys/contrib/openzfs/include/os/linux/spl/sys/ |
| H A D | taskq.h | 85 wmsum_t tqs_threads_active; /* threads running a task */
86 wmsum_t tqs_threads_idle; /* threads waiting for work */
87 wmsum_t tqs_threads_total; /* total threads */
95 wmsum_t tqs_threads_created; /* threads created */
96 wmsum_t tqs_threads_destroyed; /* threads destroyed */
113 struct list_head tq_thread_list; /* list of all threads */
114 struct list_head tq_active_list; /* list of active threads */
115 int tq_nactive; /* # of active threads */
116 int tq_nthreads; /* # of existing threads */
117 int tq_nspawn; /* # of threads being spawned */
[all …]
|
| /freebsd/sbin/nvmecontrol/ |
| H A D | perftest.c | 53 uint32_t threads; member
62 .threads = 0,
76 OPT("threads", 'n', arg_uint32, opt, threads,
77 "Number of threads to run"),
122 printf("Threads: %2d Size: %6d %5s Time: %3d IO/s: %7ju MB/s: %4ju\n", in print_perftest()
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()
|
| /freebsd/contrib/llvm-project/llvm/lib/Support/ |
| H A D | ThreadPool.cpp | 40 if (Threads.size() >= MaxThreadCount) in grow()
43 while (static_cast<int>(Threads.size()) < newThreadCount) { in grow()
44 int ThreadID = Threads.size(); in grow()
45 Threads.emplace_back([this, ThreadID] { in grow()
87 // Need to count active threads in each group separately, ActiveThreads in processTasks()
128 // If this was a task in a group, notify also threads waiting for tasks in processTasks()
146 // Wait for all threads to complete and the queue to be empty in wait()
153 // Wait for all threads in the group to complete. in wait()
172 for (const llvm::thread &Thread : Threads) in isWorkerThread()
178 // The destructor joins all threads, waiting for completion.
[all …]
|
| /freebsd/contrib/llvm-project/lldb/bindings/interface/ |
| H A D | SBProcessExtensions.i | 67 '''An accessor function that returns a list() that contains all threads in a lldb.SBProcess object.'''
68 threads = []
71 threads.append(accessor[idx])
72 return threads
75 '''Iterate over all threads in a lldb.SBProcess object.'''
79 '''Return the number of threads in a lldb.SBProcess object.'''
85 threads = property(get_process_thread_list, None, doc='''A read only property that returns a list() of lldb.SBThread objects for this process.''')
86 thread = property(get_threads_access_object, None, doc='''A read only property that returns an object that can access threads by thread index (thread = lldb.process.thread[12]).''')
92 num_threads = property(GetNumThreads, None, doc='''A read only property that returns the number of threads in this process as an integer.''')
|
| /freebsd/crypto/openssl/ |
| H A D | NOTES-NONSTOP.md | 29 OpenSSL can be built using unthreaded, POSIX User Threads (PUT), or Standard
30 POSIX Threads (SPT). Select the following build configuration for each on
218 --openssldir=${PWD}/ssl no-threads \
221 --openssldir=${PWD}/ssl no-threads \
224 --openssldir=${PWD}/ssl threads "-D_REENTRANT" \
227 --openssldir=${PWD}/ssl threads "-D_REENTRANT" \
230 --openssldir=${PWD}/ssl no-threads \
233 --openssldir=${PWD}/ssl threads "-D_REENTRANT" \
236 --openssldir=${PWD}/ssl no-threads \
240 --openssldir=${PWD}/ssl no-threads \
[all …]
|
| /freebsd/contrib/ntp/sntp/libevent/ |
| H A D | iocp-internal.h | 80 /** Number of threads ever open on the port. */
82 /** True iff we're shutting down all the threads on this port */
84 /** How often the threads on this port check for shutdown and other
87 /* The threads that are waiting for events. */
88 HANDLE *threads; member
89 /** Number of threads currently open on this port. */
161 /** Create an IOCP, and launch its worker threads. Internal use only.
169 fd will happen on one of the iocp's worker threads.
175 /** Tell all threads serving an iocp to stop. Wait for up to waitMsec for all
176 the threads to finish whatever they're doing. If waitMsec is -1, wait
[all …]
|
| /freebsd/contrib/libevent/ |
| H A D | iocp-internal.h | 80 /** Number of threads ever open on the port. */
82 /** True iff we're shutting down all the threads on this port */
84 /** How often the threads on this port check for shutdown and other
87 /* The threads that are waiting for events. */
88 HANDLE *threads; member
89 /** Number of threads currently open on this port. */
161 /** Create an IOCP, and launch its worker threads. Internal use only.
169 fd will happen on one of the iocp's worker threads.
175 /** Tell all threads serving an iocp to stop. Wait for up to waitMsec for all
176 the threads to finish whatever they're doing. If waitMsec is -1, wait
[all …]
|
| /freebsd/contrib/unbound/doc/ |
| H A D | unbound-control.8.in | 60 That means the caches sizes and the number of threads must not change between
187 being serviced from other threads.
500 summed over threads.
503 summed over threads.
506 summed over threads.
509 summed over threads.
512 summed over threads.
515 summed over threads.
518 summed over threads.
521 summed over threads.
[all …]
|
| /freebsd/crypto/openssl/Configurations/ |
| H A D | 10-main.conf | 245 cflags => add(threads("-pthread")),
247 ex_libs => add(threads("-pthread")),
268 cflags => add_before("-m64", threads("-pthread")),
270 ex_libs => add(threads("-pthread")),
298 cppflags => add(threads("-D_REENTRANT")),
301 lflags => add(threads("-mt")),
302 ex_libs => add(threads("-lpthread")),
318 cflags => add(threads("-pthread")),
320 ex_libs => add(threads("-pthread")),
356 cppflags => add(threads("-D_REENTRANT")),
[all …]
|
| /freebsd/contrib/libder/tests/ |
| H A D | fuzz_parallel.c | 78 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()
|