• Home
  • Raw
  • Download

Lines Matching refs:ring

34 static int setup_context(unsigned entries, struct io_uring *ring)  in setup_context()  argument
38 ret = io_uring_queue_init(entries, ring, 0); in setup_context()
69 static void queue_prepped(struct io_uring *ring, struct io_data *data) in queue_prepped() argument
73 sqe = io_uring_get_sqe(ring); in queue_prepped()
84 static int queue_read(struct io_uring *ring, off_t size, off_t offset) in queue_read() argument
93 sqe = io_uring_get_sqe(ring); in queue_read()
111 static void queue_write(struct io_uring *ring, struct io_data *data) in queue_write() argument
119 queue_prepped(ring, data); in queue_write()
120 io_uring_submit(ring); in queue_write()
123 static int copy_file(struct io_uring *ring, off_t insize) in copy_file() argument
150 if (queue_read(ring, this_size, offset)) in copy_file()
159 ret = io_uring_submit(ring); in copy_file()
174 ret = io_uring_wait_cqe(ring, &cqe); in copy_file()
177 ret = io_uring_peek_cqe(ring, &cqe); in copy_file()
194 queue_prepped(ring, data); in copy_file()
195 io_uring_cqe_seen(ring, cqe); in copy_file()
206 queue_prepped(ring, data); in copy_file()
207 io_uring_cqe_seen(ring, cqe); in copy_file()
216 queue_write(ring, data); in copy_file()
224 io_uring_cqe_seen(ring, cqe); in copy_file()
232 ret = io_uring_wait_cqe(ring, &cqe); in copy_file()
244 io_uring_cqe_seen(ring, cqe); in copy_file()
252 struct io_uring ring; in main() local
272 if (setup_context(QD, &ring)) in main()
277 ret = copy_file(&ring, insize); in main()
281 io_uring_queue_exit(&ring); in main()