Home
last modified time | relevance | path

Searched full:workers (Results 1 – 25 of 87) sorted by relevance

1234

/linux/Documentation/core-api/
H A Dworkqueue.rst34 number of workers as the number of CPUs. The kernel grew a lot of MT
82 For threaded workqueues, special purpose threads, called [k]workers, execute
126 number of the currently runnable workers. Generally, work items are
130 workers on the CPU, the worker-pool doesn't start execution of a new
133 are pending work items. This allows using a minimal number of workers
136 Keeping idle workers around doesn't cost other than the memory space
148 Forward progress guarantee relies on that workers can be created when
150 through the use of rescue workers. All work items which might be used
194 worker-pools which host workers which are not bound to any
203 of mostly unused workers across different CPUs as the issuer
[all …]
/linux/Documentation/translations/zh_CN/core-api/
H A Dworkqueue.rst577 pool[00] ref= 1 nice= 0 idle/workers= 4/ 4 cpu= 0
578 pool[01] ref= 1 nice=-20 idle/workers= 2/ 2 cpu= 0
579 pool[02] ref= 1 nice= 0 idle/workers= 4/ 4 cpu= 1
580 pool[03] ref= 1 nice=-20 idle/workers= 2/ 2 cpu= 1
581 pool[04] ref= 1 nice= 0 idle/workers= 4/ 4 cpu= 2
582 pool[05] ref= 1 nice=-20 idle/workers= 2/ 2 cpu= 2
583 pool[06] ref= 1 nice= 0 idle/workers= 3/ 3 cpu= 3
584 pool[07] ref= 1 nice=-20 idle/workers= 2/ 2 cpu= 3
585 pool[08] ref=42 nice= 0 idle/workers= 6/ 6 cpus=0000000f
586 pool[09] ref=28 nice= 0 idle/workers= 3/ 3 cpus=00000003
[all …]
/linux/tools/testing/selftests/sched_ext/
H A Dcyclic_kick_wait.c102 struct worker_ctx workers[NR_WORKERS] = {}; in run() local
141 workers[i].cpu = test_cpus[i / WORKERS_PER_CPU]; in run()
144 ret = pthread_create(&workers[i].tid, NULL, worker_fn, &workers[i]); in run()
150 workers[i].started = true; in run()
164 workers[i].stop = true; in run()
167 ret = join_worker(&workers[i]); in run()
H A Ddequeue.c46 * This thread changes workers' affinity from outside so that some changes
128 /* Wait for all workers to complete */ in run_scenario()
/linux/tools/testing/selftests/powerpc/math/
H A Dfpu_preempt.c24 /* Time to wait for workers to get preempted (seconds) */
69 printf("\tWaiting for all workers to start..."); in test_preempt_fpu()
74 printf("\tWaiting for %d seconds to let some workers get preempted...", PREEMPT_TIME); in test_preempt_fpu()
78 printf("\tStopping workers..."); in test_preempt_fpu()
H A Dvmx_preempt.c24 /* Time to wait for workers to get preempted (seconds) */
78 printf("\tWaiting for all workers to start..."); in test_preempt_vmx()
83 printf("\tWaiting for %d seconds to let some workers get preempted...", PREEMPT_TIME); in test_preempt_vmx()
87 printf("\tStopping workers..."); in test_preempt_vmx()
H A Dvsx_preempt.c23 /* Time to wait for workers to get preempted (seconds) */
110 printf("\tWaiting for %d workers to start...", threads_starting); in test_preempt_vsx()
115 printf("\tWaiting for %d seconds to let some workers get preempted...", PREEMPT_TIME); in test_preempt_vsx()
119 printf("\tStopping workers..."); in test_preempt_vsx()
H A Dfpu_signal.c89 printf("\tWaiting for all workers to start..."); in test_signal_fpu()
103 printf("\tStopping workers..."); in test_signal_fpu()
H A Dvmx_signal.c114 printf("\tWaiting for %d workers to start... %d", threads, threads_starting); in test_signal_vmx()
131 printf("\tKilling workers..."); in test_signal_vmx()
/linux/fs/erofs/
H A DKconfig186 bool "EROFS per-cpu decompression kthread workers"
189 Saying Y here enables per-CPU kthread workers pool to carry out
195 bool "EROFS high priority per-CPU kthread workers"
199 This permits EROFS to configure per-CPU kthread workers to run
/linux/tools/testing/selftests/bpf/
H A Dtest_progs.c562 if (verbose() && !env.workers) in test__end_subtest()
928 { "workers", ARG_NUM_WORKERS, "WORKERS", OPTION_ARG_OPTIONAL,
929 "Number of workers to run in parallel, default to number of cpus." },
1130 env->workers = atoi(arg); in parse_arg()
1131 if (!env->workers) { in parse_arg()
1136 env->workers = get_nprocs(); in parse_arg()
1364 for (i = 0; i < env.workers; i++) in sigint_handler()
1761 dispatcher_threads = calloc(sizeof(pthread_t), env.workers); in server_main()
1762 data = calloc(sizeof(struct dispatch_data), env.workers); in server_main()
1764 env.worker_current_test = calloc(sizeof(int), env.workers); in server_main()
[all …]
/linux/tools/workqueue/
H A Dwq_dump.py28 idle number of idle workers
29 workers number of all workers
31 cpus CPUs the workers in the pool can run on (unbound pool)
161 print(f'idle/workers={pool.nr_idle.value_():3}/{pool.nr_workers.value_():3} ', end='')
/linux/tools/testing/selftests/mm/
H A Dtest_vmalloc.sh86 echo "available test cases are run by NUM_CPUS workers simultaneously."
121 echo "# Runs 1 test(id_1), repeats it 5 times by NUM_CPUS workers"
129 echo -n "# Runs all tests by NUM_CPUS workers, shuffled order, repeats "
/linux/tools/testing/selftests/kvm/x86/
H A Dhyperv_tlb_flush.c57 * Pass the following info to 'workers' and 'sender'
145 * Prepare to test: 'disable' workers by setting the expectation to '0',
153 /* 'Disable' workers */ in do_delay()
157 /* Make sure workers are 'disabled' before we swap PTEs. */
160 /* Make sure workers have enough time to notice */ in prepare_to_test()
176 /* Set the expectation for workers, '0' means don't test */ in prepare_to_test()
180 /* Make sure workers have enough time to test */
619 * for 'workers' and issues TLB flush hypercalls. in main()
/linux/kernel/
H A Dworkqueue_internal.h18 * The poor guys doing the actual heavy lifting. All on-duty workers are
48 struct list_head node; /* A: anchored at pool->workers */
H A Dworkqueue.c67 * While associated (!DISASSOCIATED), all workers are bound to the
71 * While DISASSOCIATED, the cpu may be offline and all workers have
84 POOL_DISASSOCIATED = 1 << 2, /* cpu can't serve workers */
124 * Rescue workers are used only on emergencies and shared by
215 int nr_workers; /* L: total number of workers */
216 int nr_idle; /* L: currently idle workers */
218 struct list_head idle_list; /* L: list of idle workers */
222 struct timer_list mayday_timer; /* L: SOS timer for workers */
224 /* a workers is either on busy_hash or idle_list, or the manager */
226 /* L: hash of busy workers */
[all …]
/linux/include/uapi/linux/
H A Dvhost.h63 * virtqueue. If userspace is not able to call this for workers its created,
64 * the kernel will free all the device's workers when the device is closed.
261 * - Vhost will create vhost workers as kernel threads.
/linux/tools/perf/trace/beauty/include/uapi/linux/
H A Dvhost.h63 * virtqueue. If userspace is not able to call this for workers its created,
64 * the kernel will free all the device's workers when the device is closed.
261 * - Vhost will create vhost workers as kernel threads.
/linux/io_uring/
H A Dio-wq.c39 IO_WQ_BIT_EXIT_ON_IDLE = 1, /* allow all workers to exit on idle */
92 * The list of free workers. Protected by #workers_lock
98 * The list of all workers. Protected by #workers_lock
325 * below the max number of workers, create one.
331 * wasn't setup with any unbounded workers. in io_wq_create_worker()
334 pr_warn_once("io-wq is not configured for unbound workers"); in io_wq_create_worker()
721 * keeping io-wq workers around for tasks that no longer have in io_wq_worker()
776 * Called when worker is going to sleep. If there are no workers currently
1482 * Set max number of unbounded workers, returns old value. If new_count is 0,
/linux/lib/
H A Dtest_objpool.c396 /* tell workers threads to quit */ in ot_start_sync()
399 /* wait all workers threads finish and quit */ in ot_start_sync()
580 /* tell workers threads to quit */ in ot_start_async()
586 /* wait all workers threads finish and quit */ in ot_start_async()
/linux/tools/testing/selftests/drivers/net/netconsole/
H A Dnetcons_userdata.sh28 # Keys owned by each torture worker. Workers do not share keys, so a failing
115 # Run the workers concurrently and fail if any of them hits an error
/linux/drivers/vhost/
H A DKconfig107 to configure the default mode for vhost workers.
/linux/tools/include/uapi/linux/
H A Dvhost.h
/linux/fs/btrfs/
H A Dasync-thread.c38 /* Up limit of concurrency workers */
41 /* Current number of concurrency workers */
/linux/samples/workqueue/stall_detector/
H A Dwq_stall.c7 * detector correctly identifies stuck workers and produces useful

1234