Home
last modified time | relevance | path

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

12

/linux-6.3-rc2/tools/perf/bench/
A Dfutex-requeue.c77 params.nthreads, in print_summary()
132 threads_starting = params.nthreads; in block_threads()
139 for (i = 0; i < params.nthreads; i++) { in block_threads()
189 if (!params.nthreads) in bench_futex_requeue()
199 if (params.nrequeue > params.nthreads) in bench_futex_requeue()
200 params.nrequeue = params.nthreads; in bench_futex_requeue()
203 params.nrequeue = params.nthreads; in bench_futex_requeue()
272 params.nthreads, in bench_futex_requeue()
279 params.nthreads, in bench_futex_requeue()
288 if (params.nthreads != nrequeued) in bench_futex_requeue()
[all …]
A Dbreakpoint.c22 unsigned int nthreads; member
26 .nthreads = 1,
91 for (i = 0; i < thread_params.nthreads; i++) { in breakpoint_thread()
96 futex_wake(&done, thread_params.nthreads, 0); in breakpoint_thread()
97 for (i = 0; i < thread_params.nthreads; i++) in breakpoint_thread()
152 thread_params.nthreads * thread_params.nparallel); in bench_breakpoint_thread()
188 unsigned int i, nthreads, result_usec, done = 0; in bench_breakpoint_enable() local
201 nthreads = enable_params.npassive + enable_params.nactive; in bench_breakpoint_enable()
202 threads = calloc(nthreads, sizeof(threads[0])); in bench_breakpoint_enable()
206 for (i = 0; i < nthreads; i++) { in bench_breakpoint_enable()
[all …]
A Dfutex-wake.c53 OPT_UINTEGER('t', "threads", &params.nthreads, "Specify amount of threads"),
93 params.nthreads, in print_summary()
105 threads_starting = params.nthreads; in block_threads()
112 for (i = 0; i < params.nthreads; i++) { in block_threads()
164 if (!params.nthreads) in bench_futex_wake()
165 params.nthreads = perf_cpu_map__nr(cpu); in bench_futex_wake()
167 worker = calloc(params.nthreads, sizeof(*worker)); in bench_futex_wake()
176 getpid(), params.nthreads, params.fshared ? "shared":"private", in bench_futex_wake()
204 while (nwoken != params.nthreads) in bench_futex_wake()
215 j + 1, nwoken, params.nthreads, in bench_futex_wake()
[all …]
A Dfutex-wake-parallel.c153 threads_starting = params.nthreads; in block_threads()
160 for (i = 0; i < params.nthreads; i++) { in block_threads()
197 params.nthreads, waketime_avg / USEC_PER_MSEC, in print_run()
212 params.nthreads, in print_summary()
266 if (!params.nthreads) in bench_futex_wake_parallel()
267 params.nthreads = perf_cpu_map__nr(cpu); in bench_futex_wake_parallel()
270 if (params.nwakes > params.nthreads || in bench_futex_wake_parallel()
272 params.nwakes = params.nthreads; in bench_futex_wake_parallel()
274 if (params.nthreads % params.nwakes) in bench_futex_wake_parallel()
280 nwakes = params.nthreads/params.nwakes; in bench_futex_wake_parallel()
[all …]
A Dfutex-lock-pi.c48 OPT_UINTEGER('t', "threads", &params.nthreads, "Specify amount of threads"),
129 threads_starting = params.nthreads; in create_threads()
135 for (i = 0; i < params.nthreads; i++) { in create_threads()
187 if (!params.nthreads) in bench_futex_lock_pi()
188 params.nthreads = perf_cpu_map__nr(cpu); in bench_futex_lock_pi()
190 worker = calloc(params.nthreads, sizeof(*worker)); in bench_futex_lock_pi()
198 getpid(), params.nthreads, params.runtime); in bench_futex_lock_pi()
205 threads_starting = params.nthreads; in bench_futex_lock_pi()
221 for (i = 0; i < params.nthreads; i++) { in bench_futex_lock_pi()
232 for (i = 0; i < params.nthreads; i++) { in bench_futex_lock_pi()
A Dfutex-hash.c56 OPT_UINTEGER('t', "threads", &params.nthreads, "Specify amount of threads"),
155 if (!params.nthreads) /* default to the number of CPUs */ in bench_futex_hash()
156 params.nthreads = perf_cpu_map__nr(cpu); in bench_futex_hash()
158 worker = calloc(params.nthreads, sizeof(*worker)); in bench_futex_hash()
166 … getpid(), params.nthreads, params.nfutexes, params.fshared ? "shared":"private", params.runtime); in bench_futex_hash()
173 threads_starting = params.nthreads; in bench_futex_hash()
182 for (i = 0; i < params.nthreads; i++) { in bench_futex_hash()
216 for (i = 0; i < params.nthreads; i++) { in bench_futex_hash()
227 for (i = 0; i < params.nthreads; i++) { in bench_futex_hash()
A Depoll-wait.c91 static unsigned int nthreads = 0; variable
317 for (i = 0; i < nthreads; i++) { in do_threads()
394 shuffle((void *)worker, nthreads, sizeof(*worker)); in writerfn()
397 for (i = 0; i < nthreads; i++) { in writerfn()
468 if (!nthreads) in bench_epoll_wait()
469 nthreads = perf_cpu_map__nr(cpu) - 1; in bench_epoll_wait()
471 worker = calloc(nthreads, sizeof(*worker)); in bench_epoll_wait()
478 rl.rlim_cur = rl.rlim_max = nfds * nthreads * 2 + 50; in bench_epoll_wait()
493 threads_starting = nthreads; in bench_epoll_wait()
532 qsort(worker, nthreads, sizeof(struct worker), cmpworker); in bench_epoll_wait()
[all …]
A Depoll-ctl.c36 static unsigned int nthreads = 0; variable
75 OPT_UINTEGER('t', "threads", &nthreads, "Specify amount of threads"),
240 for (i = 0; i < nthreads; i++) { in do_threads()
349 if (!nthreads) in bench_epoll_ctl()
350 nthreads = perf_cpu_map__nr(cpu); in bench_epoll_ctl()
352 worker = calloc(nthreads, sizeof(*worker)); in bench_epoll_ctl()
358 rl.rlim_cur = rl.rlim_max = nfds * nthreads * 2 + 50; in bench_epoll_ctl()
366 getpid(), nthreads, nfds, nsecs); in bench_epoll_ctl()
375 threads_starting = nthreads; in bench_epoll_ctl()
391 for (i = 0; i < nthreads; i++) { in bench_epoll_ctl()
[all …]
A Dfutex.h24 unsigned int nthreads; member
/linux-6.3-rc2/tools/testing/selftests/mm/
A Dmigration.c26 int nthreads; in FIXTURE() local
36 self->nthreads = numa_num_task_cpus() - 1; in FIXTURE_SETUP()
52 self->pids = malloc(self->nthreads * sizeof(*self->pids)); in FIXTURE_SETUP()
119 if (self->nthreads < 2 || self->n1 < 0 || self->n2 < 0)
127 for (i = 0; i < self->nthreads - 1; i++)
132 for (i = 0; i < self->nthreads - 1; i++)
145 if (self->nthreads < 2 || self->n1 < 0 || self->n2 < 0)
153 for (i = 0; i < self->nthreads - 1; i++) {
162 for (i = 0; i < self->nthreads - 1; i++)
184 for (i = 0; i < self->nthreads - 1; i++)
[all …]
A Dgup_test.c93 int filed, i, opt, nr_pages = 1, thp = -1, write = 1, nthreads = 1, ret; in main() local
130 nthreads = atoi(optarg); in main()
258 tid = malloc(sizeof(pthread_t) * nthreads); in main()
260 for (i = 0; i < nthreads; i++) { in main()
264 for (i = 0; i < nthreads; i++) { in main()
/linux-6.3-rc2/tools/perf/util/
A Dcounts.c10 struct perf_counts *perf_counts__new(int ncpus, int nthreads) in perf_counts__new() argument
17 values = xyarray__new(ncpus, nthreads, sizeof(struct perf_counts_values)); in perf_counts__new()
25 values = xyarray__new(ncpus, nthreads, sizeof(bool)); in perf_counts__new()
61 int nthreads = perf_thread_map__nr(evsel->core.threads); in evsel__alloc_counts() local
63 evsel->counts = perf_counts__new(perf_cpu_map__nr(cpus), nthreads); in evsel__alloc_counts()
A Dstat.c207 int nthreads = perf_thread_map__nr(evsel->core.threads); in evsel__alloc_prev_raw_counts() local
210 counts = perf_counts__new(cpu_map_nr, nthreads); in evsel__alloc_prev_raw_counts()
299 int idx, nthreads = perf_thread_map__nr(evsel->core.threads); in evsel__copy_prev_raw_counts() local
301 for (int thread = 0; thread < nthreads; thread++) { in evsel__copy_prev_raw_counts()
492 int nthreads = perf_thread_map__nr(counter->core.threads); in process_counter_maps() local
496 for (thread = 0; thread < nthreads; thread++) { in process_counter_maps()
A Dcounts.h37 struct perf_counts *perf_counts__new(int ncpus, int nthreads);
/linux-6.3-rc2/arch/powerpc/platforms/pseries/
A Dhotplug-cpu.c222 nthreads = len / sizeof(u32); in pseries_add_processor()
272 cpu, cpu + nthreads - 1); in pseries_add_processor()
296 int len, nthreads, i; in pseries_remove_processor() local
304 nthreads = len / sizeof(u32); in pseries_remove_processor()
307 for (i = 0; i < nthreads; i++) { in pseries_remove_processor()
329 int len, nthreads, i; in dlpar_offline_cpu() local
337 nthreads = len / sizeof(u32); in dlpar_offline_cpu()
340 for (i = 0; i < nthreads; i++) { in dlpar_offline_cpu()
385 int len, nthreads, i; in dlpar_online_cpu() local
393 nthreads = len / sizeof(u32); in dlpar_online_cpu()
[all …]
/linux-6.3-rc2/kernel/
A Dscftorture.c53 torture_param(int, nthreads, -1, "# threads, defaults to -1 for all CPUs.");
161 for (i = 0; i < nthreads; i++) { in scf_torture_stats_print()
499 …verbose, holdoff, longwait, nthreads, onoff_holdoff, onoff_interval, shutdown, stat_interval, stut… in scftorture_print_module_parms()
514 if (nthreads && scf_stats_p) in scf_torture_cleanup()
515 for (i = 0; i < nthreads; i++) in scf_torture_cleanup()
621 if (nthreads < 0) in scf_torture_init()
622 nthreads = num_online_cpus(); in scf_torture_init()
623 scf_stats_p = kcalloc(nthreads, sizeof(scf_stats_p[0]), GFP_KERNEL); in scf_torture_init()
630 VERBOSE_SCFTORTOUT("Starting %d smp_call_function() threads", nthreads); in scf_torture_init()
632 atomic_set(&n_started, nthreads); in scf_torture_init()
[all …]
/linux-6.3-rc2/kernel/kcsan/
A Dkcsan_test.c1377 if (nthreads < 0 || nthreads >= 32) in nthreads_gen_params()
1379 else if (!nthreads) in nthreads_gen_params()
1381 else if (nthreads < 5) in nthreads_gen_params()
1382 nthreads++; in nthreads_gen_params()
1383 else if (nthreads == 5) in nthreads_gen_params()
1384 nthreads = 8; in nthreads_gen_params()
1386 nthreads *= 2; in nthreads_gen_params()
1401 nthreads = 0; in nthreads_gen_params()
1411 return (void *)nthreads; in nthreads_gen_params()
1500 int nthreads; in test_init() local
[all …]
/linux-6.3-rc2/kernel/locking/
A Dtest-ww_mutex.c315 static int __test_cycle(unsigned int nthreads) in __test_cycle() argument
318 unsigned int n, last = nthreads - 1; in __test_cycle()
321 cycles = kmalloc_array(nthreads, sizeof(*cycles), GFP_KERNEL); in __test_cycle()
325 for (n = 0; n < nthreads; n++) { in __test_cycle()
344 for (n = 0; n < nthreads; n++) in __test_cycle()
350 for (n = 0; n < nthreads; n++) { in __test_cycle()
357 n, nthreads, cycle->result); in __test_cycle()
362 for (n = 0; n < nthreads; n++) in __test_cycle()
564 static int stress(int nlocks, int nthreads, unsigned int flags) in stress() argument
576 for (n = 0; nthreads; n++) { in stress()
[all …]
/linux-6.3-rc2/tools/lib/perf/
A Devsel.c52 int perf_evsel__alloc_fd(struct perf_evsel *evsel, int ncpus, int nthreads) in perf_evsel__alloc_fd() argument
54 evsel->fd = xyarray__new(ncpus, nthreads, sizeof(int)); in perf_evsel__alloc_fd()
60 for (thread = 0; thread < nthreads; thread++) { in perf_evsel__alloc_fd()
72 static int perf_evsel__alloc_mmap(struct perf_evsel *evsel, int ncpus, int nthreads) in perf_evsel__alloc_mmap() argument
74 evsel->mmap = xyarray__new(ncpus, nthreads, sizeof(struct perf_mmap)); in perf_evsel__alloc_mmap()
513 int perf_evsel__alloc_id(struct perf_evsel *evsel, int ncpus, int nthreads) in perf_evsel__alloc_id() argument
515 if (ncpus == 0 || nthreads == 0) in perf_evsel__alloc_id()
518 evsel->sample_id = xyarray__new(ncpus, nthreads, sizeof(struct perf_sample_id)); in perf_evsel__alloc_id()
522 evsel->id = zalloc(ncpus * nthreads * sizeof(u64)); in perf_evsel__alloc_id()
/linux-6.3-rc2/fs/nfsd/
A Dnfssvc.c704 int nfsd_get_nrthreads(int n, int *nthreads, struct net *net) in nfsd_get_nrthreads() argument
711 nthreads[i] = nn->nfsd_serv->sv_pools[i].sp_nrthreads; in nfsd_get_nrthreads()
758 nthreads[i] = min(nthreads[i], NFSD_MAXSERVS); in nfsd_set_nrthreads()
759 tot += nthreads[i]; in nfsd_set_nrthreads()
764 int new = nthreads[i] * NFSD_MAXSERVS / tot; in nfsd_set_nrthreads()
765 tot -= (nthreads[i] - new); in nfsd_set_nrthreads()
766 nthreads[i] = new; in nfsd_set_nrthreads()
769 nthreads[i]--; in nfsd_set_nrthreads()
778 if (nthreads[0] == 0) in nfsd_set_nrthreads()
779 nthreads[0] = 1; in nfsd_set_nrthreads()
[all …]
A Dnfsctl.c455 int *nthreads; in write_pool_threads() local
471 nthreads = kcalloc(npools, sizeof(int), GFP_KERNEL); in write_pool_threads()
473 if (nthreads == NULL) in write_pool_threads()
478 rv = get_int(&mesg, &nthreads[i]); in write_pool_threads()
484 if (nthreads[i] < 0) in write_pool_threads()
487 rv = nfsd_set_nrthreads(i, nthreads, net); in write_pool_threads()
492 rv = nfsd_get_nrthreads(npools, nthreads, net); in write_pool_threads()
499 snprintf(mesg, size, "%d%c", nthreads[i], (i == npools-1 ? '\n' : ' ')); in write_pool_threads()
506 kfree(nthreads); in write_pool_threads()
/linux-6.3-rc2/tools/lib/perf/include/internal/
A Devsel.h73 int perf_evsel__alloc_fd(struct perf_evsel *evsel, int ncpus, int nthreads);
79 int perf_evsel__alloc_id(struct perf_evsel *evsel, int ncpus, int nthreads);
/linux-6.3-rc2/arch/powerpc/kernel/
A Dsetup-common.c452 int nthreads = 1; in smp_setup_cpu_maps() local
485 nthreads = len / sizeof(int); in smp_setup_cpu_maps()
487 for (j = 0; j < nthreads && cpu < nr_cpu_ids; j++) { in smp_setup_cpu_maps()
513 nthreads = 1; in smp_setup_cpu_maps()
538 maxcpus *= nthreads; in smp_setup_cpu_maps()
564 cpu_init_thread_core_maps(nthreads); in smp_setup_cpu_maps()
A Dprom.c331 int i, nthreads; in early_init_dt_scan_cpus() local
348 nthreads = len / sizeof(int); in early_init_dt_scan_cpus()
354 for (i = 0; i < nthreads; i++) { in early_init_dt_scan_cpus()
414 if (nthreads == 1) in early_init_dt_scan_cpus()
/linux-6.3-rc2/tools/testing/selftests/filesystems/binderfs/
A Dbinderfs_test.c403 int i, j, k, nthreads; in TEST() local
453 nthreads = get_nprocs_conf(); in TEST()
454 if (nthreads > DEFAULT_THREADS) in TEST()
455 nthreads = DEFAULT_THREADS; in TEST()
460 for (i = 0; i < nthreads; i++) { in TEST()

Completed in 35 milliseconds

12