Home
last modified time | relevance | path

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

/freebsd/sys/kern/
H A Dsubr_taskqueue.c76 int tq_flags; member
165 queue->tq_flags |= TQ_FLAGS_ACTIVE; in _taskqueue_create()
170 queue->tq_flags |= TQ_FLAGS_UNLOCKED_ENQUEUE; in _taskqueue_create()
220 queue->tq_flags &= ~TQ_FLAGS_ACTIVE; in taskqueue_free()
292 if ((queue->tq_flags & TQ_FLAGS_UNLOCKED_ENQUEUE) != 0) in taskqueue_enqueue_locked()
294 if ((queue->tq_flags & TQ_FLAGS_BLOCKED) == 0) in taskqueue_enqueue_locked()
296 if ((queue->tq_flags & TQ_FLAGS_UNLOCKED_ENQUEUE) == 0) in taskqueue_enqueue_locked()
458 if ((queue->tq_flags & TQ_FLAGS_ACTIVE) == 0) in taskqueue_drain_tq_active()
468 queue->tq_flags |= TQ_FLAGS_BLOCKED; in taskqueue_block()
477 queue->tq_flags &= ~TQ_FLAGS_BLOCKED; in taskqueue_unblock()
[all …]
H A Dsubr_gtaskqueue.c76 int tq_flags; member
148 queue->tq_flags |= TQ_FLAGS_ACTIVE; in _gtaskqueue_create()
150 queue->tq_flags |= TQ_FLAGS_UNLOCKED_ENQUEUE; in _gtaskqueue_create()
174 queue->tq_flags &= ~TQ_FLAGS_ACTIVE; in gtaskqueue_free()
243 if ((queue->tq_flags & TQ_FLAGS_BLOCKED) == 0) in grouptaskqueue_enqueue()
315 if ((queue->tq_flags & TQ_FLAGS_ACTIVE) == 0) in gtaskqueue_drain_tq_active()
324 queue->tq_flags |= TQ_FLAGS_BLOCKED; in gtaskqueue_block()
333 queue->tq_flags &= ~TQ_FLAGS_BLOCKED; in gtaskqueue_unblock()
542 while ((tq->tq_flags & TQ_FLAGS_ACTIVE) != 0) { in gtaskqueue_thread_loop()
550 if ((tq->tq_flags & TQ_FLAGS_ACTIVE) == 0) in gtaskqueue_thread_loop()
/freebsd/sys/contrib/openzfs/module/os/linux/spl/
H A Dspl-taskq.c675 if (!(tq->tq_flags & TASKQ_ACTIVE)) in taskq_dispatch()
748 if (!(tq->tq_flags & TASKQ_ACTIVE)) in taskq_dispatch_delay()
798 if (!(tq->tq_flags & TASKQ_ACTIVE)) { in taskq_dispatch_ent()
929 if (!(tq->tq_flags & TASKQ_DYNAMIC)) in taskq_thread_spawn()
934 (tq->tq_flags & TASKQ_ACTIVE)) { in taskq_thread_spawn()
956 if (!(tq->tq_flags & TASKQ_DYNAMIC) || !spl_taskq_thread_dynamic) in taskq_thread_should_stop()
958 if (!(tq->tq_flags & TASKQ_ACTIVE)) in taskq_thread_should_stop()
1004 if (tq->tq_flags & TASKQ_DYNAMIC) in taskq_thread()
1371 tq->tq_flags = (flags | TASKQ_ACTIVE); in taskq_create()
1442 tq->tq_flags &= ~TASKQ_ACTIVE; in taskq_destroy()
[all …]
/freebsd/sys/contrib/openzfs/lib/libzpool/
H A Dtaskq.c114 ASSERT(tq->tq_flags & TASKQ_ACTIVE); in taskq_dispatch()
224 while (tq->tq_flags & TASKQ_ACTIVE) { in taskq_thread()
280 tq->tq_flags = flags | TASKQ_ACTIVE; in taskq_create()
313 tq->tq_flags &= ~TASKQ_ACTIVE; in taskq_destroy()
/freebsd/sys/contrib/openzfs/include/os/linux/spl/sys/
H A Dtaskq.h125 uint_t tq_flags; /* flags */ member
/freebsd/sys/contrib/openzfs/include/sys/
H A Dzfs_context.h468 int tq_flags;