Home
last modified time | relevance | path

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

/freebsd-12.1/sys/cddl/compat/opensolaris/kern/
H A Dopensolaris_taskq.c75 tq->tq_queue = taskqueue_create(name, M_WAITOK, taskqueue_thread_enqueue, in taskq_create()
76 &tq->tq_queue); in taskq_create()
77 (void) taskqueue_start_threads(&tq->tq_queue, nthreads, pri, "%s", name); in taskq_create()
94 taskqueue_free(tq->tq_queue); in taskq_destroy()
102 return (taskqueue_member(tq->tq_queue, thread)); in taskq_member()
139 taskqueue_enqueue(tq->tq_queue, &task->tqent_task); in taskq_dispatch()
168 taskqueue_enqueue(tq->tq_queue, &task->tqent_task); in taskq_dispatch_ent()
174 taskqueue_quiesce(tq->tq_queue); in taskq_wait()
180 taskqueue_drain_all(tq->tq_queue); in taskq_wait_id()
/freebsd-12.1/sys/kern/
H A Dsubr_taskqueue.c66 STAILQ_HEAD(, task) tq_queue;
147 STAILQ_INIT(&queue->tq_queue); in _taskqueue_create()
238 prev = STAILQ_LAST(&queue->tq_queue, task, ta_link); in taskqueue_enqueue_locked()
240 STAILQ_INSERT_TAIL(&queue->tq_queue, task, ta_link); in taskqueue_enqueue_locked()
243 for (ins = STAILQ_FIRST(&queue->tq_queue); ins; in taskqueue_enqueue_locked()
251 STAILQ_INSERT_HEAD(&queue->tq_queue, task, ta_link); in taskqueue_enqueue_locked()
354 if (STAILQ_EMPTY(&queue->tq_queue)) in taskqueue_drain_tq_queue()
434 if (!STAILQ_EMPTY(&queue->tq_queue)) in taskqueue_unblock()
451 while (STAILQ_FIRST(&queue->tq_queue)) { in taskqueue_run_locked()
458 task = STAILQ_FIRST(&queue->tq_queue); in taskqueue_run_locked()
[all …]
H A Dsubr_gtaskqueue.c70 STAILQ_HEAD(, gtask) tq_queue;
147 STAILQ_INIT(&queue->tq_queue); in _gtaskqueue_create()
246 STAILQ_INSERT_TAIL(&queue->tq_queue, gtask, ta_link); in grouptaskqueue_enqueue()
269 if (STAILQ_EMPTY(&queue->tq_queue)) in gtaskqueue_drain_tq_queue()
281 STAILQ_INSERT_TAIL(&queue->tq_queue, &t_barrier, ta_link); in gtaskqueue_drain_tq_queue()
347 if (!STAILQ_EMPTY(&queue->tq_queue)) in gtaskqueue_unblock()
363 while (STAILQ_FIRST(&queue->tq_queue)) { in gtaskqueue_run_locked()
370 gtask = STAILQ_FIRST(&queue->tq_queue); in gtaskqueue_run_locked()
372 STAILQ_REMOVE_HEAD(&queue->tq_queue, ta_link); in gtaskqueue_run_locked()
410 STAILQ_REMOVE(&queue->tq_queue, gtask, gtask, ta_link); in gtaskqueue_cancel_locked()
/freebsd-12.1/sys/cddl/contrib/opensolaris/uts/common/sys/
H A Dtaskq.h41 struct taskqueue *tq_queue; member
/freebsd-12.1/contrib/openmp/runtime/src/
H A Dkmp_taskq.cpp231 __kmp_printf(" tq_queue : %p\n", queue->tq_queue); in __kmp_dump_task_queue()
264 __kmp_dump_thunk(tq, queue->tq_queue[qs].qs_thunk, global_tid); in __kmp_dump_task_queue()
334 __kmp_printf("%p ", curr_queue->tq_queue[qs].qs_thunk); in __kmp_aux_dump_task_queue_tree()
500 new_queue->tq_queue = in __kmp_alloc_taskq()
540 __kmpc_taskq_free(p->tq_queue, global_tid); in __kmp_free_taskq()
556 p->tq_queue = NULL; in __kmp_free_taskq()
672 queue->tq_queue[(queue->tq_head)++].qs_thunk = thunk; in __kmp_enqueue_task()
722 pt = queue->tq_queue[(queue->tq_tail)++].qs_thunk; in __kmp_dequeue_task()
H A Dkmp.h1345 kmpc_aligned_queue_slot_t *tq_queue; member
/freebsd-12.1/sys/cddl/contrib/opensolaris/uts/common/fs/zfs/
H A Dzfs_dir.c541 taskqueue_enqueue(zfsvfs_taskq->tq_queue, in zfs_rmnode()
H A Dzfs_vfsops.c2259 while (taskqueue_cancel(zfsvfs_taskq->tq_queue, in zfs_umount()
2261 taskqueue_drain(zfsvfs_taskq->tq_queue, in zfs_umount()