Lines Matching refs:bqueue_t
120 bqueue_t q;
132 bqueue_t q;
141 bqueue_t q;
1170 bqueue_t *q;
1274 get_next_range_nofree(bqueue_t *bq, struct send_range *prev) in get_next_range_nofree()
1286 get_next_range(bqueue_t *bq, struct send_range *prev) in get_next_range()
1386 find_next_range(struct send_range **ranges, bqueue_t **qs, uint64_t *out_mask) in find_next_range()
1493 bqueue_t *queues[NUM_THREADS]; in send_merge_thread()
1563 bqueue_t q;
1672 enqueue_range(struct send_reader_thread_arg *srta, bqueue_t *q, dnode_t *dn, in enqueue_range()
1757 bqueue_t *inq = &smta->q; in send_reader_thread()
1758 bqueue_t *outq = &srta->q; in send_reader_thread()