Method wait_iocp

lib_acl_cpp/src/stream/socket_stream.cpp:476–533

}

bool socket_stream::wait_iocp(int ms) const {
#ifdef MSG_ZEROCOPY
	ACL_SOCKET fd = sock_handle();
	if (fd == ACL_SOCKET_INVALID) {
		logger_error("invalid socket handle");
		return false;
	}

	struct pollfd pfd;
	pfd.fd = fd;
	pfd.events = POLLERR | POLLIN;

	int ret = poll(&pfd, 1, ms);
	if (ret < 0) {
		return false;
	}
	if (ret == 0) {
		acl_set_error(ACL_ETIMEDOUT);
		return false;
	}

	char cmsgbuf[1024];
	char payload[1];
	struct msghdr msg;
	struct iovec iov;
	memset(&msg, 0, sizeof(msg));
	iov.iov_base = payload;
	iov.iov_len = sizeof(payload);
	msg.msg_iov = &iov;
	msg.msg_iovlen = 1;
	msg.msg_control = cmsgbuf;
	msg.msg_controllen = sizeof(cmsgbuf);

	ssize_t n = ::recvmsg(fd, &msg, MSG_ERRQUEUE);
	if (n < 0) {
		return false;
	}

	struct cmsghdr *cmsg = CMSG_FIRSTHDR(&msg);
	if (cmsg == NULL) {
		return false;
	}

	if (cmsg->cmsg_level != SOL_IP || cmsg->cmsg_type != IP_RECVERR) {
		return false;
	}

	struct sock_extended_err *serr = (struct sock_extended_err *)CMSG_DATA(cmsg);
	if (serr && serr->ee_origin == SO_EE_ORIGIN_ZEROCOPY) {
		return true;
	} else {
		return false;
	}
#else
	(void) ms;
	return false;
#endif
}