Lines Matching refs:i
36 nxt_nncq_atomic_t i; in nxt_port_queue_init() local
41 for (i = 0; i < NXT_PORT_QUEUE_SIZE; i++) { in nxt_port_queue_init()
42 nxt_nncq_enqueue(&q->free_items, i); in nxt_port_queue_init()
53 nxt_nncq_atomic_t i; in nxt_port_queue_send() local
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()
71 *notify = (i == 0); in nxt_port_queue_send()
81 nxt_nncq_atomic_t i; in nxt_port_queue_recv() local
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()