Lines Matching refs:nd_input_queue

135 		STAILQ_HEAD_INITIALIZER(ng_deadnode.nd_input_queue.queue),
665 NG_QUEUE_LOCK_INIT(&node->nd_input_queue); in ng_make_node_common()
666 STAILQ_INIT(&node->nd_input_queue.queue); in ng_make_node_common()
667 node->nd_input_queue.q_flags = 0; in ng_make_node_common()
816 mtx_destroy(&node->nd_input_queue.q_mtx); in ng_unref_node()
1951 struct ng_queue *ngq = &node->nd_input_queue; in ng_dequeue()
2019 struct ng_queue *ngq = &node->nd_input_queue; 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()
2097 struct ng_queue *ngq = &node->nd_input_queue;
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()
2178 struct ng_queue *ngq = &node->nd_input_queue; in ng_flush_input_queue()
2326 ngq = &node->nd_input_queue; in ng_snd_item()
3414 STAILQ_REMOVE_HEAD(&ng_worklist, nd_input_queue.q_work); in ngthread()
3433 NG_QUEUE_LOCK(&node->nd_input_queue); in ngthread()
3436 node->nd_input_queue.q_flags2 &= ~NGQ2_WORKQ; in ngthread()
3437 NG_QUEUE_UNLOCK(&node->nd_input_queue); in ngthread()
3440 NG_QUEUE_UNLOCK(&node->nd_input_queue); in ngthread()
3476 mtx_assert(&node->nd_input_queue.q_mtx, MA_OWNED); in ng_worklist_add()
3478 if ((node->nd_input_queue.q_flags2 & NGQ2_WORKQ) == 0) { in ng_worklist_add()
3483 node->nd_input_queue.q_flags2 |= NGQ2_WORKQ; in ng_worklist_add()
3486 STAILQ_INSERT_TAIL(&ng_worklist, node, nd_input_queue.q_work); in ng_worklist_add()