Home
last modified time | relevance | path

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

12

/titanic_44/usr/src/lib/libzpool/common/
H A Dtaskq.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 …]
/titanic_44/usr/src/lib/libfakekernel/common/
H A Dtaskq.c268 taskq_create_proc(const char *name, int nthreads, pri_t pri, in taskq_create_proc() argument
276 ASSERT3S(nthreads, >=, 0); in taskq_create_proc()
277 ASSERT3S(nthreads, <=, 100); in taskq_create_proc()
278 pct = MIN(nthreads, 100); in taskq_create_proc()
281 nthreads = (sysconf(_SC_NPROCESSORS_ONLN) * pct) / 100; in taskq_create_proc()
282 nthreads = MAX(nthreads, 1); /* need at least 1 thread */ in taskq_create_proc()
284 ASSERT3S(nthreads, >=, 1); in taskq_create_proc()
293 tq->tq_active = nthreads; in taskq_create_proc()
294 tq->tq_nthreads = nthreads; in taskq_create_proc()
299 tq->tq_threadlist = kmem_alloc(nthreads * sizeof (thread_t), KM_SLEEP); in taskq_create_proc()
[all …]
/titanic_44/usr/src/tools/ctf/cvt/
H A Dbarrier.c47 barrier_init(barrier_t *bar, int nthreads) in barrier_init() argument
53 bar->bar_nthr = nthreads; in barrier_init()
/titanic_44/usr/src/uts/common/os/
H A Dtaskq.c1805 taskq_create(const char *name, int nthreads, pri_t pri, int minalloc, in taskq_create() argument
1810 return (taskq_create_common(name, 0, nthreads, pri, minalloc, in taskq_create()
1824 taskq_create_instance(const char *name, int instance, int nthreads, pri_t pri, in taskq_create_instance() argument
1834 return (taskq_create_common(name, instance, nthreads, in taskq_create_instance()
1839 taskq_create_proc(const char *name, int nthreads, pri_t pri, int minalloc, in taskq_create_proc() argument
1845 return (taskq_create_common(name, 0, nthreads, pri, minalloc, in taskq_create_proc()
1850 taskq_create_sysdc(const char *name, int nthreads, int minalloc, in taskq_create_sysdc() argument
1856 return (taskq_create_common(name, 0, nthreads, minclsyspri, minalloc, in taskq_create_sysdc()
1861 taskq_create_common(const char *name, int instance, int nthreads, pri_t pri, in taskq_create_common() argument
1893 ASSERT3S(nthreads, >=, 1); in taskq_create_common()
[all …]
H A Dturnstile.c718 turnstile_wakeup(turnstile_t *ts, int qnum, int nthreads, kthread_t *owner) in turnstile_wakeup() argument
731 while (nthreads-- > 0) { in turnstile_wakeup()
H A Dcpu.c226 kstat_named_t nthreads; member
3259 csskd->nthreads.value.ui64 = css->nthreads; in cpu_sys_stats_ks_update()
3398 cso->cpu_sysinfo.nthreads = CPU_STATS(cp, sys.nthreads); in cpu_stat_ks_update()
/titanic_44/usr/src/cmd/mdb/common/modules/genunix/
H A Dtaskq.c400 size_t nthreads; in taskq_thread_walk_init() local
409 nthreads = tq.tq_nthreads; in taskq_thread_walk_init()
410 tlist = mdb_alloc(nthreads * sizeof (*tlist), UM_SLEEP); in taskq_thread_walk_init()
414 } else if (mdb_vread(tlist, nthreads * sizeof (*tlist), in taskq_thread_walk_init()
418 mdb_free(tlist, nthreads * sizeof (*tlist)); in taskq_thread_walk_init()
423 tti->tti_nthreads = nthreads; in taskq_thread_walk_init()
/titanic_44/usr/src/cmd/avs/nsctl/
H A Dnskernd.c82 static int nthreads; /* number of threads in the kernel */ variable
121 nthreads++; in nthread_inc()
131 nthreads--; in nthread_dec()
146 if (nthreads > 0) { in canshutdown()
150 "%d kernel threads in use\n"), nthreads); in canshutdown()
153 while (nthreads > 0 && (time(0) - start_delay) < delay_time) { in canshutdown()
159 "%d kernel threads in use\n"), nthreads); in canshutdown()
161 if (nthreads > 0) { in canshutdown()
/titanic_44/usr/src/uts/common/syscall/
H A Dlgrpsys.c692 int nthreads; in lgrp_affinity_set() local
813 nthreads = p->p_lwpcnt; in lgrp_affinity_set()
818 if (nthreads < 1) in lgrp_affinity_set()
827 aff_buf_array = kmem_zalloc(nthreads * in lgrp_affinity_set()
831 for (i = 0; i < nthreads; i++) in lgrp_affinity_set()
850 for (i = 0; i < nthreads; i++) in lgrp_affinity_set()
853 nthreads * sizeof (lgrp_affinity_t *)); in lgrp_affinity_set()
863 if (nthreads != p->p_lwpcnt) { in lgrp_affinity_set()
866 for (i = 0; i < nthreads; i++) in lgrp_affinity_set()
869 nthreads * sizeof (lgrp_affinity_t *)); in lgrp_affinity_set()
[all …]
/titanic_44/usr/src/uts/common/sys/
H A Dsysinfo.h112 uint_t nthreads; /* thread_create()s */ member
236 uint64_t nthreads; /* thread_create()s */ member
H A Dsunddi.h2174 int nthreads, pri_t pri, uint_t cflags);
/titanic_44/usr/src/cmd/savecore/
H A Dsavecore.c759 int nthreads; in initstreams() local
765 nthreads = sysconf(_SC_NPROCESSORS_ONLN); in initstreams()
766 if (nstreams < nthreads) in initstreams()
767 nthreads = nstreams; in initstreams()
768 if (nthreads < 1) in initstreams()
769 nthreads = 1; in initstreams()
770 nblocks = nthreads * 2; in initstreams()
772 tinfo = Zalloc(nthreads * sizeof (tinfo_t)); in initstreams()
773 endtinfo = &tinfo[nthreads]; in initstreams()
793 nthreads = t - tinfo; in initstreams()
/titanic_44/usr/src/cmd/ptools/pstack/
H A Dpstack.c149 static int nthreads; variable
274 nthreads = 0; in main()
331 nthreads++; in thr_stack()
440 !(dothreads && nthreads > 1)) { in all_call_stacks()
/titanic_44/usr/src/uts/common/avs/ns/sv/
H A Dsv.c1617 int nthreads; in sv_thread_tune() local
1641 nthreads = nst_nthread(sv_tset); in sv_thread_tune()
1642 if ((nthreads + threads) > sv_threads_max) { in sv_thread_tune()
1643 sv_threads_extra = nthreads + threads - sv_threads_max; in sv_thread_tune()
1644 threads = sv_threads_max - nthreads; in sv_thread_tune()
1654 nthreads = nst_nthread(sv_tset); in sv_thread_tune()
1657 if (sv_threads_needed >= nthreads) in sv_thread_tune()
1660 (nthreads - (sv_threads_inc + sv_threads_hysteresis))) && in sv_thread_tune()
1661 ((nthreads - sv_threads_inc) >= sv_threads)) in sv_thread_tune()
/titanic_44/usr/src/lib/libc/port/threads/
H A Dthr.c281 ASSERT(udp->nthreads <= 1 || MUTEX_OWNED(&udp->link_lock, self)); in trim_stack_cache()
470 ASSERT(udp->nthreads <= 1 || MUTEX_OWNED(&udp->link_lock, curthread)); in ulwp_free()
701 udp->nthreads++; in _thrp_create()
763 udp->nthreads--; in _thrp_exit()
768 else if (udp->nthreads == udp->ndaemons) { in _thrp_exit()
1387 ASSERT(udp->nthreads == 1 && !udp->uberflags.uf_mt); in libc_init()
1396 udp->nthreads = 1; in libc_init()
1660 udp->nthreads = 1; in postfork1_child()
2397 return (curthread->ul_uberdata->nthreads); in __nthreads()
H A Dalloc.c213 ASSERT(udp->nthreads == 0); in lmalloc()
/titanic_44/usr/src/cmd/sa/
H A Dsa.h135 uint64_t nthreads; member
/titanic_44/usr/src/cmd/keyserv/
H A Dkeyserv.c142 static int nthreads = 32; variable
245 nthreads = atoi(optarg); in main()
366 if (nthreads > 0) { in main()
368 (void) rpc_control(RPC_SVC_THRMAX_SET, &nthreads); in main()
/titanic_44/usr/src/cmd/ptools/plgrp/
H A Dplgrp.c138 int nthreads; /* threads processed */ member
1230 plgrp_args->nthreads++; in Plwp_iter_handler()
1595 if (plgrp_todo.nthreads == 0) { in main()
/titanic_44/usr/src/head/
H A Dthread_db.h239 int nthreads; /* total number of threads in use */ member
/titanic_44/usr/src/lib/libc/inc/
H A Dthr_uberdata.h953 int nthreads; /* total number of live threads/lwps */ member
1167 int nthreads; member
/titanic_44/usr/src/lib/libc_db/common/
H A Dthread_db.c584 int nthreads; in __td_ta_get_nthreads() local
591 offsetof(uberdata_t, nthreads); in __td_ta_get_nthreads()
597 offsetof(uberdata32_t, nthreads); in __td_ta_get_nthreads()
610 if (ps_pdread(ph_p, nthreads_addr, &nthreads, sizeof (int)) != PS_OK) in __td_ta_get_nthreads()
616 *nthread_p = nthreads + nzombies; in __td_ta_get_nthreads()
/titanic_44/usr/src/cmd/mdb/common/modules/libc/
H A Dlibc.c851 OFFSET(nthreads), in d_uberdata()
852 uberdata.nthreads, in d_uberdata()
/titanic_44/usr/src/uts/common/avs/ns/rdc/
H A Drdc_io.c222 int nthreads; in rdc_thread_tune() local
230 nthreads = nst_nthread(_rdc_ioset); in rdc_thread_tune()
233 if (rdc_sets_active >= nthreads) in rdc_thread_tune()
236 (nthreads - (rdc_threads_inc + rdc_threads_hysteresis))) && in rdc_thread_tune()
237 ((nthreads - rdc_threads_inc) >= rdc_threads)) in rdc_thread_tune()
/titanic_44/usr/src/uts/common/disp/
H A Dthread.c445 CPU_STATS_ADDQ(CPU, sys, nthreads, 1); in thread_create()

12