Lines Matching refs:q

136     nxt_cq_t           *q;  in cas_worker()  local
141 q = pgq; in cas_worker()
145 c = q->counter; in cas_worker()
147 if (nxt_atomic_cmp_set(&q->counter, c, c + 1)) { in cas_worker()
157 nxt_cq_t *q; in faa_worker() local
161 q = pgq; in faa_worker()
165 nxt_atomic_fetch_add(&q->counter, 1); in faa_worker()
174 nxt_cq_t *q; in enq_deq_worker() local
178 q = pgq; in enq_deq_worker()
182 v = nxt_cq_dequeue(&q->free_queue); in enq_deq_worker()
184 if (v != nxt_cq_empty(&q->free_queue)) { in enq_deq_worker()
185 nxt_cq_enqueue(&q->active_queue, wi->id); in enq_deq_worker()
189 v = nxt_cq_dequeue(&q->active_queue); in enq_deq_worker()
191 if (v != nxt_cq_empty(&q->active_queue)) { in enq_deq_worker()
192 nxt_cq_enqueue(&q->free_queue, v); in enq_deq_worker()
206 nxt_cq_t *q; in enq_worker() local
210 q = pgq; in enq_worker()
214 v = nxt_cq_dequeue(&q->free_queue); in enq_worker()
216 if (v != nxt_cq_empty(&q->free_queue)) { in enq_worker()
217 nxt_cq_enqueue(&q->active_queue, v); in enq_worker()
227 nxt_cq_t *q; in deq_worker() local
231 q = pgq; in deq_worker()
235 v = nxt_cq_dequeue(&q->active_queue); in deq_worker()
237 if (v != nxt_cq_empty(&q->active_queue)) { in deq_worker()
238 nxt_cq_enqueue(&q->free_queue, v); in deq_worker()
248 nxt_cq_t *q; in wenq_worker() local
252 q = pgq; in wenq_worker()
259 v = nxt_cq_dequeue(&q->free_queue); in wenq_worker()
260 } while (v == nxt_cq_empty(&q->free_queue)); in wenq_worker()
262 nxt_cq_enqueue(&q->active_queue, v); in wenq_worker()
273 nxt_cq_t *q; in wdeq_worker() local
277 q = pgq; in wdeq_worker()
284 v = nxt_cq_dequeue(&q->active_queue); in wdeq_worker()
285 } while (v == nxt_cq_empty(&q->active_queue)); in wdeq_worker()
287 nxt_cq_enqueue(&q->free_queue, v); in wdeq_worker()