Function test

test/connect-rep.c:135–178

}

static int test(int flags)
{
	struct io_uring_params params = { .flags = flags, };
	struct sockaddr_in serv_addr = {};
	struct io_uring ring;
	int ret, clientfd, s_fd, i;

	if (flags & IORING_SETUP_SQPOLL)
		params.sq_thread_idle = 50;

	ret = io_uring_queue_init_params(8, &ring, &params);
	if (ret < 0) {
		fprintf(stderr, "Queue init: %d\n", ret);
		return T_EXIT_FAIL;
	}

	s_fd = init_test_server(&serv_addr);
	if (s_fd < 0)
		return T_EXIT_FAIL;

	clientfd = init_test_client();
	if (clientfd < 0) {
		close(s_fd);
		return T_EXIT_FAIL;
	}

	/* make sure SQPOLL thread is sleeping */
	if (flags & IORING_SETUP_SQPOLL)
		usleep(100000);

	for (i = 0; i < 32; i++) {
		ret = test_connect(&ring, clientfd, &serv_addr);
		if (ret == T_EXIT_SKIP)
			return T_EXIT_SKIP;
		else if (ret == T_EXIT_PASS)
			continue;

		return T_EXIT_FAIL;
	}

	close(s_fd);
	close(clientfd);
	return T_EXIT_PASS;
}

int main(int argc, char *argv[])
{