| /f-stack/freebsd/contrib/openzfs/lib/libzpool/ |
| H A D | taskq.c | 252 taskq_create(const char *name, int nthreads, pri_t pri, in taskq_create() argument
260 ASSERT3S(nthreads, >=, 0); in taskq_create()
261 ASSERT3S(nthreads, <=, 100); in taskq_create()
262 pct = MIN(nthreads, 100); in taskq_create()
265 nthreads = (sysconf(_SC_NPROCESSORS_ONLN) * pct) / 100; in taskq_create()
266 nthreads = MAX(nthreads, 1); /* need at least 1 thread */ in taskq_create()
268 ASSERT3S(nthreads, >=, 1); in taskq_create()
278 tq->tq_active = nthreads; in taskq_create()
279 tq->tq_nthreads = nthreads; in taskq_create()
294 for (t = 0; t < nthreads; t++) in taskq_create()
[all …]
|
| /f-stack/freebsd/mips/beri/ |
| H A D | beri_mp.c | 71 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()
|
| /f-stack/app/redis-5.0.5/deps/jemalloc/test/unit/ |
| H A D | retained.c | 109 unsigned nthreads = ncpus * 2; in TEST_BEGIN() local
110 VARIABLE_ARRAY(thd_t, threads, nthreads); in TEST_BEGIN()
111 for (unsigned i = 0; i < nthreads; i++) { in TEST_BEGIN()
121 while (atomic_load_u(&nfinished, ATOMIC_ACQUIRE) < nthreads) { in TEST_BEGIN()
132 size_t allocated = esz * nthreads * PER_THD_NALLOCS; in TEST_BEGIN()
169 for (unsigned i = 0; i < nthreads; i++) { in TEST_BEGIN()
|
| H A D | mallctl.c | 765 TEST_STATS_ARENAS(unsigned, nthreads); in TEST_BEGIN()
|
| /f-stack/freebsd/contrib/openzfs/include/os/linux/spl/sys/ |
| H A D | taskq.h | 160 #define taskq_create_proc(name, nthreads, pri, min, max, proc, flags) \ argument
161 taskq_create(name, nthreads, pri, min, max, flags)
162 #define taskq_create_sysdc(name, nthreads, min, max, proc, dc, flags) \ argument
163 taskq_create(name, nthreads, maxclsyspri, min, max, flags)
|
| /f-stack/freebsd/contrib/openzfs/module/os/freebsd/spl/ |
| H A D | spl_taskq.c | 212 taskq_create_impl(const char *name, int nthreads, pri_t pri, in taskq_create_impl() argument
218 nthreads = MAX((mp_ncpus * nthreads) / 100, 1); in taskq_create_impl()
227 (void) taskqueue_start_threads_in_proc(&tq->tq_queue, nthreads, pri, in taskq_create_impl()
234 taskq_create(const char *name, int nthreads, pri_t pri, int minalloc __unused, in taskq_create() argument
237 return (taskq_create_impl(name, nthreads, pri, system_proc, flags)); in taskq_create()
241 taskq_create_proc(const char *name, int nthreads, pri_t pri, in taskq_create_proc() argument
244 return (taskq_create_impl(name, nthreads, pri, proc, flags)); in taskq_create_proc()
|
| /f-stack/freebsd/contrib/openzfs/module/os/linux/spl/ |
| H A D | spl-taskq.c | 1042 int nthreads = threads_arg; in taskq_create() local
1051 ASSERT(nthreads <= 100); in taskq_create()
1052 ASSERT(nthreads >= 0); in taskq_create()
1054 nthreads = MAX(nthreads, 0); in taskq_create()
1055 nthreads = MAX((num_online_cpus() * nthreads) /100, 1); in taskq_create()
1081 tq->tq_maxthreads = nthreads; in taskq_create()
1111 nthreads = 1; in taskq_create()
1307 nthreads = MAX(((num_online_cpus() + 1) * nthreads) / 100, 1); in spl_taskq_expand()
1308 tq->tq_maxthreads = nthreads; in spl_taskq_expand()
1342 nthreads = MAX(((num_online_cpus()) * nthreads) / 100, 1); in spl_taskq_prepare_down()
[all …]
|
| /f-stack/app/redis-5.0.5/deps/jemalloc/include/jemalloc/internal/ |
| H A D | arena_externs.h | 20 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 D | arena_structs_b.h | 91 atomic_u_t nthreads[2]; member
|
| H A D | ctl.h | 67 unsigned nthreads; member
|
| /f-stack/app/redis-5.0.5/deps/jemalloc/src/ |
| H A D | arena.c | 64 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 …]
|
| H A D | ctl.c | 686 ctl_arena->nthreads = 0; in ctl_arena_clear()
711 arena_stats_merge(tsdn, arena, &ctl_arena->nthreads, in ctl_arena_stats_amerge()
730 arena_basic_stats_merge(tsdn, arena, &ctl_arena->nthreads, in ctl_arena_stats_amerge()
743 ctl_sdarena->nthreads += ctl_arena->nthreads; in ctl_arena_stats_sdmerge()
748 assert(ctl_arena->nthreads == 0); in ctl_arena_stats_sdmerge()
2658 CTL_RO_GEN(stats_arenas_i_nthreads, arenas_i(mib[2])->nthreads, unsigned) in CTL_RO_NL_CGEN()
|
| H A D | stats.c | 525 unsigned nthreads; in stats_arena_print() local
541 CTL_M2_GET("stats.arenas.0.nthreads", i, &nthreads, unsigned); in stats_arena_print()
543 emitter_type_unsigned, &nthreads); in stats_arena_print()
|
| /f-stack/freebsd/kern/ |
| H A D | kern_thread.c | 163 static __exclusive_cache_line int nthreads; variable
182 nthreads_new = atomic_fetchadd_int(&nthreads, 1) + 1; in thread_count_inc_try()
186 atomic_subtract_int(&nthreads, 1); in thread_count_inc_try()
221 atomic_subtract_int(&nthreads, n); in thread_count_sub()
|
| /f-stack/freebsd/contrib/openzfs/module/zfs/ |
| H A D | dsl_scan.c | 3115 int nthreads = spa->spa_root_vdev->vdev_children; in scan_io_queues_run() local
3124 scn->scn_taskq = taskq_create("dsl_scan_iss", nthreads, in scan_io_queues_run()
3125 minclsyspri, nthreads, nthreads, TASKQ_PREPOPULATE); in scan_io_queues_run()
|
| /f-stack/app/redis-5.0.5/deps/jemalloc/ |
| H A D | ChangeLog | 434 - Fix stats.arenas.<i>.nthreads accounting. (@interwq)
|