Lines Matching refs:q_flags
671 node->nd_input_queue.q_flags = 0; in ng_make_node_common()
1921 #define QUEUE_ACTIVE(QP) ((QP)->q_flags & OP_PENDING)
1929 (((QP)->q_flags & (NGQ_RMASK & ~OP_PENDING)) == 0)
1931 (((QP)->q_flags & (NGQ_WMASK & ~OP_PENDING)) == 0)
1963 node->nd_ID, node, ngq->q_flags); in ng_dequeue()
1974 long t = ngq->q_flags; in ng_dequeue()
1982 if (atomic_cmpset_acq_int(&ngq->q_flags, t, in ng_dequeue()
1989 } else if (atomic_cmpset_acq_int(&ngq->q_flags, OP_PENDING, in ng_dequeue()
1997 ngq->q_flags); in ng_dequeue()
2008 atomic_clear_int(&ngq->q_flags, OP_PENDING); in ng_dequeue()
2011 "READER", ngq->q_flags); in ng_dequeue()
2031 atomic_set_int(&ngq->q_flags, OP_PENDING); in ng_queue_rw()
2055 long t = node->nd_input_queue.q_flags; in ng_acquire_read()
2058 if (atomic_cmpset_acq_int(&node->nd_input_queue.q_flags, t, in ng_acquire_read()
2082 if (atomic_cmpset_acq_int(&node->nd_input_queue.q_flags, 0, in ng_acquire_write()
2118 atomic_add_int(&ngq->q_flags, WRITER_ACTIVE - READER_INCREMENT);
2119 if ((ngq->q_flags & (NGQ_WMASK & ~OP_PENDING)) == WRITER_ACTIVE) {
2130 atomic_add_int(&ngq->q_flags, READER_INCREMENT - WRITER_ACTIVE);
2144 atomic_set_int(&ngq->q_flags, OP_PENDING);
2154 atomic_add_int(&ngq->q_flags, READER_INCREMENT - WRITER_ACTIVE);
2167 atomic_subtract_rel_int(&node->nd_input_queue.q_flags, READER_INCREMENT); in ng_leave_read()
2174 atomic_clear_rel_int(&node->nd_input_queue.q_flags, WRITER_ACTIVE); in ng_leave_write()
2188 atomic_clear_int(&ngq->q_flags, OP_PENDING); in ng_flush_input_queue()