Lines Matching refs:queue
218 io_merge(struct opioctx *ctx, struct iocb **queue, int num) in io_merge() argument
229 memcpy(q, queue, num * sizeof(struct iocb *)); in io_merge()
233 if (merge(ctx, queue[on_queue], io) != 0) in io_merge()
234 queue[++on_queue] = io; in io_merge()
238 print_merged_iocbs(ctx, queue, on_queue + 1); in io_merge()
245 expand_iocb(struct opioctx *ctx, struct iocb **queue, struct iocb *io) in expand_iocb() argument
255 queue[idx++] = op->iocb; in expand_iocb()
264 io_expand_iocbs(struct opioctx *ctx, struct iocb **queue, int idx, int num) in io_expand_iocbs() argument
274 memcpy(q, queue, num * sizeof(struct iocb *)); in io_expand_iocbs()
279 queue[on_queue++] = io; in io_expand_iocbs()
281 on_queue += expand_iocb(ctx, queue + on_queue, io); in io_expand_iocbs()
289 struct io_event *event, struct io_event *queue, int idx) in expand_event() argument
309 ep = &queue[idx++]; in expand_event()