Home
last modified time | relevance | path

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

/freebsd/sys/contrib/openzfs/module/os/freebsd/spl/
H A Dspl_taskq.c217 tq->tq_queue = taskqueue_create(name, M_WAITOK, in taskq_create_impl()
218 taskqueue_thread_enqueue, &tq->tq_queue); in taskq_create_impl()
219 taskqueue_set_callback(tq->tq_queue, TASKQUEUE_CALLBACK_TYPE_INIT, in taskq_create_impl()
221 taskqueue_set_callback(tq->tq_queue, TASKQUEUE_CALLBACK_TYPE_SHUTDOWN, in taskq_create_impl()
223 (void) taskqueue_start_threads_in_proc(&tq->tq_queue, nthreads, pri, in taskq_create_impl()
247 taskqueue_free(tq->tq_queue); in taskq_destroy()
336 return (taskqueue_member(tq->tq_queue, thread)); in taskq_member()
364 rc = taskqueue_cancel(tq->tq_queue, &ent->tqent_task, &pend); in taskq_cancel_id()
366 taskqueue_drain(tq->tq_queue, &ent->tqent_task); in taskq_cancel_id()
368 rc = taskqueue_cancel_timeout(tq->tq_queue, in taskq_cancel_id()
[all …]
/freebsd/sys/cddl/compat/opensolaris/kern/
H A Dopensolaris_taskq.c74 tq->tq_queue = taskqueue_create(name, M_WAITOK, taskqueue_thread_enqueue, in taskq_create_impl()
75 &tq->tq_queue); in taskq_create_impl()
76 (void) taskqueue_start_threads_in_proc(&tq->tq_queue, nthreads, pri, in taskq_create_impl()
100 taskqueue_free(tq->tq_queue); in taskq_destroy()
108 return (taskqueue_member(tq->tq_queue, thread)); in taskq_member()
145 taskqueue_enqueue(tq->tq_queue, &task->tqent_task); in taskq_dispatch()
174 taskqueue_enqueue(tq->tq_queue, &task->tqent_task); in taskq_dispatch_ent()
180 taskqueue_quiesce(tq->tq_queue); in taskq_wait()
186 taskqueue_drain_all(tq->tq_queue); in taskq_wait_id()
/freebsd/sys/kern/
H A Dsubr_taskqueue.c64 STAILQ_HEAD(, task) tq_queue;
159 STAILQ_INIT(&queue->tq_queue); in _taskqueue_create()
269 prev = STAILQ_LAST(&queue->tq_queue, task, ta_link); in taskqueue_enqueue_locked()
271 STAILQ_INSERT_TAIL(&queue->tq_queue, task, ta_link); in taskqueue_enqueue_locked()
278 ins = STAILQ_FIRST(&queue->tq_queue); in taskqueue_enqueue_locked()
285 STAILQ_INSERT_AFTER(&queue->tq_queue, prev, task, ta_link); in taskqueue_enqueue_locked()
288 STAILQ_INSERT_HEAD(&queue->tq_queue, task, ta_link); in taskqueue_enqueue_locked()
404 if (STAILQ_EMPTY(&queue->tq_queue)) in taskqueue_drain_tq_queue()
416 STAILQ_INSERT_TAIL(&queue->tq_queue, &t_barrier, ta_link); in taskqueue_drain_tq_queue()
478 if (!STAILQ_EMPTY(&queue->tq_queue)) in taskqueue_unblock()
[all …]
H A Dsubr_gtaskqueue.c65 STAILQ_HEAD(, gtask) tq_queue;
142 STAILQ_INIT(&queue->tq_queue); in _gtaskqueue_create()
240 STAILQ_INSERT_TAIL(&queue->tq_queue, gtask, ta_link); in grouptaskqueue_enqueue()
263 if (STAILQ_EMPTY(&queue->tq_queue)) in gtaskqueue_drain_tq_queue()
275 STAILQ_INSERT_TAIL(&queue->tq_queue, &t_barrier, ta_link); in gtaskqueue_drain_tq_queue()
334 if (!STAILQ_EMPTY(&queue->tq_queue)) in gtaskqueue_unblock()
353 while ((gtask = STAILQ_FIRST(&queue->tq_queue)) != NULL) { in gtaskqueue_run_locked()
354 STAILQ_REMOVE_HEAD(&queue->tq_queue, ta_link); in gtaskqueue_run_locked()
396 STAILQ_REMOVE(&queue->tq_queue, gtask, gtask, ta_link); in gtaskqueue_cancel_locked()
/freebsd/sys/cddl/contrib/opensolaris/uts/common/sys/
H A Dtaskq.h41 struct taskqueue *tq_queue; member
/freebsd/sys/contrib/openzfs/include/os/freebsd/spl/sys/
H A Dtaskq.h45 struct taskqueue *tq_queue; member
/freebsd/sys/contrib/openzfs/module/os/freebsd/zfs/
H A Dzfs_dir.c561 taskqueue_enqueue(zfsvfs_taskq->tq_queue, in zfs_rmnode()
H A Dzfs_vfsops.c1766 while (taskqueue_cancel(zfsvfs_taskq->tq_queue, in zfs_umount()
1768 taskqueue_drain(zfsvfs_taskq->tq_queue, in zfs_umount()