Function test

test/read-mshot.c:265–424

}

static int test(int first_good, int async, int overflow, int incremental)
{
	struct io_uring_buf_ring *br;
	struct io_uring_params p = { };
	struct io_uring_sqe *sqe;
	struct io_uring_cqe *cqe;
	struct io_uring ring;
	int ret, fds[2], i, start_msg = 0;
	int br_flags = 0;
	char tmp[32];
	void *ptr[NR_BUFS];
	char *inc_index;

	p.flags = IORING_SETUP_CQSIZE;
	if (!overflow)
		p.cq_entries = NR_BUFS + 1;
	else
		p.cq_entries = NR_OVERFLOW;
	ret = io_uring_queue_init_params(1, &ring, &p);
	if (ret) {
		fprintf(stderr, "ring setup failed: %d\n", ret);
		return 1;
	}

	if (incremental) {
		if (no_buf_ring_inc)
			return 0;
		br_flags |= IOU_PBUF_RING_INC;
	}

	br = io_uring_setup_buf_ring(&ring, NR_BUFS, BUF_BGID, br_flags, &ret);
	if (!br) {
		if (ret == -EINVAL) {
			if (incremental) {
				no_buf_ring_inc = 1;
				return 0;
			}
			no_buf_ring = 1;
			return 0;
		}
		fprintf(stderr, "Buffer ring register failed %d\n", ret);
		return 1;
	}

	if (pipe(fds) < 0) {
		perror("pipe");
		return 1;
	}

	if (!incremental) {
		for (i = 0; i < NR_BUFS; i++) {
			unsigned size = i <= 1 ? BUF_SIZE_FIRST : BUF_SIZE;
			ptr[i] = malloc(size);
			if (!ptr[i])
				return 1;
			io_uring_buf_ring_add(br, ptr[i], size, i + 1, BR_MASK, i);
		}
		inc_index = NULL;