Home
last modified time | relevance | path

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

12

/NextBSD/contrib/gcclibs/libgomp/
HDteam.c137 new_team (unsigned nthreads, struct gomp_work_share *work_share) in new_team() argument
142 size = sizeof (*team) + nthreads * sizeof (team->ordered_release[0]); in new_team()
152 team->nthreads = nthreads; in new_team()
153 gomp_barrier_init (&team->barrier, nthreads); in new_team()
178 gomp_team_start (void (*fn) (void *), void *data, unsigned nthreads, in gomp_team_start() argument
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()
223 gomp_barrier_init (&gomp_threads_dock, nthreads); in gomp_team_start()
[all …]
HDordered.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()
130 if (ws->ordered_num_used < team->nthreads) 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()
[all …]
HDiter.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()
HDwork.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()
HDparallel.c87 return team ? team->nthreads : 1; in omp_get_num_threads()
115 if (team->nthreads > 1) in omp_in_parallel()
HDlibgomp.h185 unsigned nthreads; member
/NextBSD/cddl/contrib/opensolaris/lib/libzpool/common/
HDtaskq.c229 taskq_create(const char *name, int nthreads, pri_t pri, in taskq_create() argument
237 ASSERT3S(nthreads, >=, 0); in taskq_create()
238 ASSERT3S(nthreads, <=, 100); in taskq_create()
239 pct = MIN(nthreads, 100); in taskq_create()
242 nthreads = (sysconf(_SC_NPROCESSORS_ONLN) * pct) / 100; in taskq_create()
243 nthreads = MAX(nthreads, 1); /* need at least 1 thread */ in taskq_create()
245 ASSERT3S(nthreads, >=, 1); in taskq_create()
255 tq->tq_active = nthreads; in taskq_create()
256 tq->tq_nthreads = nthreads; in taskq_create()
261 tq->tq_threadlist = kmem_alloc(nthreads * sizeof (thread_t), KM_SLEEP); in taskq_create()
[all …]
/NextBSD/tools/tools/netrate/netreceive/
HDnetreceive.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()
/NextBSD/sys/cddl/compat/opensolaris/kern/
HDopensolaris_taskq.c65 taskq_create(const char *name, int nthreads, pri_t pri, int minalloc __unused, in taskq_create() argument
71 nthreads = MAX((mp_ncpus * nthreads) / 100, 1); in taskq_create()
76 (void) taskqueue_start_threads(&tq->tq_queue, nthreads, pri, "%s", name); in taskq_create()
82 taskq_create_proc(const char *name, int nthreads, pri_t pri, int minalloc, in taskq_create_proc() argument
86 return (taskq_create(name, nthreads, pri, minalloc, maxalloc, flags)); in taskq_create_proc()
/NextBSD/contrib/netbsd-tests/lib/libpthread/
HDh_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()
/NextBSD/usr.bin/sort/
HDradixsort.c140 if (nthreads > 1) in push_ls()
148 if (nthreads > 1) in push_ls()
599 if (nthreads < 2) { in run_top_sort_level()
606 for(i = 0; i < nthreads; ++i) { in run_top_sort_level()
629 for(i = 0; i < nthreads; ++i) in run_top_sort_level()
641 size_t nthreads_save = nthreads; in run_sort()
643 nthreads = 1; in run_sort()
645 if (nthreads > 1) { in run_sort()
677 if (nthreads > 1) { in run_sort()
682 nthreads = nthreads_save; in run_sort()
HDsort.c107 size_t nthreads = 1; variable
297 nthreads = ncpu; in set_hw_params()
1108 nthreads = (size_t)(atoi(optarg)); in main()
1109 if (nthreads < 1) in main()
1110 nthreads = 1; in main()
1111 if (nthreads > 1024) in main()
1112 nthreads = 1024; in main()
1217 nthreads = 1; in main()
1259 nthreads = 1; in main()
HDfile.c1510 if (nthreads < 2 || list->count < MT_SORT_THRESHOLD) { in mt_sort()
1511 size_t nthreads_save = nthreads; in mt_sort()
1512 nthreads = 1; in mt_sort()
1520 nthreads = nthreads_save; in mt_sort()
1527 parts = sort_malloc(sizeof(struct sort_list*) * nthreads); in mt_sort()
1529 avgsize = list->count / nthreads; in mt_sort()
1535 for (i = 0; i < nthreads; ++i) { in mt_sort()
1543 sz = (i == nthreads - 1) ? list->count - cstart : in mt_sort()
1557 for (i = 0; i < nthreads; ++i) { in mt_sort()
1581 for (i = 0; i < nthreads; ++i) { in mt_sort()
[all …]
HDsort.h58 extern size_t nthreads;
/NextBSD/sys/mips/rmi/
HDfmn.c88 int nthreads; /* number of threads started */ member
302 if(nt >= mthd->nthreads) { in msgring_process_fast_intr()
353 ++mthd->nthreads; /* Active thread count */ in msgring_process()
360 msgrng_setconfig(mthd->running, mthd->nthreads); in msgring_process()
369 msgrng_setconfig(mthd->running, mthd->nthreads); in msgring_process()
398 mthd->running = mthd->nthreads = 0; in create_msgring_thread()
/NextBSD/cddl/contrib/opensolaris/tools/ctf/cvt/
HDbarrier.c49 barrier_init(barrier_t *bar, int nthreads) in barrier_init() argument
59 bar->bar_nthr = nthreads; in barrier_init()
/NextBSD/lib/libc/tests/resolv/
HDresolv_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()
/NextBSD/tools/tools/netmap/
HDpkt-gen.c174 int nthreads; member
824 if (targ->g->nthreads > 1) { in pinger_body()
924 if (targ->g->nthreads > 1) { in ponger_body()
1069 int i, n = targ->g->npackets / targ->g->nthreads; in sender_body()
1425 targs = calloc(g->nthreads, sizeof(*targs)); in start_threads()
1430 for (i = 0; i < g->nthreads; i++) { in start_threads()
1442 if (g->nthreads > 1) { in start_threads()
1515 for (i = 0; i < g->nthreads; i++) { in main_thread()
1531 if (done == g->nthreads) in main_thread()
1537 for (i = 0; i < g->nthreads; i++) { in main_thread()
[all …]
/NextBSD/contrib/jemalloc/src/
HDjemalloc.c453 arena->nthreads++; in arena_bind_locked()
476 oldarena->nthreads--; in arena_migrate()
477 newarena->nthreads++; in arena_migrate()
485 unsigned nthreads; in arena_nbound() local
488 nthreads = arenas[ind]->nthreads; in arena_nbound()
490 return (nthreads); in arena_nbound()
500 arena->nthreads--; in arena_unbind()
595 if (arenas[i]->nthreads < in arena_choose_hard()
596 arenas[choose]->nthreads) in arena_choose_hard()
612 if (arenas[choose]->nthreads == 0 in arena_choose_hard()
HDstats.c259 unsigned nthreads; in stats_arena_print() local
274 CTL_M2_GET("stats.arenas.0.nthreads", i, &nthreads, unsigned); in stats_arena_print()
276 "assigned threads: %u\n", nthreads); in stats_arena_print()
HDctl.c625 sstats->nthreads += astats->nthreads; in ctl_arena_refresh()
691 ctl_stats.arenas[ctl_stats.narenas].nthreads = 0; in ctl_refresh()
705 ctl_stats.arenas[i].nthreads = arena_nbound(i); in ctl_refresh()
707 ctl_stats.arenas[i].nthreads = 0; in ctl_refresh()
2002 CTL_RO_GEN(stats_arenas_i_nthreads, ctl_stats.arenas[mib[2]].nthreads, unsigned) in CTL_RO_NL_CGEN()
/NextBSD/usr.bin/sort/nls/
HDC.msg16 …files0-from file] [--heapsort] [--mergesort] [--radixsort] [--qsort] [--nthreads thread_no] [--hum…
HDhu_HU.ISO8859-2.msg16 …files0-from f�jl] [--heapsort] [--mergesort] [--radixsort] [--qsort] [--nthreads sz�lak_sz�ma] [--…
/NextBSD/contrib/jemalloc/include/jemalloc/internal/
HDctl.h35 unsigned nthreads; member
/NextBSD/contrib/gdb/gdb/
HDprocfs.c3030 int nthreads = 0; in proc_get_nthreads() local
3032 if (ioctl (pi->ctl_fd, PIOCNTHR, &nthreads) < 0) in proc_get_nthreads()
3035 return nthreads; in proc_get_nthreads()
3275 int nthreads, i; in proc_update_threads() local
3290 nthreads = proc_get_nthreads (pi); in proc_update_threads()
3291 if (nthreads < 2) in proc_update_threads()
3294 threads = xmalloc (nthreads * sizeof (tid_t)); in proc_update_threads()
3299 for (i = 0; i < nthreads; i++) in proc_update_threads()

12