Method get

lib_acl_cpp/src/connpool/connect_manager.cpp:350–397

}

connect_pool* connect_manager::get(const char* addr,
	bool exclusive /* = true */, bool restore /* = false */)
{
	string key;
	get_key(addr, key);
	unsigned long id = get_id();

	if (exclusive) {
		lock_.lock();
	}

	conns_pools& pools = get_pools_by_id(id);

	pools_t::iterator it = pools.pools.begin();
	for (; it != pools.pools.end(); ++it) {
		if (key == (*it)->get_key()) {
			if (restore && !(*it)->aliving()) {
				(*it)->set_alive(true);
			}
			if (exclusive) {
				lock_.unlock();
			}
			return *it;
		}
	}

	string buf(addr);
	buf.lower();

	std::map<string, conn_config>::const_iterator cit = addrs_.find(buf);
	if (cit == addrs_.end()) {
		if (exclusive) {
			lock_.unlock();
		}
		logger_debug(ACL_CPP_DEBUG_CONN_MANAGER, 1,
			"no connect pool for addr %s", addr);
		return NULL;
	}

	connect_pool* pool = create_pool(cit->second, pools.pools.size());
	pools.pools.push_back(pool);

	if (exclusive) {
		lock_.unlock();
	}

	return pool;
}

//////////////////////////////////////////////////////////////////////////