Searched refs:nthreads (Results 1 - 25 of 35) sorted by relevance

12

/freebsd-12-stable/contrib/gcclibs/libgomp/
H A Dordered.c46 if (team == NULL || team->nthreads == 1)
50 if (index >= team->nthreads)
51 index -= team->nthreads;
77 if (team == NULL || team->nthreads == 1)
87 if (next == team->nthreads)
112 if (team == NULL || team->nthreads == 1)
130 if (ws->ordered_num_used < team->nthreads)
133 if (index >= team->nthreads)
134 index -= team->nthreads;
139 if (index == team->nthreads)
[all...]
H A Dteam.c137 new_team (unsigned nthreads, struct gomp_work_share *work_share) argument
142 size = sizeof (*team) + nthreads * sizeof (team->ordered_release[0]);
152 team->nthreads = nthreads;
153 gomp_barrier_init (&team->barrier, nthreads);
178 gomp_team_start (void (*fn) (void *), void *data, unsigned nthreads, argument
191 team = new_team (nthreads, work_share);
204 if (nthreads == 1)
218 if (nthreads <= old_threads_used)
219 n = nthreads;
[all...]
H A Diter.c46 unsigned long nthreads = team ? team->nthreads : 1; local
52 if (nthreads == 1)
79 q = n / nthreads;
80 q += (q * nthreads != n);
115 /* Initial guess is a C sized chunk positioned nthreads iterations
117 s0 = (thr->ts.static_trip * nthreads + i) * c;
238 unsigned long nthreads = team ? team->nthreads : 1; local
247 q = (n + nthreads
272 unsigned long nthreads = team ? team->nthreads : 1; local
[all...]
H A Dparallel.c88 return team ? team->nthreads : 1;
116 if (team->nthreads > 1)
H A Dwork.c39 gomp_new_work_share (bool ordered, unsigned nthreads) argument
46 size += nthreads * sizeof (ws->ordered_team_ids[0]);
130 ws = gomp_new_work_share (ordered, team->nthreads);
208 if (completed == team->nthreads)
H A Dlibgomp.h185 unsigned nthreads; member in struct:gomp_team
/freebsd-12-stable/cddl/contrib/opensolaris/tools/ctf/cvt/
H A Dbarrier.c49 barrier_init(barrier_t *bar, int nthreads) argument
59 bar->bar_nthr = nthreads;
/freebsd-12-stable/sys/cddl/compat/opensolaris/kern/
H A Dopensolaris_taskq.c68 taskq_create_impl(const char *name, int nthreads, pri_t pri, proc_t *proc, argument
74 nthreads = MAX((mp_ncpus * nthreads) / 100, 1);
79 (void) taskqueue_start_threads_in_proc(&tq->tq_queue, nthreads, pri,
86 taskq_create(const char *name, int nthreads, pri_t pri, int minalloc __unused, argument
89 return (taskq_create_impl(name, nthreads, pri, system_proc, flags));
93 taskq_create_proc(const char *name, int nthreads, pri_t pri, int minalloc, argument
96 return (taskq_create_impl(name, nthreads, pri, proc, flags));
/freebsd-12-stable/cddl/contrib/opensolaris/lib/libzpool/common/
H A Dtaskq.c240 taskq_create(const char *name, int nthreads, pri_t pri, argument
248 ASSERT3S(nthreads, >=, 0);
249 ASSERT3S(nthreads, <=, 100);
250 pct = MIN(nthreads, 100);
253 nthreads = (sysconf(_SC_NPROCESSORS_ONLN) * pct) / 100;
254 nthreads = MAX(nthreads, 1); /* need at least 1 thread */
256 ASSERT3S(nthreads, >=, 1);
266 tq->tq_active = nthreads;
267 tq->tq_nthreads = nthreads;
292 int nthreads = tq->tq_nthreads; local
[all...]
/freebsd-12-stable/tools/tools/netrate/netreceive/
H A Dnetreceive.c72 fprintf(stderr, "netreceive port [nthreads]\n");
127 make_threads(int *s, int nsock, int nthreads) argument
129 int i, si, nt = nsock * nthreads;
159 main_thread(struct td_desc **tp, int nsock, int nthreads) argument
168 int i, nt = nsock * nthreads;
201 int error, v, nthreads = 1; local
219 nthreads = strtoul(argv[2], &dummy, 10);
220 if (nthreads < 1 || nthreads > 64)
267 nsock, nthreads, (u_shor
[all...]
/freebsd-12-stable/sys/mips/beri/
H A Dberi_mp.c71 int ncores, ncpus, nthreads; local
78 nthreads = beri_get_nthreads();
80 KASSERT(nthreads <= 0x10000, ("%s: too many threads %d", __func__,
81 nthreads));
82 KASSERT(ncores < 0xffff || nthreads < 0xffff,
84 nthreads));
85 ncpus = ncores * nthreads;
90 ncores, nthreads);
/freebsd-12-stable/contrib/netbsd-tests/lib/libpthread/
H A Dh_resolv.c67 "Usage: %s [-d] [-h <nhosts>] [-n <nthreads>] <file> ...\n",
144 int nthreads = NTHREADS; local
160 nthreads = atoi(optarg);
172 if ((nleft = malloc(nthreads * sizeof(int))) == NULL)
180 for (i = 0; i < nthreads; i++) {
187 for (i = 0; i < nthreads; i++) {
/freebsd-12-stable/sys/powerpc/powernv/
H A Dplatform_powernv.c413 int res, nthreads; local
425 nthreads = 1;
434 nthreads = res / sizeof(cell_t);
436 nthreads = 1;
440 smp_threads_per_core = nthreads;
441 if (mp_ncpus % nthreads == 0)
442 mp_ncores = mp_ncpus / nthreads;
/freebsd-12-stable/contrib/jemalloc/include/jemalloc/internal/
H A Darena_structs_b.h91 atomic_u_t nthreads[2]; member in struct:arena_s
H A Dctl.h67 unsigned nthreads; member in struct:ctl_arena_s
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,
/freebsd-12-stable/usr.bin/sort/
H A Dsort.h60 extern size_t nthreads;
H A Dradixsort.c106 if (sort_left == 0 && nthreads > 1)
152 if (nthreads > 1) {
609 if (nthreads < 2) {
616 for(i = 0; i < nthreads; ++i) {
638 for (i = 0; i < nthreads; ++i)
650 size_t nthreads_save = nthreads;
652 nthreads = 1;
654 if (nthreads > 1) {
686 if (nthreads > 1) {
690 nthreads
[all...]
H A Dfile.c1511 if (nthreads < 2 || list->count < MT_SORT_THRESHOLD) {
1512 size_t nthreads_save = nthreads;
1513 nthreads = 1;
1521 nthreads = nthreads_save;
1528 parts = sort_malloc(sizeof(struct sort_list*) * nthreads);
1530 avgsize = list->count / nthreads;
1536 for (i = 0; i < nthreads; ++i) {
1544 sz = (i == nthreads - 1) ? list->count - cstart :
1558 for (i = 0; i < nthreads; ++i) {
1582 for (i = 0; i < nthreads;
[all...]
H A Dsort.c109 size_t nthreads = 1; variable
293 nthreads = ncpu;
1104 nthreads = (size_t)(atoi(optarg));
1105 if (nthreads < 1)
1106 nthreads = 1;
1107 if (nthreads > 1024)
1108 nthreads = 1024;
1213 nthreads = 1;
1255 nthreads = 1;
/freebsd-12-stable/lib/libc/tests/resolv/
H A Dresolv_test.c254 size_t nthreads = NTHREADS; local
266 nleft = malloc(nthreads * sizeof(int));
275 for (i = 0; i < nthreads; i++) {
282 for (i = 0; i < nthreads; i++) {
/freebsd-12-stable/contrib/llvm-project/openmp/runtime/src/
H A Dkmp_tasking.cpp1204 1); // 1 indicates setup the current team regardless of nthreads
2793 kmp_int32 nthreads, victim_tid = -2, use_own_tasks = 1, new_victim = 0, local
2810 nthreads = task_team->tt.tt_nproc;
2812 KMP_DEBUG_ASSERT(nthreads > 1 || task_team->tt.tt_found_proxy_tasks);
2822 if ((task == NULL) && (nthreads > 1)) { // Steal a task
2840 victim_tid = __kmp_get_random(thread) % (nthreads - 1);
2979 if (nthreads == 1)
3022 int nthreads, i, is_init_thread; local
3030 nthreads = task_team->tt.tt_nproc;
3031 KMP_DEBUG_ASSERT(nthreads >
3179 kmp_int32 nthreads, maxthreads; local
3302 int nthreads; local
3804 kmp_int32 nthreads = team->t.t_nproc; local
[all...]
/freebsd-12-stable/tools/tools/netmap/
H A Dpkt-gen.c270 int nthreads; member in struct:glob_arg
1320 if (targ->g->nthreads > 1) {
1500 if (targ->g->nthreads > 1) {
1581 uint64_t n = targ->g->npackets / targ->g->nthreads;
1948 if (targ->g->nthreads > 1) {
2507 targs = calloc(g->nthreads, sizeof(*targs));
2513 for (i = 0; i < g->nthreads; i++) {
2584 for (i = 0; i < g->nthreads; i++) {
2620 for (i = 0; i < g->nthreads; i++) {
2674 if (done == g->nthreads)
[all...]
/freebsd-12-stable/contrib/jemalloc/src/
H A Darena.c64 arena_basic_stats_merge(UNUSED tsdn_t *tsdn, arena_t *arena, unsigned *nthreads, argument
67 *nthreads += arena_nthreads_get(arena, false);
77 arena_stats_merge(tsdn_t *tsdn, arena_t *arena, unsigned *nthreads, argument
83 arena_basic_stats_merge(tsdn, arena, nthreads, dss, dirty_decay_ms,
1743 return atomic_load_u(&arena->nthreads[internal], ATOMIC_RELAXED);
1748 atomic_fetch_add_u(&arena->nthreads[internal], 1, ATOMIC_RELAXED);
1753 atomic_fetch_sub_u(&arena->nthreads[internal], 1, ATOMIC_RELAXED);
1781 atomic_store_u(&arena->nthreads[0], 0, ATOMIC_RELAXED);
1782 atomic_store_u(&arena->nthreads[1], 0, ATOMIC_RELAXED);
2005 atomic_store_u(&arena->nthreads[
[all...]
/freebsd-12-stable/contrib/gdb/gdb/
H A Dgdb_thread_db.h238 int nthreads; /* Total number of threads in use. */ member in struct:td_ta_stats

Completed in 528 milliseconds

12