Function uring_write

lib_fiber/samples-c/benchmark/main.c:66–114

//////////////////////////////////////////////////////////////////////////////

static void uring_write(const char *path)
{
	int   fd = open(path, __open_flags, 0600), ret;
	long long i;
	char  buf[1] = { '0' };
	struct io_uring uring;

	if (fd < 0) {
		printf("open %s error %s\r\n", path, strerror(errno));
		exit(1);
	}

	struct io_uring_params params;
	memset(&params, 0, sizeof(params));

	ret = io_uring_queue_init_params(100, &uring, &params);
	if (ret < 0) {
		printf("init io_uring error=%s\r\n", strerror(errno));
		exit(1);
	}

	struct io_uring_sqe *sqe;
	struct io_uring_cqe *cqe;

	printf("open %s ok, fd=%d\r\n", path, fd);

	for (i = 0; i < __write_count; i++) {
		sqe = io_uring_get_sqe(&uring);
		io_uring_prep_write(sqe, fd, buf, 1, i);
		io_uring_submit(&uring);
		ret = io_uring_wait_cqes(&uring, &cqe, 1, NULL, NULL);
		if (ret < 0) {
			printf("io_uring_wait_cqe error=%s\r\n", strerror(-ret));
			exit(1);
		}

		io_uring_cqe_seen(&uring, cqe);
	}

	ret = write(fd, "\r\n", 2);
	if (ret <= 0) {
		printf("write CRLF error %s\r\n", strerror(errno));
		exit(1);
	}

	ret = close(fd);
	printf("close %s %s, fd=%d\r\n", path, ret == 0 ? "ok" : "error", fd);
	io_uring_queue_exit(&uring);
}

//////////////////////////////////////////////////////////////////////////////