Home
last modified time | relevance | path

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

/f-stack/freebsd/contrib/openzfs/module/os/freebsd/spl/
H A Dspl_taskq.c221 tq->tq_queue = taskqueue_create(name, M_WAITOK, in taskq_create_impl()
222 taskqueue_thread_enqueue, &tq->tq_queue); in taskq_create_impl()
251 taskqueue_free(tq->tq_queue); in taskq_destroy()
259 return (taskqueue_member(tq->tq_queue, thread)); in taskq_member()
291 rc = taskqueue_cancel_timeout(tq->tq_queue, in taskq_cancel_id()
296 taskqueue_drain(tq->tq_queue, &ent->tqent_task); in taskq_cancel_id()
381 taskqueue_enqueue(tq->tq_queue, &task->tqent_task); in taskq_dispatch()
411 taskqueue_enqueue(tq->tq_queue, &task->tqent_task); in taskq_dispatch_ent()
417 taskqueue_quiesce(tq->tq_queue); in taskq_wait()
430 taskqueue_drain(tq->tq_queue, &ent->tqent_task); in taskq_wait_id()
[all …]
/f-stack/freebsd/kern/
H A Dsubr_taskqueue.c66 STAILQ_HEAD(, task) tq_queue;
152 STAILQ_INIT(&queue->tq_queue); in _taskqueue_create()
246 prev = STAILQ_LAST(&queue->tq_queue, task, ta_link); in taskqueue_enqueue_locked()
248 STAILQ_INSERT_TAIL(&queue->tq_queue, task, ta_link); in taskqueue_enqueue_locked()
255 ins = STAILQ_FIRST(&queue->tq_queue); in taskqueue_enqueue_locked()
265 STAILQ_INSERT_HEAD(&queue->tq_queue, task, ta_link); in taskqueue_enqueue_locked()
368 if (STAILQ_EMPTY(&queue->tq_queue)) in taskqueue_drain_tq_queue()
442 if (!STAILQ_EMPTY(&queue->tq_queue)) in taskqueue_unblock()
462 while ((task = STAILQ_FIRST(&queue->tq_queue)) != NULL) { in taskqueue_run_locked()
463 STAILQ_REMOVE_HEAD(&queue->tq_queue, ta_link); in taskqueue_run_locked()
[all …]
H A Dsubr_gtaskqueue.c68 STAILQ_HEAD(, gtask) tq_queue;
145 STAILQ_INIT(&queue->tq_queue); in _gtaskqueue_create()
243 STAILQ_INSERT_TAIL(&queue->tq_queue, gtask, ta_link); in grouptaskqueue_enqueue()
266 if (STAILQ_EMPTY(&queue->tq_queue)) in gtaskqueue_drain_tq_queue()
278 STAILQ_INSERT_TAIL(&queue->tq_queue, &t_barrier, ta_link); in gtaskqueue_drain_tq_queue()
337 if (!STAILQ_EMPTY(&queue->tq_queue)) in gtaskqueue_unblock()
356 while ((gtask = STAILQ_FIRST(&queue->tq_queue)) != NULL) { in gtaskqueue_run_locked()
357 STAILQ_REMOVE_HEAD(&queue->tq_queue, ta_link); in gtaskqueue_run_locked()
399 STAILQ_REMOVE(&queue->tq_queue, gtask, gtask, ta_link); in gtaskqueue_cancel_locked()
/f-stack/freebsd/contrib/openzfs/include/os/freebsd/spl/sys/
H A Dtaskq.h44 struct taskqueue *tq_queue; member
/f-stack/freebsd/contrib/openzfs/module/os/freebsd/zfs/
H A Dzfs_dir.c552 taskqueue_enqueue(zfsvfs_taskq->tq_queue, in zfs_rmnode()
H A Dzfs_vfsops.c1680 while (taskqueue_cancel(zfsvfs_taskq->tq_queue, in zfs_umount()
1682 taskqueue_drain(zfsvfs_taskq->tq_queue, in zfs_umount()