Lines Matching refs:qi
54 nxt_app_queue_item_t *qi; in nxt_app_queue_send() local
62 qi = (nxt_app_queue_item_t *) &q->items[i]; in nxt_app_queue_send()
64 qi->size = size; in nxt_app_queue_send()
65 nxt_memcpy(qi->data, p, size); in nxt_app_queue_send()
66 qi->tracking = tracking; in nxt_app_queue_send()
92 nxt_app_queue_item_t *qi; in nxt_app_queue_cancel() local
94 qi = (nxt_app_queue_item_t *) &q->items[cookie]; in nxt_app_queue_cancel()
96 return nxt_atomic_cmp_set(&qi->tracking, tracking, 0); in nxt_app_queue_cancel()
104 nxt_app_queue_item_t *qi; in nxt_app_queue_recv() local
113 qi = (nxt_app_queue_item_t *) &q->items[i]; in nxt_app_queue_recv()
115 res = qi->size; in nxt_app_queue_recv()
116 nxt_memcpy(p, qi->data, qi->size); in nxt_app_queue_recv()