Function acl_write_wait_ms

lib_acl/src/stdlib/iostuff/acl_write_wait.c:41–124

}

int acl_write_wait_ms(ACL_SOCKET fd, int timeout)
{
	const char *myname = "acl_write_wait";
	struct pollfd fds;
	int delay = timeout;
#if 0
	time_t begin, end;
#endif

	fds.events = POLLOUT;
	fds.revents = 0;
	fds.fd = fd;

#if 0
	begin = time(NULL);
#endif

	for (;;) {
		switch (__sys_poll(&fds, 1, delay)) {
#ifdef ACL_WINDOWS
		case SOCKET_ERROR:
#else
		case -1:
#endif
			if (acl_last_error() == ACL_EINTR) {
				continue;
			}
#if 0
			acl_msg_error("%s(%d), %s: poll error(%s), fd: %d",
				__FILE__, __LINE__, myname,
				acl_last_serror(), (int) fd);
#endif
			return -1;
		case 0:
			if (timeout == 0) {
				acl_set_error(ACL_EAGAIN);
			} else {
				acl_set_error(ACL_ETIMEDOUT);
			}
#if 0
			end = time(NULL);
			acl_msg_error("%s(%d), %s: poll return 0, delay=%d, "
				"fd=%d, cost=%ld", __FILE__, __LINE__,
				myname, delay, fd, (long) ( end - begin));
#endif
			return -1;
		default:
			if (fds.revents & POLLNVAL) {
				acl_msg_error("%s(%d), %s: %s, POLLNVAL, fd=%d",
					__FILE__, __LINE__, myname,
					acl_last_serror(), (int) fd);
				acl_set_error(ACL_EINVAL);
				return -1;
			}

			if ((fds.revents & (POLLHUP | POLLERR))) {
				/*
				acl_msg_error("%s(%d), %s: %s, %s, %s, fd=%d",