Function main_fiber_monitor_master

lib_fiber/cpp/src/fiber_server.cpp:376–461

#if !defined(_WIN32) && !defined(_WIN64)

static void main_fiber_monitor_master(ACL_FIBER *fiber, void *ctx)
{
	ACL_VSTREAM *stat_stream = (ACL_VSTREAM *) ctx;
	char  buf[8192];
	int   ret, n = 0;

	stat_stream->rw_timeout = -1;
	ret = acl_vstream_read(stat_stream, buf, sizeof(buf));
	acl_msg_info("%s(%d), %s: disconnect(%d) from acl_master, clients %lld",
		__FILE__, __LINE__, __FUNCTION__, ret,
		acl_atomic_clock_users(__clock));

	/* must close listening as quickly as possible, so that acl_master
	 * can rebind the addr quickly.
	 */
	acl_msg_info("%s(%d), %s: stopping listen ...",
		__FILE__, __LINE__, __FUNCTION__);
	main_stop_listen();
	acl_msg_info("%s(%d), %s: stop listen ok",
		__FILE__, __LINE__, __FUNCTION__);

	/* the user's callback will be called here */
	if (__service_preexit) {
		while (true) {
			acl_msg_info("%s(%d), %s: calling server_pre_exit ...",
				__FILE__, __LINE__, __FUNCTION__);

			if (__service_preexit(__service_ctx)) {
				break;
			}

			acl_fiber_sleep(1);
		}

		acl_msg_info("%s(%d), %s: server_pre_exit ok",
			__FILE__, __LINE__, __FUNCTION__);
	}

	while (!acl_var_fiber_quick_abort) {
		if (acl_atomic_clock_users(__clock) <= 0) {
			acl_msg_warn("%s(%d), %s: all clients closed!",
				__FILE__, __LINE__, __FUNCTION__);
			break;
		}

		acl_fiber_sleep(1);
		n++;

		if (acl_var_fiber_wait_limit > 0
			&& n >= acl_var_fiber_wait_limit) {

			acl_msg_warn("%s(%d), %s: too long, clients: %lld",
				__FILE__, __LINE__, __FUNCTION__,
				acl_atomic_clock_users(__clock));
			break;
		}

		acl_msg_info("%s(%d), %s: waiting %d, clients %lld",