Method run_alone

lib_acl_cpp/src/master/master_aio.cpp:81–137

}

bool master_aio::run_alone(const char* addrs, const char* path /* = NULL */,
	aio_handle_type ht /* = ENGINE_SELECT */)
{
	acl_assert(__has_called == false);
	__has_called = true;
	daemon_mode_ = false;

#ifdef ACL_WINDOWS
	acl_cpp_init();
#endif
	std::vector<aio_listen_stream*> sstreams;
	ACL_ARGV* tokens = acl_argv_split(addrs, ";,| \t");
	ACL_ITER iter;

	// ��ʼ�����ò���
	conf_.load(path);

	handle_ = NEW aio_handle(ht);

	ACL_AIO* aio = handle_->get_handle();
	acl_assert(aio);
	ACL_EVENT* eventp = acl_aio_event(aio);
	set_event(eventp);  // ���û�����¼����

	acl_foreach(iter, tokens) {
		const char* addr = (const char*) iter.data;
		aio_listen_stream* sstream = NEW aio_listen_stream(handle_);
		// ����ָ���ĵ�ַ
		if (!sstream->open(addr)) {
			logger_error("listen %s error: %s", addr, last_serror());
			close_all_listener(sstreams);
			// XXX: Ϊ�˱�֤�ܹرռ�������Ӧ�ڴ˴��� check һ��
			handle_->check();
			acl_argv_free(tokens);
			return (false);
		}

		service_on_listen(this, sstream->get_vstream());
		sstream->add_accept_callback(this);
	}
	acl_argv_free(tokens);

	service_pre_jail(this);
	service_init(this);
	while (true) {
		// ������� false ���ʾ���ټ�������Ҫ�˳�
		if (!handle_->check()) {
			logger("aio_server stop now ...");
			break;
		}
	}
	close_all_listener(sstreams);
	handle_->check();
	service_pre_exit(this);
	service_exit(this);
	return true;
}