Function test_race

test/epwait.c:236–337

}

static int test_race(int flags)
{
	struct io_uring_cqe *cqe;
	struct io_uring_sqe *sqe;
	struct io_uring ring;
	struct d d;
	struct epoll_event ev;
	struct epoll_event out[NPIPES];
	pthread_t thread;
	int i, efd, ret;
	void *tret;
	int sqe_id = 0;
	int submitted = 0, completed = 0;
	int sqe_ids[MAX_QE];
	int cqe_ids[MAX_QE];

	ret = t_create_ring(32, &ring, flags);
	if (ret == T_SETUP_SKIP) {
		return 0;
	} else if (ret != T_SETUP_OK) {
		fprintf(stderr, "ring create failed %x -> %d\n", flags, ret);
		return 1;
	}

	for (i = 0; i < NPIPES; i++) {
		if (pipe(d.pipes[i]) < 0) {
			perror("pipe");
			return 1;
		}
	}

	efd = epoll_create1(0);
	if (efd < 0) {
		perror("epoll_create");
		return T_EXIT_FAIL;
	}

	for (i = 0; i < NPIPES; i++) {
		ev.events = EPOLLIN;
		ev.data.fd = d.pipes[i][0];
		ret = epoll_ctl(efd, EPOLL_CTL_ADD, d.pipes[i][0], &ev);
		if (ret < 0) {
			perror("epoll_ctl");
			return T_EXIT_FAIL;
		}
	}

	sqe = io_uring_get_sqe(&ring);
	io_uring_prep_epoll_wait(sqe, efd, out, NPIPES, 0);
	io_uring_submit(&ring);

	atomic_store(&keep_running, true);
	pthread_create(&thread, NULL, thread_fn, &d);

	while (completed < 1000) {
		io_uring_submit_and_wait(&ring, 1);
		sqe_ids[submitted] = sqe->user_data;
		ret = io_uring_wait_cqe(&ring, &cqe);