Function main_dispatch_poll

lib_fiber/cpp/src/fiber_server.cpp:518–551

}

static void main_dispatch_poll(ACL_VSTREAM *conn)
{
	struct pollfd pfd;
	time_t last = time(NULL);

	memset(&pfd, 0, sizeof(pfd));
	pfd.fd = ACL_VSTREAM_SOCK(conn);
	pfd.events = POLLIN;

	while (!__server_stopping) {
		int n = poll(&pfd, 1, 1000);
		if (n < 0) {
			acl_msg_error("%s(%d), %s: poll error %s", __FILE__,
				__LINE__, __FUNCTION__, acl_last_serror());
			break;
		}

		if (n > 0 && pfd.revents & POLLIN) {
			if (main_dispatch_receive(ACL_VSTREAM_SOCK(conn)) < 0) {
				break;
			}

			pfd.revents = 0;
		}

		if (time(NULL) - last >= 1) {
			if (main_dispatch_report(conn) < 0) {
				break;
			}

			last = time(NULL);
		}
	}
}

static void main_fiber_dispatch(ACL_FIBER *fiber, void *ctx acl_unused)
{