| /openbmc/linux/include/linux/ |
| H A D | workqueue.h | 3 * workqueue.h --- work queue handling for Linux.
37 WORK_STRUCT_COLOR_SHIFT = 5, /* color for workqueue flushing */
39 WORK_STRUCT_COLOR_SHIFT = 4, /* color for workqueue flushing */
61 * This makes pwqs aligned to 256 bytes and allows 16 workqueue
115 /* target workqueue and CPU ->timer uses to queue ->work */
124 /* target workqueue ->rcu uses to queue ->work */
140 * struct workqueue_attrs - A struct for workqueue attributes.
142 * This can be used to change attributes of an unbound workqueue.
153 * Work items in this workqueue are affine to these CPUs and not allowed
154 * to execute on other CPUs. A pool serving a workqueue must have the
[all …]
|
| /openbmc/linux/Documentation/core-api/ |
| H A D | workqueue.rst | 2 Workqueue title
14 is needed and the workqueue (wq) API is the most commonly used
20 queue is called workqueue and the thread is called worker.
22 While there are work items on the workqueue the worker executes the
24 there is no work item left on the workqueue the worker becomes idle.
28 Why Concurrency Managed Workqueue?
55 Concurrency Managed Workqueue (cmwq) is a reimplementation of wq with
58 * Maintain compatibility with the original workqueue API.
78 workqueue.
95 workqueue API functions as they see fit. They can influence some
[all …]
|
| /openbmc/linux/include/trace/events/ |
| H A D | workqueue.h | 3 #define TRACE_SYSTEM workqueue
9 #include <linux/workqueue.h>
20 * delayed work is actually queued on a workqueue (ie: once the delay
33 __string( workqueue, pwq->wq->name)
41 __assign_str(workqueue, pwq->wq->name);
46 TP_printk("work struct=%p function=%ps workqueue=%s req_cpu=%d cpu=%d",
47 __entry->work, __entry->function, __get_str(workqueue),
77 * workqueue_execute_start - called immediately before the workqueue callback
80 * Allows to track workqueue execution.
102 * workqueue_execute_end - called immediately after the workqueue callback
[all …]
|
| /openbmc/linux/kernel/ |
| H A D | workqueue_internal.h | 5 * Workqueue internal header file. Only to be included by workqueue and
11 #include <linux/workqueue.h>
20 * details on the locking annotation (L, I, X...), refer to workqueue.c.
22 * Only to be used in workqueue and async.
60 /* used only by rescuers to point to the target workqueue */
61 struct workqueue_struct *rescue_wq; /* I: the workqueue to rescue */
65 * current_wq_worker - return struct worker if %current is a workqueue worker
75 * Scheduler hooks for concurrency managed workqueue. Only to be used from
76 * sched/ and workqueue.c.
|
| H A D | workqueue.c | 3 * kernel/workqueue.c - generic async execution with shared worker pool
25 * Please read Documentation/core-api/workqueue.rst for details.
34 #include <linux/workqueue.h>
206 * tools/workqueue/wq_monitor.py.
222 * The per-pool workqueue. While queued, the lower WORK_STRUCT_FLAG_BITS
229 struct workqueue_struct *wq; /* I: the owning workqueue */
271 * Structure used to wait for workqueue flush.
282 * The externally visible workqueue. It relays the issued work items to
314 char name[WQ_NAME_LEN]; /* I: workqueue name */
444 #include <trace/events/workqueue.h>
[all …]
|
| /openbmc/phosphor-host-ipmid/ |
| H A D | host-cmd-manager.cpp | 55 if (this->workQueue.empty()) in getNextCommand()
65 auto command = this->workQueue.front(); in getNextCommand()
66 this->workQueue.pop(); in getNextCommand()
94 while (!this->workQueue.empty()) in clearQueue()
96 auto command = this->workQueue.front(); in clearQueue()
97 this->workQueue.pop(); in clearQueue()
111 if (this->workQueue.size() >= 1) in checkQueueAndAlertHost()
153 this->workQueue.emplace(command); in execute()
157 if (this->workQueue.size() == 1) in execute()
|
| /openbmc/linux/tools/workqueue/ |
| H A D | wq_monitor.py | 10 total Total number of work items executed by the workqueue.
14 CPUtime Total CPU time consumed by the workqueue in seconds. This is
19 longer than the threshold (workqueue.cpu_intensive_thresh_us)
24 wake-ups while executing a work item of the workqueue. For
49 parser.add_argument('workqueue', metavar='REGEX', nargs='*',
50 help='Target workqueue name patterns (all if empty)')
142 if args.workqueue:
143 for r in args.workqueue:
|
| H A D | wq_dump.py | 7 This is a drgn script to show the current workqueue configuration. For more
33 Workqueue CPU -> pool
37 each workqueue:
41 NAME name of the workqueue
148 print('Workqueue CPU -> pool')
151 print('[ workqueue \ type CPU', end='')
|
| /openbmc/linux/net/vmw_vsock/ |
| H A D | vsock_loopback.c | 16 struct workqueue_struct *workqueue; member
35 queue_work(vsock->workqueue, &vsock->pkt_work); in vsock_loopback_send_pkt()
130 vsock->workqueue = alloc_workqueue("vsock-loopback", 0, 0); in vsock_loopback_init()
131 if (!vsock->workqueue) in vsock_loopback_init()
145 destroy_workqueue(vsock->workqueue); in vsock_loopback_init()
159 destroy_workqueue(vsock->workqueue); in vsock_loopback_exit()
|
| /openbmc/linux/Documentation/translations/zh_CN/core-api/ |
| H A D | workqueue.rst | 4 :Original: Documentation/core-api/workqueue.rst
88 ``workqueue API`` 函数创建和排队工作项。他们可以通过在工作队列上
130 ``alloc_workqueue()`` 分配了一个wq。原来的 ``create_*workqueue()``
316 $ echo workqueue:workqueue_queue_work > /sys/kernel/tracing/set_event
350 include/linux/workqueue.h
352 kernel/workqueue.c
|
| /openbmc/linux/drivers/remoteproc/ |
| H A D | keystone_remoteproc.c | 14 #include <linux/workqueue.h>
53 * @workqueue: workqueue for processing virtio interrupts
66 struct work_struct workqueue; member
119 * Main virtqueue message workqueue function
122 * driver's workqueue. The workqueue is scheduled by the vring ISR handler.
144 container_of(work, struct keystone_rproc, workqueue); in handle_event()
157 schedule_work(&ksproc->workqueue); in keystone_rproc_vring_interrupt()
174 INIT_WORK(&ksproc->workqueue, handle_event); in keystone_rproc_start()
202 flush_work(&ksproc->workqueue); in keystone_rproc_start()
220 flush_work(&ksproc->workqueue); in keystone_rproc_stop()
|
| /openbmc/linux/arch/sh/include/asm/ |
| H A D | push-switch.h | 7 #include <linux/workqueue.h>
15 /* workqueue */
17 /* platform device, for workqueue handler */
|
| /openbmc/linux/drivers/net/wireless/quantenna/qtnfmac/ |
| H A D | shm_ipc.h | 7 #include <linux/workqueue.h>
46 struct workqueue_struct *workqueue; member
54 struct workqueue_struct *workqueue,
|
| H A D | shm_ipc.c | 62 queue_work(ipc->workqueue, &ipc->irq_work); in qtnf_shm_ipc_irq_inbound_handler()
83 struct workqueue_struct *workqueue, in qtnf_shm_ipc_init() argument
97 ipc->workqueue = workqueue; in qtnf_shm_ipc_init()
|
| /openbmc/linux/drivers/misc/ |
| H A D | tifm_core.c | 17 static struct workqueue_struct *workqueue; variable
221 flush_workqueue(workqueue); in tifm_remove_adapter()
309 queue_work(workqueue, work); in tifm_queue_work()
331 workqueue = create_freezable_workqueue("tifm"); in tifm_init()
332 if (!workqueue) in tifm_init()
347 destroy_workqueue(workqueue); in tifm_init()
356 destroy_workqueue(workqueue); in tifm_exit()
|
| /openbmc/linux/drivers/net/wireless/quantenna/qtnfmac/pcie/ |
| H A D | pcie.c | 11 #include <linux/workqueue.h>
267 ipc_tx_reg, priv->workqueue, in qtnf_pcie_init_shm_ipc()
270 ipc_rx_reg, priv->workqueue, in qtnf_pcie_init_shm_ipc()
361 pcie_priv->workqueue = create_singlethread_workqueue("QTNF_PCIE"); in qtnf_pcie_probe()
362 if (!pcie_priv->workqueue) { in qtnf_pcie_probe()
363 pr_err("failed to alloc bus workqueue\n"); in qtnf_pcie_probe()
390 destroy_workqueue(pcie_priv->workqueue); in qtnf_pcie_probe()
418 destroy_workqueue(priv->workqueue); in qtnf_pcie_remove()
|
| /openbmc/linux/drivers/tty/serial/ |
| H A D | max3100.c | 122 /* for handling irqs: need workqueue since we do spi_sync */
123 struct workqueue_struct *workqueue; member
127 /* need to know we are suspending to avoid deadlock on workqueue */
181 queue_work(s->workqueue, &s->work); in max3100_dowork()
569 if (s->workqueue) { in max3100_shutdown()
570 destroy_workqueue(s->workqueue); in max3100_shutdown()
571 s->workqueue = NULL; in max3100_shutdown()
608 s->workqueue = create_freezable_workqueue(b); in max3100_startup()
609 if (!s->workqueue) { in max3100_startup()
610 dev_warn(&s->spi->dev, "cannot create workqueue\n"); in max3100_startup()
[all …]
|
| /openbmc/linux/drivers/media/platform/mediatek/jpeg/ |
| H A D | mtk_jpeg_core.h | 145 * @job_timeout_work: encode timeout workqueue
173 * @job_timeout_work: decode timeout workqueue
196 * @workqueue: decode work queue
216 struct workqueue_struct *workqueue; member
281 * @jpeg_work: jpeg encoder workqueue
|
| /openbmc/linux/drivers/crypto/intel/qat/qat_common/ |
| H A D | adf_vf_isr.c | 10 #include <linux/workqueue.h>
277 * adf_flush_vf_wq() - Flush workqueue for VF
281 * are received and flushes the workqueue 'adf_vf_stop_wq'.
294 * adf_init_vf_wq() - Init workqueue for VF
296 * Function init workqueue 'adf_vf_stop_wq' for VF.
|
| /openbmc/linux/drivers/mfd/ |
| H A D | ezx-pcap.c | 45 struct workqueue_struct *workqueue; member
151 queue_work(pcap->workqueue, &pcap->msr_work); in pcap_mask_irq()
159 queue_work(pcap->workqueue, &pcap->msr_work); in pcap_unmask_irq()
210 queue_work(pcap->workqueue, &pcap->isr_work); in pcap_irq_handler()
412 destroy_workqueue(pcap->workqueue); in ezx_pcap_remove()
449 pcap->workqueue = create_singlethread_workqueue("pcapd"); in ezx_pcap_probe()
450 if (!pcap->workqueue) { in ezx_pcap_probe()
505 destroy_workqueue(pcap->workqueue); in ezx_pcap_probe()
|
| /openbmc/linux/drivers/media/platform/amphion/ |
| H A D | vpu_core.c | 259 core->workqueue = alloc_ordered_workqueue("vpu", WQ_MEM_RECLAIM); in vpu_core_register()
260 if (!core->workqueue) { in vpu_core_register()
261 dev_err(core->dev, "fail to alloc workqueue\n"); in vpu_core_register()
288 if (core->workqueue) { in vpu_core_register()
289 destroy_workqueue(core->workqueue); in vpu_core_register()
290 core->workqueue = NULL; in vpu_core_register()
313 if (core->workqueue) { in vpu_core_unregister()
316 destroy_workqueue(core->workqueue); in vpu_core_unregister()
317 core->workqueue = NULL; in vpu_core_unregister()
768 queue_work(core->workqueue, &core->msg_work); in vpu_core_resume_work()
[all …]
|
| /openbmc/linux/drivers/scsi/fcoe/ |
| H A D | fcoe_sysfs.c | 690 * fcoe_ctlr_device_flush_work() - Flush a FIP ctlr's workqueue
691 * @ctlr: Pointer to the FIP ctlr whose workqueue is to be flushed
698 "when no workqueue created.\n", ctlr->id); in fcoe_ctlr_device_flush_work()
707 * fcoe_ctlr_device_queue_work() - Schedule work for a FIP ctlr's workqueue
708 * @ctlr: Pointer to the FIP ctlr who owns the devloss workqueue
720 "when no workqueue created.\n", ctlr->id); in fcoe_ctlr_device_queue_work()
730 * fcoe_ctlr_device_flush_devloss() - Flush a FIP ctlr's devloss workqueue
731 * @ctlr: Pointer to FIP ctlr whose workqueue is to be flushed
738 "when no workqueue created.\n", ctlr->id); in fcoe_ctlr_device_flush_devloss()
747 * fcoe_ctlr_device_queue_devloss_work() - Schedule work for a FIP ctlr's devloss workqueue
[all …]
|
| /openbmc/linux/Documentation/fb/ |
| H A D | deferred_io.rst | 16 - schedule a workqueue task to be run after a delay
19 - the workqueue task comes in and mkcleans the pages on the list, then
70 from a workqueue.
|
| /openbmc/linux/drivers/net/wireless/st/cw1200/ |
| H A D | scan.c | 40 queue_delayed_work(priv->workqueue, &priv->scan.timeout, in cw1200_scan_start()
122 queue_work(priv->workqueue, &priv->scan.work); in cw1200_hw_scan()
263 queue_work(priv->workqueue, &priv->scan.work); in cw1200_scan_work()
277 if (queue_work(priv->workqueue, &priv->unjoin_work) <= 0) in cw1200_scan_restart_delayed()
288 queue_delayed_work(priv->workqueue, &priv->clear_recent_scan_work, HZ); in cw1200_scan_complete()
308 queue_delayed_work(priv->workqueue, &priv->scan.timeout, 0); in cw1200_scan_failed_cb()
322 queue_delayed_work(priv->workqueue, &priv->scan.timeout, 0); in cw1200_scan_complete_cb()
388 queue_delayed_work(priv->workqueue, &priv->scan.probe_work, in cw1200_probe_work()
|
| /openbmc/linux/net/mac802154/ |
| H A D | main.c | 200 local->workqueue = in ieee802154_register_hw()
202 if (!local->workqueue) { in ieee802154_register_hw()
265 destroy_workqueue(local->workqueue); in ieee802154_register_hw()
276 flush_workqueue(local->workqueue); in ieee802154_unregister_hw()
285 destroy_workqueue(local->workqueue); in ieee802154_unregister_hw()
|