/linux/Documentation/translations/zh_CN/core-api/ |
A D | workqueue.rst | 4 :Original: Documentation/core-api/workqueue.rst 29 列被称为workqueue,线程被称为工作者(worker,即执行这一队列的线程)。 72 向该函数的工作项,并在工作队列中排队等待该工作项。(就是挂到workqueue 87 ``workqueue API`` 函数创建和排队工作项。他们可以通过在工作队列上 115 workqueue将自动创建与属性相匹配的后备工作者池。调节并发水平的责任在 129 ``alloc_workqueue()`` 分配了一个wq。原来的 ``create_*workqueue()`` 319 $ echo workqueue:workqueue_queue_work > /sys/kernel/debug/tracing/set_event 337 include/linux/workqueue.h 339 kernel/workqueue.c
|
/linux/lib/ |
A D | test_kasan_module.c | 101 struct workqueue_struct *workqueue; in kasan_workqueue_uaf() local 104 workqueue = create_workqueue("kasan_wq_test"); in kasan_workqueue_uaf() 105 if (!workqueue) { in kasan_workqueue_uaf() 116 queue_work(workqueue, work); in kasan_workqueue_uaf() 117 destroy_workqueue(workqueue); in kasan_workqueue_uaf()
|
/linux/net/vmw_vsock/ |
A D | vsock_loopback.c | 16 struct workqueue_struct *workqueue; member 39 queue_work(vsock->workqueue, &vsock->pkt_work); in vsock_loopback_send_pkt() 146 vsock->workqueue = alloc_workqueue("vsock-loopback", 0, 0); in vsock_loopback_init() 147 if (!vsock->workqueue) in vsock_loopback_init() 162 destroy_workqueue(vsock->workqueue); in vsock_loopback_init() 184 destroy_workqueue(vsock->workqueue); in vsock_loopback_exit()
|
/linux/include/trace/events/ |
A D | workqueue.h | 3 #define TRACE_SYSTEM workqueue 33 __string( workqueue, pwq->wq->name) 41 __assign_str(workqueue, pwq->wq->name); 47 __entry->work, __entry->function, __get_str(workqueue),
|
/linux/drivers/misc/ |
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()
|
/linux/net/mac802154/ |
A D | main.c | 146 local->workqueue = in ieee802154_register_hw() 148 if (!local->workqueue) { in ieee802154_register_hw() 199 destroy_workqueue(local->workqueue); in ieee802154_register_hw() 210 flush_workqueue(local->workqueue); in ieee802154_unregister_hw() 218 destroy_workqueue(local->workqueue); in ieee802154_unregister_hw()
|
/linux/drivers/net/wireless/quantenna/qtnfmac/ |
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()
|
A D | shm_ipc.h | 46 struct workqueue_struct *workqueue; member 54 struct workqueue_struct *workqueue,
|
/linux/Documentation/core-api/ |
A D | workqueue.rst | 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. 58 * Maintain compatibility with the original workqueue API. 78 workqueue. 133 Unbound workqueue can be assigned custom attributes using 356 workqueue users. 397 2. No one queues the work item to another workqueue. 411 .. kernel-doc:: include/linux/workqueue.h [all …]
|
/linux/drivers/remoteproc/ |
A D | keystone_remoteproc.c | 66 struct work_struct workqueue; member 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()
|
/linux/drivers/mfd/ |
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() 212 queue_work(pcap->workqueue, &pcap->isr_work); in pcap_irq_handler() 414 destroy_workqueue(pcap->workqueue); in ezx_pcap_remove() 453 pcap->workqueue = create_singlethread_workqueue("pcapd"); in ezx_pcap_probe() 454 if (!pcap->workqueue) { in ezx_pcap_probe() 509 destroy_workqueue(pcap->workqueue); in ezx_pcap_probe()
|
/linux/drivers/net/wireless/st/cw1200/ |
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()
|
A D | main.c | 344 priv->workqueue = create_singlethread_workqueue("cw1200_wq"); in cw1200_init_common() 345 if (!priv->workqueue) { in cw1200_init_common() 384 destroy_workqueue(priv->workqueue); in cw1200_init_common() 396 destroy_workqueue(priv->workqueue); in cw1200_init_common() 465 destroy_workqueue(priv->workqueue); in cw1200_unregister_common() 466 priv->workqueue = NULL; in cw1200_unregister_common()
|
A D | sta.c | 115 flush_workqueue(priv->workqueue); in cw1200_stop() 167 queue_delayed_work(priv->workqueue, in __cw1200_cqm_bssloss_sm() 178 queue_work(priv->workqueue, &priv->bss_params_work); in __cw1200_cqm_bssloss_sm() 264 if (queue_work(priv->workqueue, &priv->unjoin_work) <= 0) in cw1200_remove_interface() 991 queue_delayed_work(priv->workqueue, in cw1200_event_handler() 1325 queue_delayed_work(priv->workqueue, in cw1200_do_join() 1589 flush_workqueue(priv->workqueue); in cw1200_sta_remove() 1615 queue_work(priv->workqueue, in __cw1200_sta_notify() 1626 queue_work(priv->workqueue, in __cw1200_sta_notify() 1714 queue_work(priv->workqueue, &priv->set_tim_work); in cw1200_set_tim() [all …]
|
A D | txrx.c | 672 if (queue_work(priv->workqueue, in cw1200_tx_h_rate_policy() 691 queue_work(priv->workqueue, in cw1200_tx_h_pm_state() 891 queue_work(priv->workqueue, in cw1200_tx_confirm_cb() 1179 queue_work(priv->workqueue, in cw1200_rx_cb() 1189 queue_work(priv->workqueue, in cw1200_rx_cb() 1281 flush_workqueue(priv->workqueue); in cw1200_link_id_reset() 1290 if (queue_work(priv->workqueue, in cw1200_link_id_reset() 1302 if (queue_work(priv->workqueue, &priv->link_id_work) <= 0) in cw1200_link_id_reset() 1304 flush_workqueue(priv->workqueue); in cw1200_link_id_reset() 1353 if (queue_work(priv->workqueue, &priv->link_id_work) <= 0) in cw1200_alloc_link_id() [all …]
|
/linux/drivers/tty/serial/ |
A D | max3100.c | 120 struct workqueue_struct *workqueue; member 178 queue_work(s->workqueue, &s->work); in max3100_dowork() 556 if (s->workqueue) { in max3100_shutdown() 557 flush_workqueue(s->workqueue); in max3100_shutdown() 558 destroy_workqueue(s->workqueue); in max3100_shutdown() 559 s->workqueue = NULL; in max3100_shutdown() 596 s->workqueue = create_freezable_workqueue(b); in max3100_startup() 597 if (!s->workqueue) { in max3100_startup() 607 destroy_workqueue(s->workqueue); in max3100_startup() 608 s->workqueue = NULL; in max3100_startup() [all …]
|
/linux/drivers/net/wireless/quantenna/qtnfmac/pcie/ |
A D | pcie.c | 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() 390 destroy_workqueue(pcie_priv->workqueue); in qtnf_pcie_probe() 418 destroy_workqueue(priv->workqueue); in qtnf_pcie_remove()
|
/linux/drivers/input/rmi4/ |
A D | rmi_f54.c | 113 struct workqueue_struct *workqueue; member 210 queue_delayed_work(f54->workqueue, &f54->work, 0); in rmi_f54_request_report() 604 queue_delayed_work(f54->workqueue, &f54->work, in rmi_f54_work() 691 f54->workqueue = create_singlethread_workqueue("rmi4-poller"); in rmi_f54_probe() 692 if (!f54->workqueue) in rmi_f54_probe() 736 flush_workqueue(f54->workqueue); in rmi_f54_probe() 737 destroy_workqueue(f54->workqueue); in rmi_f54_probe() 747 destroy_workqueue(f54->workqueue); in rmi_f54_remove()
|
/linux/drivers/memstick/core/ |
A D | memstick.c | 24 static struct workqueue_struct *workqueue; variable 208 queue_work(workqueue, &host->media_checker); in memstick_detect_change() 549 flush_workqueue(workqueue); in memstick_remove_host() 624 workqueue = create_freezable_workqueue("kmemstick"); in memstick_init() 625 if (!workqueue) in memstick_init() 641 destroy_workqueue(workqueue); in memstick_init() 650 destroy_workqueue(workqueue); in memstick_exit()
|
/linux/drivers/char/tpm/ |
A D | tpm_vtpm_proxy.c | 53 static struct workqueue_struct *workqueue; variable 481 queue_work(workqueue, &proxy_dev->work); in vtpm_proxy_work_start() 706 workqueue = create_workqueue("tpm-vtpm"); in vtpm_module_init() 707 if (!workqueue) { in vtpm_module_init() 723 destroy_workqueue(workqueue); in vtpm_module_exit()
|
/linux/drivers/net/ethernet/mellanox/mlx4/ |
A D | en_main.c | 208 queue_work(mdev->workqueue, &priv->linkstate_task); in mlx4_en_event() 240 destroy_workqueue(mdev->workqueue); in mlx4_en_remove() 327 mdev->workqueue = create_singlethread_workqueue("mlx4_en"); in mlx4_en_add() 328 if (!mdev->workqueue) in mlx4_en_add()
|
/linux/drivers/net/wireless/marvell/libertas/ |
A D | if_sdio.c | 124 struct workqueue_struct *workqueue; member 974 queue_work(card->workqueue, &card->packet_worker); in if_sdio_host_to_card() 1068 flush_workqueue(card->workqueue); in if_sdio_power_save() 1181 card->workqueue = alloc_workqueue("libertas_sdio", WQ_MEM_RECLAIM, 0); in if_sdio_probe() 1182 if (unlikely(!card->workqueue)) { in if_sdio_probe() 1233 flush_workqueue(card->workqueue); in if_sdio_probe() 1236 destroy_workqueue(card->workqueue); in if_sdio_probe() 1280 destroy_workqueue(card->workqueue); in if_sdio_remove()
|
A D | if_spi.c | 58 struct workqueue_struct *workqueue; member 982 queue_work(card->workqueue, &card->packet_work); in if_spi_host_to_card() 997 queue_work(card->workqueue, &card->packet_work); in if_spi_host_interrupt() 1154 card->workqueue = alloc_workqueue("libertas_spi", WQ_MEM_RECLAIM, 0); in if_spi_probe() 1155 if (!card->workqueue) { in if_spi_probe() 1186 destroy_workqueue(card->workqueue); in if_spi_probe() 1211 destroy_workqueue(card->workqueue); in libertas_spi_remove() 1226 flush_workqueue(card->workqueue); in if_spi_suspend()
|
/linux/Documentation/fb/ |
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.
|
/linux/net/qrtr/ |
A D | ns.c | 24 struct workqueue_struct *workqueue; member 755 queue_work(qrtr_ns.workqueue, &qrtr_ns.work); in qrtr_ns_data_ready() 777 qrtr_ns.workqueue = alloc_workqueue("qrtr_ns_handler", WQ_UNBOUND, 1); in qrtr_ns_init() 778 if (!qrtr_ns.workqueue) { in qrtr_ns_init() 805 destroy_workqueue(qrtr_ns.workqueue); in qrtr_ns_init() 815 destroy_workqueue(qrtr_ns.workqueue); in qrtr_ns_remove()
|