Home
last modified time | relevance | path

Searched refs:t_barrier (Results 1 – 2 of 2) sorted by relevance

/freebsd/sys/kern/
H A Dsubr_taskqueue.c402 struct task t_barrier; in taskqueue_drain_tq_queue() local
415 TASK_INIT(&t_barrier, UCHAR_MAX, taskqueue_task_nop_fn, &t_barrier); in taskqueue_drain_tq_queue()
416 STAILQ_INSERT_TAIL(&queue->tq_queue, &t_barrier, ta_link); in taskqueue_drain_tq_queue()
417 queue->tq_hint = &t_barrier; in taskqueue_drain_tq_queue()
418 t_barrier.ta_pending = 1; in taskqueue_drain_tq_queue()
424 while (t_barrier.ta_pending != 0) in taskqueue_drain_tq_queue()
425 TQ_SLEEP(queue, &t_barrier, "tq_qdrain"); in taskqueue_drain_tq_queue()
H A Dsubr_gtaskqueue.c261 struct gtask t_barrier; in gtaskqueue_drain_tq_queue() local
274 GTASK_INIT(&t_barrier, 0, USHRT_MAX, gtaskqueue_task_nop_fn, &t_barrier); in gtaskqueue_drain_tq_queue()
275 STAILQ_INSERT_TAIL(&queue->tq_queue, &t_barrier, ta_link); in gtaskqueue_drain_tq_queue()
276 t_barrier.ta_flags |= TASK_ENQUEUED; in gtaskqueue_drain_tq_queue()
282 while (t_barrier.ta_flags & TASK_ENQUEUED) in gtaskqueue_drain_tq_queue()
283 TQ_SLEEP(queue, &t_barrier, "gtq_qdrain"); in gtaskqueue_drain_tq_queue()