Function test_readv_fixed

test/vec-regbuf.c:523–610

}

static int test_readv_fixed(struct buf_desc *bd, struct iovec *vecs, int nr_vec)
{
	unsigned buf_idx = bd->buf_idx;
	struct io_uring *ring = &bd->ring;
	struct io_uring_sqe *sqe;
	struct io_uring_cqe *cqe;
	size_t total_len, i, offset;
	int ret, fd;
	char *expected;
	char filename[] = ".readv_fixed.XXXXXX";

	total_len = t_iovec_data_length(vecs, nr_vec);

	expected = malloc(total_len);
	if (!expected) {
		fprintf(stderr, "malloc failed\n");
		return 1;
	}

	/* Fill expected buffer with pattern */
	for (i = 0; i < total_len; i++)
		expected[i] = i & 0xff;

	fd = mkstemp(filename);
	if (fd < 0) {
		perror("mkstemp");
		free(expected);
		return 1;
	}
	unlink(filename);

	/* Write expected data to file */
	ret = write(fd, expected, total_len);
	if (ret != total_len) {
		fprintf(stderr, "file write failed: %d\n", ret);
		close(fd);
		free(expected);
		return 1;
	}

	/* Clear registered buffer before reading into it */
	memset(bd->buf_wr, 0, bd->size);

	/* Read using READV_FIXED - vecs already point to bd->buf_wr (registered) */
	sqe = io_uring_get_sqe(ring);
	io_uring_prep_readv_fixed(sqe, fd, vecs, nr_vec, 0, 0, buf_idx);

	ret = io_uring_submit(ring);
	if (ret != 1) {
		fprintf(stderr, "submit failed %i\n", ret);
		close(fd);
		free(expected);
		return 1;
	}

	ret = io_uring_wait_cqe(ring, &cqe);
	if (ret) {
		fprintf(stderr, "wait_cqe=%d\n", ret);