Method timer_callback

lib_acl_cpp/src/connpool/check_timer.cpp:25–110

}

void check_timer::timer_callback(unsigned int id)
{
	id_ = (int) id;

	if (stopping_) {
		logger("check_timer stopping ...");
		return;
	}

	connect_manager& manager = monitor_.get_manager();

	// �Զ���Ⲣ�رչ��ڿ��г����ӣ��Զ��ر��쳣���ӣ��Զ�����ÿ�����ӳص���С������
	manager.check_conns(monitor_.get_check_step(),
		monitor_.check_idle_on(), monitor_.kick_dead_on(),
		monitor_.keep_conns_on(), monitor_.get_threads(), NULL);

	if (!monitor_.check_server_on()) {
		return;
	}

	// ��ʼ�ռ���������˷�������ԣ����������÷����ַ�����������

	// ����ȡ���з�������ַ����ΪҪ�����Ķ����ڶ��̻߳����У�
	// ������Ҫ���л���������
	manager.lock();

	const std::vector<connect_pool*>& pools = manager.get_pools();

	for (std::vector<connect_pool*>::const_iterator cit = pools.begin();
		cit != pools.end(); ++cit) {

		const char* addr = (*cit)->get_addr();
		if (addr == NULL || *addr == 0) {
			logger_warn("addr null");
			continue;
		}

		std::map<string, int>::iterator it = addrs_.find(addr);
		if (it == addrs_.end()) {
			addrs_[addr] = 1;
		} else {
			it->second++;
		}
	}

	manager.unlock();

	//if (addrs_.empty())
	//	logger_warn(">>>no addr been set!<<<");

	// �������з�������ַ

	struct timeval begin;
	std::map<string, int>::iterator cit_next;

	for (std::map<string, int>::iterator cit = addrs_.begin();
		cit != addrs_.end(); cit = cit_next) {