Home
last modified time | relevance | path

Searched refs:tq_queue (Results 1 – 8 of 8) sorted by relevance

/freebsd-14.2/sys/contrib/openzfs/module/os/freebsd/spl/
H A Dspl_taskq.c223 tq->tq_queue = taskqueue_create(name, M_WAITOK, in taskq_create_impl()
224 taskqueue_thread_enqueue, &tq->tq_queue); in taskq_create_impl()
253 taskqueue_free(tq->tq_queue); in taskq_destroy()
261 return (taskqueue_member(tq->tq_queue, thread)); in taskq_member()
291 taskqueue_drain(tq->tq_queue, &ent->tqent_task); in taskq_cancel_id()
293 rc = taskqueue_cancel_timeout(tq->tq_queue, in taskq_cancel_id()
296 taskqueue_drain_timeout(tq->tq_queue, in taskq_cancel_id()
383 taskqueue_enqueue(tq->tq_queue, &task->tqent_task); in taskq_dispatch()
419 taskqueue_quiesce(tq->tq_queue); in taskq_wait()
431 taskqueue_drain(tq->tq_queue, &ent->tqent_task); in taskq_wait_id()
[all …]
/freebsd-14.2/sys/cddl/compat/opensolaris/kern/
H A Dopensolaris_taskq.c75 tq->tq_queue = taskqueue_create(name, M_WAITOK, taskqueue_thread_enqueue, in taskq_create_impl()
76 &tq->tq_queue); in taskq_create_impl()
77 (void) taskqueue_start_threads_in_proc(&tq->tq_queue, nthreads, pri, in taskq_create_impl()
101 taskqueue_free(tq->tq_queue); in taskq_destroy()
109 return (taskqueue_member(tq->tq_queue, thread)); in taskq_member()
146 taskqueue_enqueue(tq->tq_queue, &task->tqent_task); in taskq_dispatch()
175 taskqueue_enqueue(tq->tq_queue, &task->tqent_task); in taskq_dispatch_ent()
181 taskqueue_quiesce(tq->tq_queue); in taskq_wait()
187 taskqueue_drain_all(tq->tq_queue); in taskq_wait_id()
/freebsd-14.2/sys/kern/
H A Dsubr_taskqueue.c65 STAILQ_HEAD(, task) tq_queue;
160 STAILQ_INIT(&queue->tq_queue); in _taskqueue_create()
270 prev = STAILQ_LAST(&queue->tq_queue, task, ta_link); in taskqueue_enqueue_locked()
272 STAILQ_INSERT_TAIL(&queue->tq_queue, task, ta_link); in taskqueue_enqueue_locked()
279 ins = STAILQ_FIRST(&queue->tq_queue); in taskqueue_enqueue_locked()
289 STAILQ_INSERT_HEAD(&queue->tq_queue, task, ta_link); in taskqueue_enqueue_locked()
405 if (STAILQ_EMPTY(&queue->tq_queue)) in taskqueue_drain_tq_queue()
479 if (!STAILQ_EMPTY(&queue->tq_queue)) in taskqueue_unblock()
499 while ((task = STAILQ_FIRST(&queue->tq_queue)) != NULL) { in taskqueue_run_locked()
500 STAILQ_REMOVE_HEAD(&queue->tq_queue, ta_link); in taskqueue_run_locked()
[all …]
H A Dsubr_gtaskqueue.c66 STAILQ_HEAD(, gtask) tq_queue;
143 STAILQ_INIT(&queue->tq_queue); in _gtaskqueue_create()
241 STAILQ_INSERT_TAIL(&queue->tq_queue, gtask, ta_link); in grouptaskqueue_enqueue()
264 if (STAILQ_EMPTY(&queue->tq_queue)) in gtaskqueue_drain_tq_queue()
276 STAILQ_INSERT_TAIL(&queue->tq_queue, &t_barrier, ta_link); in gtaskqueue_drain_tq_queue()
335 if (!STAILQ_EMPTY(&queue->tq_queue)) in gtaskqueue_unblock()
354 while ((gtask = STAILQ_FIRST(&queue->tq_queue)) != NULL) { in gtaskqueue_run_locked()
355 STAILQ_REMOVE_HEAD(&queue->tq_queue, ta_link); in gtaskqueue_run_locked()
397 STAILQ_REMOVE(&queue->tq_queue, gtask, gtask, ta_link); in gtaskqueue_cancel_locked()
/freebsd-14.2/sys/cddl/contrib/opensolaris/uts/common/sys/
H A Dtaskq.h41 struct taskqueue *tq_queue; member
/freebsd-14.2/sys/contrib/openzfs/include/os/freebsd/spl/sys/
H A Dtaskq.h44 struct taskqueue *tq_queue; member
/freebsd-14.2/sys/contrib/openzfs/module/os/freebsd/zfs/
H A Dzfs_dir.c556 taskqueue_enqueue(zfsvfs_taskq->tq_queue, in zfs_rmnode()
H A Dzfs_vfsops.c1705 while (taskqueue_cancel(zfsvfs_taskq->tq_queue, in zfs_umount()
1707 taskqueue_drain(zfsvfs_taskq->tq_queue, in zfs_umount()