Method peek

lib_acl_cpp/src/connpool/connect_pool.cpp:197–314

}

connect_client* connect_pool::peek(bool on, double* tc, bool* old)
{
	struct timeval begin;

#define	SET_TIME_COST do {                                                    \
	if (tc) {                                                             \
		struct timeval end;                                           \
		gettimeofday(&end, NULL);                                     \
		*tc = stamp_sub(end, begin);                                  \
	}                                                                     \
} while (0)

	if (tc) {
		*tc = 0.0;
		gettimeofday(&begin, NULL);
	}

	if (old) {
		*old = false;
	}

	lock_.lock();
	if (alive_ == false) {
		time_t now = time(NULL);
		if (retry_inter_ <= 0 || now - last_dead_ < retry_inter_) {
			lock_.unlock();
			return NULL;
		}
		alive_ = true;

		// ���÷��������״̬���Ա�����
		logger("reset server: %s", get_addr());
	}

	connect_client* conn;

	std::list<connect_client*>::iterator it = pool_.begin();
	if (it != pool_.end()) {
		conn = *it;
		pool_.erase(it);
		total_used_++;
		current_used_++;

		lock_.unlock();

		SET_TIME_COST;

		if (old) {
			*old = true;
		}

		return conn;
	} else if (max_ > 0 && count_ >= max_) {
		logger_error("too many connections, max: %zd, curr: %zd,"
			" server: %s", max_, count_, addr_);
		lock_.unlock();

		SET_TIME_COST;