Lines Matching refs:q_flags

667 	node->nd_input_queue.q_flags = 0;  in ng_make_node_common()
1918 #define QUEUE_ACTIVE(QP) ((QP)->q_flags & OP_PENDING)
1926 (((QP)->q_flags & (NGQ_RMASK & ~OP_PENDING)) == 0)
1928 (((QP)->q_flags & (NGQ_WMASK & ~OP_PENDING)) == 0)
1960 node->nd_ID, node, ngq->q_flags); in ng_dequeue()
1971 long t = ngq->q_flags; in ng_dequeue()
1979 if (atomic_cmpset_acq_int(&ngq->q_flags, t, in ng_dequeue()
1986 } else if (atomic_cmpset_acq_int(&ngq->q_flags, OP_PENDING, in ng_dequeue()
1994 ngq->q_flags); in ng_dequeue()
2005 atomic_clear_int(&ngq->q_flags, OP_PENDING); in ng_dequeue()
2008 "READER", ngq->q_flags); in ng_dequeue()
2028 atomic_set_int(&ngq->q_flags, OP_PENDING); in ng_queue_rw()
2052 long t = node->nd_input_queue.q_flags; in ng_acquire_read()
2055 if (atomic_cmpset_acq_int(&node->nd_input_queue.q_flags, t, in ng_acquire_read()
2079 if (atomic_cmpset_acq_int(&node->nd_input_queue.q_flags, 0, in ng_acquire_write()
2115 atomic_add_int(&ngq->q_flags, WRITER_ACTIVE - READER_INCREMENT);
2116 if ((ngq->q_flags & (NGQ_WMASK & ~OP_PENDING)) == WRITER_ACTIVE) {
2127 atomic_add_int(&ngq->q_flags, READER_INCREMENT - WRITER_ACTIVE);
2141 atomic_set_int(&ngq->q_flags, OP_PENDING);
2151 atomic_add_int(&ngq->q_flags, READER_INCREMENT - WRITER_ACTIVE);
2164 atomic_subtract_rel_int(&node->nd_input_queue.q_flags, READER_INCREMENT); in ng_leave_read()
2171 atomic_clear_rel_int(&node->nd_input_queue.q_flags, WRITER_ACTIVE); in ng_leave_write()
2185 atomic_clear_int(&ngq->q_flags, OP_PENDING); in ng_flush_input_queue()