Lines Matching refs:q
34 nxt_port_queue_init(nxt_port_queue_t volatile *q) in nxt_port_queue_init() argument
38 nxt_nncq_init(&q->free_items); in nxt_port_queue_init()
39 nxt_nncq_init(&q->queue); in nxt_port_queue_init()
42 nxt_nncq_enqueue(&q->free_items, i); in nxt_port_queue_init()
45 q->nitems = 0; in nxt_port_queue_init()
50 nxt_port_queue_send(nxt_port_queue_t volatile *q, const void *p, uint8_t size, in nxt_port_queue_send() argument
56 i = nxt_nncq_dequeue(&q->free_items); in nxt_port_queue_send()
57 if (i == nxt_nncq_empty(&q->free_items)) { in nxt_port_queue_send()
62 qi = (nxt_port_queue_item_t *) &q->items[i]; in nxt_port_queue_send()
67 nxt_nncq_enqueue(&q->queue, i); in nxt_port_queue_send()
69 i = nxt_atomic_fetch_add(&q->nitems, 1); in nxt_port_queue_send()
78 nxt_port_queue_recv(nxt_port_queue_t volatile *q, void *p) in nxt_port_queue_recv() argument
84 i = nxt_nncq_dequeue(&q->queue); in nxt_port_queue_recv()
85 if (i == nxt_nncq_empty(&q->queue)) { in nxt_port_queue_recv()
89 qi = (nxt_port_queue_item_t *) &q->items[i]; in nxt_port_queue_recv()
94 nxt_nncq_enqueue(&q->free_items, i); in nxt_port_queue_recv()
96 nxt_atomic_fetch_add(&q->nitems, -1); in nxt_port_queue_recv()