Lines Matching refs:nd_input_queue

135         STAILQ_HEAD_INITIALIZER(ng_deadnode.nd_input_queue.queue),
669 NG_QUEUE_LOCK_INIT(&node->nd_input_queue); in ng_make_node_common()
670 STAILQ_INIT(&node->nd_input_queue.queue); in ng_make_node_common()
671 node->nd_input_queue.q_flags = 0; in ng_make_node_common()
822 mtx_destroy(&node->nd_input_queue.q_mtx); in ng_unref_node()
1954 struct ng_queue *ngq = &node->nd_input_queue; in ng_dequeue()
2022 struct ng_queue *ngq = &node->nd_input_queue; 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()
2100 struct ng_queue *ngq = &node->nd_input_queue;
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()
2181 struct ng_queue *ngq = &node->nd_input_queue; in ng_flush_input_queue()
2340 ngq = &node->nd_input_queue; in ng_snd_item()
3438 STAILQ_REMOVE_HEAD(&ng_worklist, nd_input_queue.q_work); in ngthread()
3457 NG_QUEUE_LOCK(&node->nd_input_queue); in ngthread()
3460 node->nd_input_queue.q_flags2 &= ~NGQ2_WORKQ; in ngthread()
3461 NG_QUEUE_UNLOCK(&node->nd_input_queue); in ngthread()
3464 NG_QUEUE_UNLOCK(&node->nd_input_queue); in ngthread()
3485 mtx_assert(&node->nd_input_queue.q_mtx, MA_OWNED); in ng_worklist_add()
3487 if ((node->nd_input_queue.q_flags2 & NGQ2_WORKQ) == 0) { in ng_worklist_add()
3492 node->nd_input_queue.q_flags2 |= NGQ2_WORKQ; in ng_worklist_add()
3495 STAILQ_INSERT_TAIL(&ng_worklist, node, nd_input_queue.q_work); in ng_worklist_add()