Home
last modified time | relevance | path

Searched refs:workqueue (Results 1 – 25 of 162) sorted by relevance

1234567

/linux/Documentation/translations/zh_CN/core-api/
H A Dworkqueue.rst4 :Original: Documentation/core-api/workqueue.rst
31 列被称为workqueue，线程被称为工作者（worker，即执行这一队列的线程）。
74 向该函数的工作项，并在工作队列中排队等待该工作项。（就是挂到workqueue
95 ``workqueue API`` 函数创建和排队工作项。他们可以通过在工作队列上
123 workqueue将自动创建与属性相匹配的后备工作者池。调节并发水平的责任在
137 ``alloc_workqueue()`` 分配了一个wq。原来的 ``create_*workqueue()``
324 使用模块参数 ``workqueue.default_affinity_scope`` 指定
346 默认的亲和性作用域可以被模块参数 ``workqueue.default_affinity_scope``
350 如果设置了 ``WQ_SYSFS`` ，工作队列会在它的 ``/sys/devices/virtual/workqueue/WQ_NAME/``
537 使用 tools/workqueue/wq_dump.py（drgn脚本） 来检查未
[all …]
/linux/include/trace/events/
H A Dworkqueue.h3 #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);
46 TP_printk("work struct=%p function=%ps workqueue=%s req_cpu=%d cpu=%d",
47 __entry->work, __entry->function, __get_str(workqueue),
79 * workqueue_execute_start - called immediately before the workqueue callback
82 * Allows to track workqueue execution.
104 * workqueue_execute_end - called immediately after the workqueue callbac
[all...]
/linux/drivers/misc/
H A Dtifm_core.c17 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/drivers/net/wireless/quantenna/qtnfmac/
H A Dshm_ipc.c62 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()
H A Dshm_ipc.h46 struct workqueue_struct *workqueue; member
54 struct workqueue_struct *workqueue,
/linux/drivers/net/wireless/st/cw1200/
H A Dscan.c40 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()
H A Dmain.c349 priv->workqueue = create_singlethread_workqueue("cw1200_wq"); in cw1200_init_common()
350 if (!priv->workqueue) { in cw1200_init_common()
389 destroy_workqueue(priv->workqueue); in cw1200_init_common()
401 destroy_workqueue(priv->workqueue); in cw1200_init_common()
470 destroy_workqueue(priv->workqueue); in cw1200_unregister_common()
471 priv->workqueue = NULL; in cw1200_unregister_common()
H A Dtxrx.c672 if (queue_work(priv->workqueue, in cw1200_tx_h_rate_policy()
691 queue_work(priv->workqueue, in cw1200_tx_h_pm_state()
888 queue_work(priv->workqueue, in cw1200_tx_confirm_cb()
1175 queue_work(priv->workqueue, in cw1200_rx_cb()
1185 queue_work(priv->workqueue, in cw1200_rx_cb()
1277 flush_workqueue(priv->workqueue); in cw1200_link_id_reset()
1286 if (queue_work(priv->workqueue, in cw1200_link_id_reset()
1298 if (queue_work(priv->workqueue, &priv->link_id_work) <= 0) in cw1200_link_id_reset()
1300 flush_workqueue(priv->workqueue); in cw1200_link_id_reset()
1349 if (queue_work(priv->workqueue, &priv->link_id_work) <= 0) in cw1200_alloc_link_id()
[all …]
H A Dsta.c115 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()
993 queue_delayed_work(priv->workqueue, in cw1200_event_handler()
1043 if (queue_work(priv->workqueue, &priv->unjoin_work) <= 0) in cw1200_bss_loss_work()
1201 queue_work(priv->workqueue, &priv->join_complete_work); in cw1200_join_complete_cb()
1327 queue_delayed_work(priv->workqueue, in cw1200_do_join()
1344 if (queue_work(priv->workqueue, &priv->unjoin_work) <= 0) in cw1200_do_join()
1374 if (queue_work(priv->workqueue, &priv->unjoin_work) <= 0) in cw1200_join_timeout()
[all …]
/linux/drivers/media/platform/amphion/
H A Dvpu_msgs.c289 if (!inst->workqueue) in vpu_inst_handle_msg()
296 queue_work(inst->workqueue, &inst->msg_work); in vpu_inst_handle_msg()
369 queue_delayed_work(core->workqueue, &core->msg_delayed_work, delay); in vpu_msg_run_work()
394 if (inst->workqueue && kfifo_len(&inst->msg_fifo) >= bytes) in vpu_msg_delayed_work()
395 queue_work(inst->workqueue, &inst->msg_work); in vpu_msg_delayed_work()
418 queue_work(core->workqueue, &core->msg_work); in vpu_isr()
/linux/drivers/char/tpm/
H A Dtpm_vtpm_proxy.c53 static struct workqueue_struct *workqueue; variable
482 queue_work(workqueue, &proxy_dev->work); in vtpm_proxy_work_start()
691 workqueue = create_workqueue("tpm-vtpm"); in vtpm_module_init()
692 if (!workqueue) { in vtpm_module_init()
700 destroy_workqueue(workqueue); in vtpm_module_init()
708 destroy_workqueue(workqueue); in vtpm_module_exit()
/linux/net/bluetooth/
H A Dcoredump.c207 queue_delayed_work(hdev->workqueue, &hdev->dump.dump_timeout, in hci_devcd_handle_pkt_init()
465 queue_work(hdev->workqueue, &hdev->dump.dump_rx); in hci_devcd_init()
484 queue_work(hdev->workqueue, &hdev->dump.dump_rx); in hci_devcd_append()
509 queue_work(hdev->workqueue, &hdev->dump.dump_rx); in hci_devcd_append_pattern()
529 queue_work(hdev->workqueue, &hdev->dump.dump_rx); in hci_devcd_complete()
549 queue_work(hdev->workqueue, &hdev->dump.dump_rx); in hci_devcd_abort()
/linux/drivers/net/ethernet/mellanox/mlx4/
H A Den_main.c215 queue_work(mdev->workqueue, &priv->linkstate_task); in mlx4_en_event()
254 destroy_workqueue(mdev->workqueue); in mlx4_en_remove()
332 mdev->workqueue = create_singlethread_workqueue("mlx4_en"); in mlx4_en_probe()
333 if (!mdev->workqueue) { in mlx4_en_probe()
/linux/Documentation/fb/
H A Ddeferred_io.rst16 - 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/
H A Dns.c10 #include <linux/workqueue.h>
25 struct workqueue_struct *workqueue; member
684 queue_work(qrtr_ns.workqueue, &qrtr_ns.work); in qrtr_ns_data_ready()
706 qrtr_ns.workqueue = alloc_ordered_workqueue("qrtr_ns_handler", 0); in qrtr_ns_init()
707 if (!qrtr_ns.workqueue) { in qrtr_ns_init()
752 destroy_workqueue(qrtr_ns.workqueue); in qrtr_ns_init()
762 destroy_workqueue(qrtr_ns.workqueue); in qrtr_ns_remove()
/linux/tools/workqueue/
H A Dwq_monitor.py135 if args.workqueue:
136 for r in args.workqueue:
/linux/drivers/remoteproc/
H A Dimx_rproc.c27 #include <linux/workqueue.h>
119 struct workqueue_struct *workqueue;
852 queue_work(priv->workqueue, &priv->rproc_work);
1215 struct workqueue_struct *workqueue = data;
1217 destroy_workqueue(workqueue);
1248 priv->workqueue = create_workqueue(dev_name(dev));
1249 if (!priv->workqueue) {
1250 dev_err(dev, "cannot create workqueue\n");
1254 ret = devm_add_action_or_reset(dev, imx_rproc_destroy_workqueue, priv->workqueue);
1256 return dev_err_probe(dev, ret, "Failed to add devm destroy workqueue actio
110 struct workqueue_struct *workqueue; global() member
1014 struct workqueue_struct *workqueue = data; imx_rproc_destroy_workqueue() local
[all...]
H A Dstm32_rproc.c91 struct workqueue_struct *workqueue; member
305 queue_work(ddata->workqueue, &mb->vq_work); in stm32_rproc_mb_callback()
868 ddata->workqueue = create_workqueue(dev_name(dev)); in stm32_rproc_probe()
869 if (!ddata->workqueue) { in stm32_rproc_probe()
890 destroy_workqueue(ddata->workqueue); in stm32_rproc_probe()
912 destroy_workqueue(ddata->workqueue); in stm32_rproc_remove()
/linux/Documentation/driver-api/crypto/iaa/
H A Diaa-crypto.rst175 For instance, here's an example of configuring an IAA workqueue and
194 Whenever a new workqueue is bound to or unbound from the iaa_crypto
197 workqueue available. Current best practice is to configure and bind
198 at least one workqueue for each IAA device, but as long as there is at
199 least one workqueue configured and bound to any IAA device in the
205 binding of the first IAA workqueue to the iaa_crypto driver.
448 system to be configured properly as a kernel workqueue with a
449 workqueue driver_name of "crypto".
525 system to be configured properly as a kernel workqueue with a
526 workqueue driver_name of "crypto".
[all …]
/linux/drivers/cdx/controller/
H A Dmcdi.c128 mcdi->workqueue = alloc_ordered_workqueue("mcdi_wq", 0); in cdx_mcdi_init()
129 if (!mcdi->workqueue) in cdx_mcdi_init()
165 destroy_workqueue(mcdi->workqueue); in cdx_mcdi_finish()
204 flush_workqueue(mcdi->workqueue); in cdx_mcdi_wait_for_quiescence()
547 queue_work(mcdi->workqueue, &cmd->work); in cdx_mcdi_rpc_async_internal()
/linux/drivers/scsi/
H A Dvmw_pvscsi.c26 #include <linux/workqueue.h>
75 struct workqueue_struct *workqueue; member
916 * workqueue we can safely flush any outstanding work. in pvscsi_host_reset()
918 flush_workqueue(adapter->workqueue); in pvscsi_host_reset()
1140 adapter->workqueue = in pvscsi_setup_msg_workqueue()
1142 if (!adapter->workqueue) { in pvscsi_setup_msg_workqueue()
1187 queue_work(adapter->workqueue, &adapter->work); in pvscsi_isr()
1221 if (adapter->workqueue) in pvscsi_release_resources()
1222 destroy_workqueue(adapter->workqueue); in pvscsi_release_resources()
1568 if (adapter->workqueue) in __pvscsi_shutdown()
[all...]
/linux/drivers/net/ethernet/sfc/
H A Defx_common.c204 queue_work(efx->workqueue, &efx->mac_work); in efx_set_rx_mode()
347 queue_delayed_work(efx->workqueue, &efx->monitor_work, in efx_start_monitor()
1021 efx->workqueue = create_singlethread_workqueue(efx->workqueue_name); in efx_init_struct()
1022 if (!efx->workqueue) { in efx_init_struct()
1044 if (efx->workqueue) { in efx_fini_struct()
1045 destroy_workqueue(efx->workqueue); in efx_fini_struct()
1046 efx->workqueue = NULL; in efx_fini_struct()
/linux/drivers/net/ethernet/sfc/siena/
H A Defx_common.c208 queue_work(efx->workqueue, &efx->mac_work); in efx_siena_set_rx_mode()
351 queue_delayed_work(efx->workqueue, &efx->monitor_work, in efx_siena_start_monitor()
1046 efx->workqueue = create_singlethread_workqueue(efx->workqueue_name); in efx_siena_init_struct()
1047 if (!efx->workqueue) { in efx_siena_init_struct()
1069 if (efx->workqueue) { in efx_siena_fini_struct()
1070 destroy_workqueue(efx->workqueue); in efx_siena_fini_struct()
1071 efx->workqueue = NULL; in efx_siena_fini_struct()
/linux/fs/smb/client/
H A Dsmbdirect.c327 queue_work(sc->workqueue, &sc->disconnect_work); in smbd_conn_upcall()
759 queue_work(sc->workqueue, &sc->idle.immediate_work); in recv_done()
802 mod_delayed_work(sc->workqueue, &sc->idle.timer_work, in recv_done()
885 queue_work(sc->workqueue, &sc->idle.immediate_work); in smbd_create_id()
895 queue_work(sc->workqueue, &sc->recv_io.posted.refill_work);
1202 mod_delayed_work(sc->workqueue, &sc->idle.timer_work, in smbd_post_send_iter()
1460 queue_work(sc->workqueue, &sc->recv_io.posted.refill_work); in get_receive_buffer()
1797 queue_work(sc->workqueue, &sc->recv_io.posted.refill_work); in _smbd_get_connection()
1873 mod_delayed_work(sc->workqueue, &sc->idle.timer_work, in _smbd_get_connection()
1876 queue_work(sc->workqueue, in _smbd_get_connection()
1798 struct workqueue_struct *workqueue; _smbd_get_connection() local
[all...]
/linux/Documentation/translations/zh_CN/rust/
H A Dtesting.rst95 /// # use kernel::{spawn_work_item, workqueue};
96 /// spawn_work_item!(workqueue::system(), || pr_info!("x\n"))?;

1234567