Function test_buf_select_pipe

test/read-write.c:529–600

}

static int test_buf_select_pipe(void)
{
	struct io_uring_sqe *sqe;
	struct io_uring_cqe *cqe;
	struct io_uring ring;
	int ret, i;
	int fds[2];

	if (no_buf_select)
		return 0;

	ret = io_uring_queue_init(64, &ring, 0);
	if (ret) {
		fprintf(stderr, "ring create failed: %d\n", ret);
		return 1;
	}

	ret = provide_buffers_iovec(&ring, 0);
	if (ret) {
		fprintf(stderr, "provide buffers failed: %d\n", ret);
		return 1;
	}

	ret = pipe(fds);
	if (ret) {
		fprintf(stderr, "pipe failed: %d\n", ret);
		return 1;
	}

	for (i = 0; i < 5; i++) {
		sqe = io_uring_get_sqe(&ring);
		io_uring_prep_read(sqe, fds[0], NULL, 1 /* max read 1 per go */, -1);
		sqe->flags |= IOSQE_BUFFER_SELECT;
		sqe->buf_group = 0;
	}
	io_uring_submit(&ring);

	ret = write(fds[1], "01234", 5);
	if (ret != 5) {
		fprintf(stderr, "pipe write failed %d\n", ret);
		return 1;
	}

	for (i = 0; i < 5; i++) {
		const char *buff;

		if (io_uring_wait_cqe(&ring, &cqe)) {
			fprintf(stderr, "bad wait %d\n", i);
			return 1;
		}
		if (cqe->res != 1) {
			fprintf(stderr, "expected read %d\n", cqe->res);
			return 1;
		}
		if (!(cqe->flags & IORING_CQE_F_BUFFER)) {
			fprintf(stderr, "no buffer %d\n", cqe->res);
			return 1;
		}