Function main

examples/poll-bench.c:25–101

}

int main(void)
{
	unsigned long tstop;
	unsigned long nr_reqs = 0;
	struct io_uring_cqe *cqe;
	struct io_uring_sqe *sqe;
	struct io_uring ring;
	int pipe1[2];
	int ret, i, qd = 32;

	if (pipe(pipe1) != 0) {
		perror("pipe");
		return 1;
	}

	ret = io_uring_queue_init(1024, &ring, IORING_SETUP_SINGLE_ISSUER);
	if (ret == -EINVAL) {
		fprintf(stderr, "can't single\n");
		ret = io_uring_queue_init(1024, &ring, 0);
	}
	if (ret) {
		fprintf(stderr, "child: ring setup failed: %d\n", ret);
		return 1;
	}

	ret = io_uring_register_files(&ring, pipe1, 2);
	if (ret < 0) {
		fprintf(stderr, "io_uring_register_files failed\n");
		return 1;
	}

	ret = io_uring_register_ring_fd(&ring);
	if (ret < 0) {
		fprintf(stderr, "io_uring_register_ring_fd failed\n");
		return 1;
	}

	tstop = gettimeofday_ms() + runtime_ms;
	do {
		for (i = 0; i < qd; i++) {
			sqe = io_uring_get_sqe(&ring);
			io_uring_prep_poll_add(sqe, 0, POLLIN);
			sqe->flags |= IOSQE_FIXED_FILE;
			sqe->user_data = 1;
		}

		ret = io_uring_submit(&ring);
		if (ret != qd) {
			fprintf(stderr, "child: sqe submit failed: %d\n", ret);
			return 1;
		}

		ret = write(pipe1[1], buf, 1);
		if (ret != 1) {
			fprintf(stderr, "write failed %i\n", errno);
			return 1;
		}
		ret = read(pipe1[0], buf, 1);