Lines Matching refs:i
47 nxt_nvbcq_index(nxt_nvbcq_t const volatile *q, nxt_nvbcq_atomic_t i) in nxt_nvbcq_index() argument
49 return i % NXT_NVBCQ_SIZE; in nxt_nvbcq_index()
54 nxt_nvbcq_map(nxt_nvbcq_t const volatile *q, nxt_nvbcq_atomic_t i) in nxt_nvbcq_map() argument
56 return i % NXT_NVBCQ_SIZE; in nxt_nvbcq_map()
70 nxt_nvbcq_atomic_t i; in nxt_nvbcq_init() local
74 for (i = 0; i < NXT_NVBCQ_SIZE; i++) { in nxt_nvbcq_init()
75 q->entries[i] = NXT_NVBCQ_SIZE; in nxt_nvbcq_init()
85 nxt_nvbcq_atomic_t t, h, i; in nxt_nvbcq_enqueue() local
91 i = nxt_nvbcq_map(q, t); in nxt_nvbcq_enqueue()
93 if (q->entries[i] == NXT_NVBCQ_SIZE in nxt_nvbcq_enqueue()
94 && nxt_atomic_cmp_set(&q->entries[i], NXT_NVBCQ_SIZE, val)) in nxt_nvbcq_enqueue()
116 nxt_nvbcq_atomic_t h, t, i, e; in nxt_nvbcq_dequeue() local
122 i = nxt_nvbcq_map(q, h); in nxt_nvbcq_dequeue()
123 e = q->entries[i]; in nxt_nvbcq_dequeue()
126 && nxt_atomic_cmp_set(&q->entries[i], e, NXT_NVBCQ_SIZE)) in nxt_nvbcq_dequeue()