Function check

lib_fiber/c/src/common/socketpair.c:46–92

#if defined(HAS_POLL)

static int check(socket_t listener, socket_t client, socket_t result[2])
{
	int ret;
	struct pollfd fds[2];

	while (result[0] == INVALID_SOCKET || result[1] ==INVALID_SOCKET) {
		int i = 0;
		if (result[1] == INVALID_SOCKET) {
			fds[i].fd      = listener;
			fds[i].events  = POLLIN;
			fds[i].revents = 0;
			i++;
		}

		if (result[0] == INVALID_SOCKET) {
			fds[i].fd      = client;
			fds[i].events  = POLLOUT;
			fds[i].revents = 0;
		}

		if (var_hook_sys_api) {
			ret = (*sys_poll)(fds, 2, 10000);
		} else {
			ret = WSAPoll(fds, 2, 10000);
		}

		if (ret < 0) {
			if (acl_fiber_last_error() == FIBER_EINTR) {
				continue;
			}
			msg_error("WSAPoll error: %s", last_serror());
			return -1;
		} else if (ret == 0) {
			msg_error("WSAPoll timeout: %s", last_serror());
			return -1;
		}

		if ((fds[0].revents & POLLIN)) {
			result[1] = accept(listener, NULL, 0);
		}
		if ((fds[1].revents & POLLOUT)) {
			result[0] = client;
		}
	}

	return 0;
}

#else