| /src/sys/sys/ |
| H A D | taskqueue.h | 40 struct taskqueue;
69 struct taskqueue *taskqueue_create(const char *name, int mflags,
72 int taskqueue_start_threads(struct taskqueue **tqp, int count, int pri,
74 int taskqueue_start_threads_in_proc(struct taskqueue **tqp, int count,
76 int taskqueue_start_threads_cpuset(struct taskqueue **tqp, int count,
78 int taskqueue_enqueue(struct taskqueue *queue, struct task *task);
79 int taskqueue_enqueue_flags(struct taskqueue *queue, struct task *task,
81 int taskqueue_enqueue_timeout(struct taskqueue *queue,
83 int taskqueue_enqueue_timeout_sbt(struct taskqueue *queue,
86 int taskqueue_poll_is_busy(struct taskqueue *queue, struct task *task);
[all …]
|
| H A D | _task.h | 62 struct taskqueue;
65 struct taskqueue *q;
|
| /src/sys/kern/ |
| H A D | subr_taskqueue.c | 63 struct taskqueue { struct
107 _timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task, in _timeout_task_init()
119 TQ_SLEEP(struct taskqueue *tq, void *p, const char *wm) in TQ_SLEEP()
127 task_get_busy(struct taskqueue *queue, struct task *task) in task_get_busy()
139 static struct taskqueue *
144 struct taskqueue *queue; in _taskqueue_create()
151 queue = malloc(sizeof(struct taskqueue), M_TASKQUEUE, mflags | M_ZERO); in _taskqueue_create()
176 struct taskqueue *
186 taskqueue_set_callback(struct taskqueue *queue, in taskqueue_set_callback()
206 taskqueue_terminate(struct thread **pp, struct taskqueue *tq) in taskqueue_terminate()
[all …]
|
| /src/sys/compat/linuxkpi/common/src/ |
| H A D | linux_work.c | 61 struct taskqueue *linux_irq_work_tq;
119 struct taskqueue *tq; in linux_delayed_work_enqueue()
121 tq = dwork->work.work_queue->taskqueue; in linux_delayed_work_enqueue()
153 taskqueue_enqueue(wq->taskqueue, &work->work_task); in linux_queue_work_on()
386 struct taskqueue *tq; in linux_cancel_work()
393 tq = work->work_queue->taskqueue; in linux_cancel_work()
417 struct taskqueue *tq; in linux_cancel_work_sync()
428 tq = work->work_queue->taskqueue; in linux_cancel_work_sync()
433 tq = work->work_queue->taskqueue; in linux_cancel_work_sync()
478 struct taskqueue *tq; in linux_cancel_delayed_work()
[all …]
|
| /src/sys/dev/thunderbolt/ |
| H A D | hcm.c | 81 hcm->taskqueue = taskqueue_create("hcm_event", M_NOWAIT, in hcm_attach()
82 taskqueue_thread_enqueue, &hcm->taskqueue); in hcm_attach()
83 if (hcm->taskqueue == NULL) in hcm_attach()
85 taskqueue_start_threads(&hcm->taskqueue, 1, PI_DISK, "tbhcm%d_tq", in hcm_attach()
98 if (hcm->taskqueue) in hcm_detach()
99 taskqueue_free(hcm->taskqueue); in hcm_detach()
108 taskqueue_enqueue(hcm->taskqueue, &hcm->cfg_task); in hcm_router_discover()
|
| H A D | hcm_var.h | 40 struct taskqueue *taskqueue; member
|
| /src/sys/dev/hyperv/netvsc/ |
| H A D | if_hnvar.h | 130 struct taskqueue *hn_tx_taskq;
218 struct taskqueue **hn_tx_taskqs;
229 struct taskqueue *hn_mgmt_taskq;
230 struct taskqueue *hn_mgmt_taskq0;
268 struct taskqueue *hn_vf_taskq;
|
| /src/sys/dev/hyperv/vmbus/ |
| H A D | vmbus_var.h | 82 struct taskqueue *event_tq; /* event taskq */
83 struct taskqueue *message_tq; /* message taskq */
117 struct taskqueue *vmbus_devtq; /* for dev attach/detach */
118 struct taskqueue *vmbus_subchtq; /* for sub-chan attach/detach */
|
| H A D | vmbus_chanvar.h | 57 struct taskqueue *ch_tq;
130 struct taskqueue *ch_mgmt_tq;
|
| H A D | vmbus_if.m | 35 struct taskqueue;
55 METHOD struct taskqueue * get_event_taskq { struct
|
| /src/sys/compat/linuxkpi/common/include/linux/ |
| H A D | workqueue.h | 57 struct taskqueue *taskqueue; member
136 taskqueue_drain_all(system_wq->taskqueue)
172 taskqueue_drain_all((wq)->taskqueue)
176 taskqueue_drain_all((wq)->taskqueue); \
|
| H A D | irq_work.h | 38 #define LKPI_IRQ_WORK_STD_TQ system_wq->taskqueue
61 extern struct taskqueue *linux_irq_work_tq;
|
| H A D | kthread.h | 49 struct taskqueue *tq;
53 struct taskqueue *tq;
|
| /src/sys/dev/wtap/wtap_hal/ |
| H A D | handler.h | 42 struct taskqueue;
45 struct taskqueue *tq;
|
| /src/sys/dev/qlxgbe/ |
| H A D | ql_def.h | 121 struct taskqueue *fp_taskqueue;
228 struct taskqueue *stats_tq;
252 struct taskqueue *err_tq;
257 struct taskqueue *async_event_tq;
|
| /src/sys/dev/iicbus/ |
| H A D | iichid.c | 188 struct taskqueue *taskqueue; member
572 taskqueue_enqueue_timeout_sbt(sc->taskqueue, &sc->sampling_task, in iichid_sampling_task()
749 taskqueue_enqueue_timeout(sc->taskqueue, &sc->sampling_task, 0); in iichid_reset_callout()
759 taskqueue_cancel_timeout(sc->taskqueue, &sc->sampling_task, NULL); in iichid_teardown_callout()
846 taskqueue_start_threads(&sc->taskqueue, 1, PI_TTY, in iichid_intr_setup()
859 taskqueue_drain_all(sc->taskqueue); in iichid_intr_unsetup()
1144 sc->taskqueue = taskqueue_create_fast("iichid_tq", M_WAITOK | M_ZERO, in iichid_attach()
1145 taskqueue_thread_enqueue, &sc->taskqueue); in iichid_attach()
1146 TIMEOUT_TASK_INIT(sc->taskqueue, &sc->sampling_task, 0, in iichid_attach()
1269 if (sc->taskqueue != NULL) in iichid_detach()
[all …]
|
| /src/share/man/man9/ |
| H A D | Makefile | 346 taskqueue.9 \
2280 MLINKS+=taskqueue.9 TASK_INIT.9 \
2281 taskqueue.9 TASK_INITIALIZER.9 \
2282 taskqueue.9 taskqueue_block.9 \
2283 taskqueue.9 taskqueue_cancel.9 \
2284 taskqueue.9 taskqueue_cancel_timeout.9 \
2285 taskqueue.9 taskqueue_create.9 \
2286 taskqueue.9 taskqueue_create_fast.9 \
2287 taskqueue.9 TASKQUEUE_DECLARE.9 \
2288 taskqueue.9 TASKQUEUE_DEFINE.9 \
[all …]
|
| /src/sys/cddl/contrib/opensolaris/uts/common/sys/ |
| H A D | taskq.h | 39 struct taskqueue;
41 struct taskqueue *tq_queue;
|
| /src/sys/dev/wtap/ |
| H A D | if_wtapvar.h | 99 struct taskqueue;
112 struct taskqueue *sc_tq; /* private task queue */
|
| /src/sys/dev/vnic/ |
| H A D | nicvf_queues.h | 260 struct taskqueue *rbdr_taskq;
296 struct taskqueue *cmp_taskq;
332 struct taskqueue *snd_taskq;
355 struct taskqueue *qs_err_taskq;
|
| /src/sys/dev/qlxgb/ |
| H A D | qla_def.h | 100 struct taskqueue *rcv_tq;
163 struct taskqueue *tx_tq;
|
| /src/sys/dev/ena/ |
| H A D | ena.h | 226 struct taskqueue *cleanup_tq;
364 struct taskqueue *enqueue_tq;
500 struct taskqueue *reset_tq;
502 struct taskqueue *metrics_tq;
|
| /src/sys/dev/qcom_ess_edma/ |
| H A D | qcom_ess_edma_var.h | 177 struct taskqueue *completion_tq;
189 struct taskqueue *completion_tq;
|
| /src/sys/ufs/ufs/ |
| H A D | ufsmount.h | 55 struct taskqueue;
116 struct taskqueue *um_trim_tq; /* (c) trim request queue */
|
| /src/sys/dev/ufshci/ |
| H A D | ufshci_ctrlr.c | 370 ctrlr->taskqueue = taskqueue_create("ufshci_taskq", M_WAITOK, in ufshci_ctrlr_construct()
371 taskqueue_thread_enqueue, &ctrlr->taskqueue); in ufshci_ctrlr_construct()
372 taskqueue_start_threads(&ctrlr->taskqueue, 1, PI_DISK, "ufshci taskq"); in ufshci_ctrlr_construct()
421 taskqueue_enqueue(ctrlr->taskqueue, &ctrlr->reset_task); in ufshci_ctrlr_reset()
|