Home
last modified time | relevance | path

Searched refs:nthreads (Results 1 – 25 of 42) sorted by relevance

12

/freebsd-12.1/contrib/gcclibs/libgomp/
H A Dteam.c152 team->nthreads = nthreads; in new_team()
191 team = new_team (nthreads, work_share); in gomp_team_start()
204 if (nthreads == 1) in gomp_team_start()
218 if (nthreads <= old_threads_used) in gomp_team_start()
219 n = nthreads; in gomp_team_start()
237 gomp_threads_used = nthreads; in gomp_team_start()
253 if (i == nthreads) in gomp_team_start()
259 if (nthreads >= gomp_threads_size) in gomp_team_start()
261 gomp_threads_size = nthreads + 1; in gomp_team_start()
281 * (nthreads-i)); in gomp_team_start()
[all …]
H A Dordered.c46 if (team == NULL || team->nthreads == 1) in gomp_ordered_first()
50 if (index >= team->nthreads) in gomp_ordered_first()
51 index -= team->nthreads; in gomp_ordered_first()
77 if (team == NULL || team->nthreads == 1) in gomp_ordered_last()
87 if (next == team->nthreads) in gomp_ordered_last()
112 if (team == NULL || team->nthreads == 1) in gomp_ordered_next()
133 if (index >= team->nthreads) in gomp_ordered_next()
134 index -= team->nthreads; in gomp_ordered_next()
139 if (index == team->nthreads) in gomp_ordered_next()
157 if (team == NULL || team->nthreads == 1) in gomp_ordered_static_init()
[all …]
H A Diter.c46 unsigned long nthreads = team ? team->nthreads : 1; in gomp_iter_static_next() local
52 if (nthreads == 1) in gomp_iter_static_next()
79 q = n / nthreads; in gomp_iter_static_next()
80 q += (q * nthreads != n); in gomp_iter_static_next()
117 s0 = (thr->ts.static_trip * nthreads + i) * c; in gomp_iter_static_next()
238 unsigned long nthreads = team ? team->nthreads : 1; in gomp_iter_guided_next_locked() local
247 q = (n + nthreads - 1) / nthreads; in gomp_iter_guided_next_locked()
272 unsigned long nthreads = team ? team->nthreads : 1; in gomp_iter_guided_next() local
290 q = (n + nthreads - 1) / nthreads; in gomp_iter_guided_next()
H A Dwork.c39 gomp_new_work_share (bool ordered, unsigned nthreads) in gomp_new_work_share() argument
46 size += nthreads * sizeof (ws->ordered_team_ids[0]); in gomp_new_work_share()
130 ws = gomp_new_work_share (ordered, team->nthreads); in gomp_work_share_start()
208 if (completed == team->nthreads) in gomp_work_share_end_nowait()
H A Dparallel.c87 return team ? team->nthreads : 1; in omp_get_num_threads()
115 if (team->nthreads > 1) in omp_in_parallel()
H A Dlibgomp.h185 unsigned nthreads; member
/freebsd-12.1/cddl/contrib/opensolaris/lib/libzpool/common/
H A Dtaskq.c240 taskq_create(const char *name, int nthreads, pri_t pri, in taskq_create() argument
248 ASSERT3S(nthreads, >=, 0); in taskq_create()
249 ASSERT3S(nthreads, <=, 100); in taskq_create()
250 pct = MIN(nthreads, 100); in taskq_create()
254 nthreads = MAX(nthreads, 1); /* need at least 1 thread */ in taskq_create()
256 ASSERT3S(nthreads, >=, 1); in taskq_create()
266 tq->tq_active = nthreads; in taskq_create()
267 tq->tq_nthreads = nthreads; in taskq_create()
281 for (t = 0; t < nthreads; t++) in taskq_create()
292 int nthreads = tq->tq_nthreads; in taskq_destroy() local
[all …]
/freebsd-12.1/tools/tools/netrate/netreceive/
H A Dnetreceive.c127 make_threads(int *s, int nsock, int nthreads) in make_threads() argument
129 int i, si, nt = nsock * nthreads; in make_threads()
159 main_thread(struct td_desc **tp, int nsock, int nthreads) in main_thread() argument
168 int i, nt = nsock * nthreads; in main_thread()
201 int error, v, nthreads = 1; in main() local
219 nthreads = strtoul(argv[2], &dummy, 10); in main()
220 if (nthreads < 1 || nthreads > 64) in main()
267 nsock, nthreads, (u_short)port); in main()
269 tp = make_threads(s, nsock, nthreads); in main()
270 main_thread(tp, nsock, nthreads); in main()
/freebsd-12.1/sys/mips/beri/
H A Dberi_mp.c71 int ncores, ncpus, nthreads; in platform_cpu_mask() local
78 nthreads = beri_get_nthreads(); in platform_cpu_mask()
80 KASSERT(nthreads <= 0x10000, ("%s: too many threads %d", __func__, in platform_cpu_mask()
81 nthreads)); in platform_cpu_mask()
82 KASSERT(ncores < 0xffff || nthreads < 0xffff, in platform_cpu_mask()
84 nthreads)); in platform_cpu_mask()
85 ncpus = ncores * nthreads; in platform_cpu_mask()
90 ncores, nthreads); in platform_cpu_mask()
/freebsd-12.1/sys/cddl/compat/opensolaris/kern/
H A Dopensolaris_taskq.c66 taskq_create(const char *name, int nthreads, pri_t pri, int minalloc __unused, in taskq_create() argument
72 nthreads = MAX((mp_ncpus * nthreads) / 100, 1); in taskq_create()
77 (void) taskqueue_start_threads(&tq->tq_queue, nthreads, pri, "%s", name); in taskq_create()
83 taskq_create_proc(const char *name, int nthreads, pri_t pri, int minalloc, in taskq_create_proc() argument
87 return (taskq_create(name, nthreads, pri, minalloc, maxalloc, flags)); in taskq_create_proc()
/freebsd-12.1/sys/powerpc/powernv/
H A Dplatform_powernv.c411 int res, nthreads; in powernv_smp_topo() local
423 nthreads = 1; in powernv_smp_topo()
432 nthreads = res / sizeof(cell_t); in powernv_smp_topo()
434 nthreads = 1; in powernv_smp_topo()
438 if (mp_ncpus % nthreads != 0) { in powernv_smp_topo()
441 mp_ncpus, nthreads); in powernv_smp_topo()
446 if (nthreads == 1) in powernv_smp_topo()
449 return (smp_topo_1level(CG_SHARE_L1, nthreads, CG_FLAG_SMT)); in powernv_smp_topo()
/freebsd-12.1/contrib/netbsd-tests/lib/libpthread/
H A Dh_resolv.c144 int nthreads = NTHREADS; in main() local
160 nthreads = atoi(optarg); in main()
172 if ((nleft = malloc(nthreads * sizeof(int))) == NULL) in main()
180 for (i = 0; i < nthreads; i++) { in main()
187 for (i = 0; i < nthreads; i++) { in main()
/freebsd-12.1/usr.bin/sort/
H A Dradixsort.c106 if (sort_left == 0 && nthreads > 1) in sort_left_dec()
152 if (nthreads > 1) { in push_ls()
609 if (nthreads < 2) { in run_top_sort_level()
616 for(i = 0; i < nthreads; ++i) { in run_top_sort_level()
638 for (i = 0; i < nthreads; ++i) in run_top_sort_level()
650 size_t nthreads_save = nthreads; in run_sort()
652 nthreads = 1; in run_sort()
654 if (nthreads > 1) { in run_sort()
686 if (nthreads > 1) { in run_sort()
690 nthreads = nthreads_save; in run_sort()
H A Dsort.c109 size_t nthreads = 1; variable
293 nthreads = ncpu; in set_hw_params()
1104 nthreads = (size_t)(atoi(optarg)); in main()
1105 if (nthreads < 1) in main()
1106 nthreads = 1; in main()
1107 if (nthreads > 1024) in main()
1108 nthreads = 1024; in main()
1213 nthreads = 1; in main()
1255 nthreads = 1; in main()
H A Dfile.c1511 if (nthreads < 2 || list->count < MT_SORT_THRESHOLD) { in mt_sort()
1512 size_t nthreads_save = nthreads; in mt_sort()
1513 nthreads = 1; in mt_sort()
1521 nthreads = nthreads_save; in mt_sort()
1530 avgsize = list->count / nthreads; in mt_sort()
1536 for (i = 0; i < nthreads; ++i) { in mt_sort()
1544 sz = (i == nthreads - 1) ? list->count - cstart : in mt_sort()
1558 for (i = 0; i < nthreads; ++i) { in mt_sort()
1582 for (i = 0; i < nthreads; ++i) { in mt_sort()
1589 merge_list_parts(parts, nthreads, fn); in mt_sort()
[all …]
H A Dsort.h60 extern size_t nthreads;
/freebsd-12.1/cddl/contrib/opensolaris/tools/ctf/cvt/
H A Dbarrier.c49 barrier_init(barrier_t *bar, int nthreads) in barrier_init() argument
59 bar->bar_nthr = nthreads; in barrier_init()
/freebsd-12.1/lib/libc/tests/resolv/
H A Dresolv_test.c232 int nthreads = NTHREADS; in run_tests() local
243 nleft = malloc(nthreads * sizeof(int)); in run_tests()
252 for (i = 0; i < nthreads; i++) { in run_tests()
259 for (i = 0; i < nthreads; i++) { in run_tests()
/freebsd-12.1/contrib/openmp/runtime/src/
H A Dkmp_tasking.cpp2590 nthreads = task_team->tt.tt_nproc; in __kmp_execute_tasks_template()
2595 KMP_DEBUG_ASSERT(nthreads > 1); in __kmp_execute_tasks_template()
2771 if (nthreads == 1) in __kmp_execute_tasks_template()
2816 int nthreads, i, is_init_thread; in __kmp_enable_tasking() local
2824 nthreads = task_team->tt.tt_nproc; in __kmp_enable_tasking()
2825 KMP_DEBUG_ASSERT(nthreads > 0); in __kmp_enable_tasking()
2847 for (i = 0; i < nthreads; i++) { in __kmp_enable_tasking()
2977 kmp_int32 nthreads, maxthreads; in __kmp_realloc_task_threads_data() local
3000 if (maxthreads < nthreads) { in __kmp_realloc_task_threads_data()
3100 int nthreads; in __kmp_allocate_task_team() local
[all …]
/freebsd-12.1/tools/tools/netmap/
H A Dpkt-gen.c266 int nthreads; member
1301 if (targ->g->nthreads > 1) { in ping_body()
1481 if (targ->g->nthreads > 1) { in pong_body()
1929 if (targ->g->nthreads > 1) { in txseq_body()
2512 if (g->nthreads > 1) { in start_threads()
2642 if (done == g->nthreads) in main_thread()
2812 g.nthreads = 1; in main()
2956 g.nthreads = atoi(optarg); in main()
3105 if (g.nthreads > 1) { in main()
3136 if (g.nthreads < 1 || g.nthreads > devqueues) { in main()
[all …]
/freebsd-12.1/contrib/jemalloc/include/jemalloc/internal/
H A Darena_externs.h20 unsigned *nthreads, const char **dss, ssize_t *dirty_decay_ms,
22 void arena_stats_merge(tsdn_t *tsdn, arena_t *arena, unsigned *nthreads,
H A Darena_structs_b.h91 atomic_u_t nthreads[2]; member
/freebsd-12.1/usr.bin/sort/nls/
H A DC.msg16 …files0-from file] [--heapsort] [--mergesort] [--radixsort] [--qsort] [--nthreads thread_no] [--hum…
H A Dhu_HU.ISO8859-2.msg16 …files0-from f�jl] [--heapsort] [--mergesort] [--radixsort] [--qsort] [--nthreads sz�lak_sz�ma] [--…
/freebsd-12.1/contrib/jemalloc/src/
H A Darena.c64 arena_basic_stats_merge(UNUSED tsdn_t *tsdn, arena_t *arena, unsigned *nthreads, in arena_basic_stats_merge() argument
67 *nthreads += arena_nthreads_get(arena, false); in arena_basic_stats_merge()
77 arena_stats_merge(tsdn_t *tsdn, arena_t *arena, unsigned *nthreads, in arena_stats_merge() argument
83 arena_basic_stats_merge(tsdn, arena, nthreads, dss, dirty_decay_ms, in arena_stats_merge()
1743 return atomic_load_u(&arena->nthreads[internal], ATOMIC_RELAXED); in arena_nthreads_get()
1748 atomic_fetch_add_u(&arena->nthreads[internal], 1, ATOMIC_RELAXED); in arena_nthreads_inc()
1753 atomic_fetch_sub_u(&arena->nthreads[internal], 1, ATOMIC_RELAXED); in arena_nthreads_dec()
1781 atomic_store_u(&arena->nthreads[0], 0, ATOMIC_RELAXED); in arena_new()
1782 atomic_store_u(&arena->nthreads[1], 0, ATOMIC_RELAXED); in arena_new()
2005 atomic_store_u(&arena->nthreads[0], 0, ATOMIC_RELAXED); in arena_postfork_child()
[all …]

12