WRITER_ACTIVE
#define NGQ_RMASK (WRITER_ACTIVE|OP_PENDING)
if (t & WRITER_ACTIVE) {
OP_PENDING + WRITER_ACTIVE)) {
WRITER_ACTIVE)) {
atomic_add_int(&ngq->q_flags, WRITER_ACTIVE - READER_INCREMENT);
if ((ngq->q_flags & (NGQ_WMASK & ~OP_PENDING)) == WRITER_ACTIVE) {
atomic_add_int(&ngq->q_flags, READER_INCREMENT - WRITER_ACTIVE);
atomic_add_int(&ngq->q_flags, READER_INCREMENT - WRITER_ACTIVE);
atomic_clear_rel_int(&node->nd_input_queue.q_flags, WRITER_ACTIVE);