| /freebsd-10-stable/sys/sys/ |
| D | taskqueue.h | 40 struct taskqueue;
44 struct taskqueue *q;
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_enqueue(struct taskqueue *queue, struct task *task);
75 int taskqueue_enqueue_timeout(struct taskqueue *queue,
77 int taskqueue_poll_is_busy(struct taskqueue *queue, struct task *task);
78 int taskqueue_cancel(struct taskqueue *queue, struct task *task,
80 int taskqueue_cancel_timeout(struct taskqueue *queue,
82 void taskqueue_drain(struct taskqueue *queue, struct task *task);
[all …]
|
| /freebsd-10-stable/sys/ofed/include/linux/ |
| D | workqueue.h | 42 struct taskqueue *taskqueue; member
48 struct taskqueue *taskqueue; member
75 (work)->taskqueue = NULL; \
89 (work)->taskqueue = taskqueue_thread; \
98 work->taskqueue = wq->taskqueue; in queue_work()
103 return (!taskqueue_enqueue(wq->taskqueue, &work->work_task)); in queue_work()
112 work->work.taskqueue = wq->taskqueue; in queue_delayed_work()
120 pending = taskqueue_enqueue(work->work.taskqueue, in queue_delayed_work()
132 wq.taskqueue = taskqueue_thread; in schedule_delayed_work()
149 #define flush_workqueue(wq) flush_taskqueue((wq)->taskqueue)
[all …]
|
| D | linux_compat.c | 938 taskqueue_enqueue(work->work.taskqueue, &work->work.work_task); in linux_delayed_work_fn()
961 wq->taskqueue = taskqueue_create(name, M_WAITOK, in linux_create_workqueue_common()
962 taskqueue_thread_enqueue, &wq->taskqueue); in linux_create_workqueue_common()
964 taskqueue_start_threads(&wq->taskqueue, cpus, PWAIT, "%s", name); in linux_create_workqueue_common()
972 taskqueue_free(wq->taskqueue); in destroy_workqueue()
|
| /freebsd-10-stable/sys/kern/ |
| D | subr_taskqueue.c | 58 struct taskqueue { struct
99 _timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task, in _timeout_task_init()
111 TQ_SLEEP(struct taskqueue *tq, void *p, struct mtx *m, int pri, const char *wm, in TQ_SLEEP()
119 static struct taskqueue *
124 struct taskqueue *queue; in _taskqueue_create()
126 queue = malloc(sizeof(struct taskqueue), M_TASKQUEUE, mflags | M_ZERO); in _taskqueue_create()
146 struct taskqueue *
155 taskqueue_set_callback(struct taskqueue *queue, in taskqueue_set_callback()
175 taskqueue_terminate(struct thread **pp, struct taskqueue *tq) in taskqueue_terminate()
185 taskqueue_free(struct taskqueue *queue) in taskqueue_free()
[all …]
|
| /freebsd-10-stable/sys/dev/hyperv/vmbus/ |
| D | vmbus_var.h | 78 struct taskqueue *event_tq; /* event taskq */
79 struct taskqueue *message_tq; /* message taskq */
120 struct taskqueue *vmbus_devtq; /* for dev attach/detach */
121 struct taskqueue *vmbus_subchtq; /* for sub-chan attach/detach */
|
| D | vmbus_chanvar.h | 60 struct taskqueue *ch_tq;
135 struct taskqueue *ch_mgmt_tq;
|
| D | vmbus_if.m | 36 struct taskqueue;
56 METHOD struct taskqueue * get_event_taskq { struct
|
| /freebsd-10-stable/share/man/man9/ |
| D | Makefile | 267 taskqueue.9 \
1364 MLINKS+=taskqueue.9 TASK_INIT.9 \
1365 taskqueue.9 TASK_INITIALIZER.9 \
1366 taskqueue.9 taskqueue_block.9 \
1367 taskqueue.9 taskqueue_cancel.9 \
1368 taskqueue.9 taskqueue_cancel_timeout.9 \
1369 taskqueue.9 taskqueue_create.9 \
1370 taskqueue.9 taskqueue_create_fast.9 \
1371 taskqueue.9 TASKQUEUE_DECLARE.9 \
1372 taskqueue.9 TASKQUEUE_DEFINE.9 \
[all …]
|
| /freebsd-10-stable/sys/dev/hyperv/netvsc/ |
| D | if_hnvar.h | 116 struct taskqueue *hn_tx_taskq;
205 struct taskqueue **hn_tx_taskqs;
216 struct taskqueue *hn_mgmt_taskq;
217 struct taskqueue *hn_mgmt_taskq0;
257 struct taskqueue *hn_vf_taskq;
|
| /freebsd-10-stable/sys/dev/qlxgbe/ |
| 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;
|
| /freebsd-10-stable/sys/dev/wtap/wtap_hal/ |
| D | handler.h | 42 struct taskqueue;
45 struct taskqueue *tq;
|
| /freebsd-10-stable/sys/cddl/contrib/opensolaris/uts/common/sys/ |
| D | taskq.h | 39 struct taskqueue;
41 struct taskqueue *tq_queue;
|
| /freebsd-10-stable/sys/dev/wtap/ |
| D | if_wtapvar.h | 130 struct taskqueue;
145 struct taskqueue *sc_tq; /* private task queue */
|
| /freebsd-10-stable/sys/dev/qlxgb/ |
| D | qla_def.h | 100 struct taskqueue *rcv_tq;
163 struct taskqueue *tx_tq;
|
| /freebsd-10-stable/sys/dev/e1000/ |
| D | if_em.h | 333 struct taskqueue *tq;
367 struct taskqueue *tq;
424 struct taskqueue *tq; /* private task queue */
|
| /freebsd-10-stable/sys/ufs/ufs/ |
| D | ufsmount.h | 55 struct taskqueue;
92 struct taskqueue *um_trim_tq;
|
| /freebsd-10-stable/sys/dev/rt/ |
| D | if_rt.c | 407 sc->taskqueue = taskqueue_create("rt_taskq", M_NOWAIT, in rt_attach()
408 taskqueue_thread_enqueue, &sc->taskqueue); in rt_attach()
410 taskqueue_start_threads(&sc->taskqueue, 1, PI_NET, "%s taskq", in rt_attach()
543 taskqueue_drain(sc->taskqueue, &sc->rx_done_task); in rt_detach()
544 taskqueue_drain(sc->taskqueue, &sc->tx_done_task); in rt_detach()
545 taskqueue_drain(sc->taskqueue, &sc->periodic_task); in rt_detach()
563 taskqueue_free(sc->taskqueue); in rt_detach()
793 taskqueue_block(sc->taskqueue); in rt_stop_locked()
800 taskqueue_drain(sc->taskqueue, &sc->rx_done_task); in rt_stop_locked()
801 taskqueue_drain(sc->taskqueue, &sc->tx_done_task); in rt_stop_locked()
[all …]
|
| D | if_rtvar.h | 217 struct taskqueue *taskqueue; member
|
| /freebsd-10-stable/sys/dev/hyperv/include/ |
| D | vmbus.h | 127 struct taskqueue;
224 struct taskqueue *
|
| /freebsd-10-stable/sys/dev/qlnx/qlnxe/ |
| D | qlnx_def.h | 199 struct taskqueue *fp_taskqueue;
347 struct taskqueue *pf_taskqueue;
448 struct taskqueue *sp_taskqueue[MAX_HWFNS_PER_DEVICE];
487 struct taskqueue *err_taskqueue;
|
| /freebsd-10-stable/sys/dev/virtio/network/ |
| D | if_vtnetvar.h | 78 struct taskqueue *vtnrx_tq;
110 struct taskqueue *vtntx_tq;
|
| /freebsd-10-stable/sys/dev/qlxge/ |
| D | qls_def.h | 306 struct taskqueue *tx_tq;
346 struct taskqueue *err_tq;
|
| /freebsd-10-stable/sys/dev/nvme/ |
| D | nvme_ctrlr.c | 203 taskqueue_enqueue(ctrlr->taskqueue, &ctrlr->fail_req_task); in nvme_ctrlr_post_failed_request()
353 taskqueue_enqueue(ctrlr->taskqueue, &ctrlr->reset_task); in nvme_ctrlr_reset()
1110 ctrlr->taskqueue = taskqueue_create("nvme_taskq", M_WAITOK,
1111 taskqueue_thread_enqueue, &ctrlr->taskqueue);
1112 taskqueue_start_threads(&ctrlr->taskqueue, 1, PI_DISK, "nvme taskq");
1141 taskqueue_free(ctrlr->taskqueue);
|
| /freebsd-10-stable/sys/x86/iommu/ |
| D | intel_dmar.h | 172 struct taskqueue *fault_taskqueue;
191 struct taskqueue *qi_taskqueue;
196 struct taskqueue *delayed_taskqueue;
|
| /freebsd-10-stable/sys/dev/smc/ |
| D | if_smcvar.h | 48 struct taskqueue *smc_tq;
|