Method peek

lib_acl_cpp/src/hsocket/hspool.cpp:42–105

}

hsclient* hspool::peek(const char* dbn, const char* tbl,
	const char* idx, const char* flds, bool readonly /* = false */)
{
	hsclient* client;
	const char* addr;

	if (readonly) {
		addr = addr_rd_;
	} else {
		addr = addr_rw_;
	}

	locker_->lock();

	// ��˳���ѯ���ϱ��ֶ����������Ӷ���
	std::list<hsclient*>::iterator it = pool_.begin();
	for (; it != pool_.end(); ++it) {
		// �����ַ��ƥ�����������ַ����ƥ��
		if (strcmp((*it)->get_addr(), addr) != 0) {
			continue;
		}

		// ���Ѿ��򿪵ı�����ѯ���ֶ��Ƿ����
		if ((*it)->open_tbl(dbn, tbl, idx, flds, false)) {
			client = *it;
			pool_.erase(it);
			locker_->unlock();
			return client;
		}
	}

	// ��ѯ��ַƥ������Ӷ����������һ��ƥ������Ӷ�����
	// ���µı�
	for (it = pool_.begin(); it != pool_.end();) {
		// �����ַ��ƥ�����������ַ����ƥ��
		if (strcmp((*it)->get_addr(), addr) != 0) {
			++it;
			continue;
		}

		client = *it;
		it = pool_.erase(it); // �����ӳ���ɾ��

		// ���µı�
		if (client->open_tbl(dbn, tbl, idx, flds, true)) {
			locker_->unlock();
			return client;
		}

		// ��ʧ�ܣ�����Ҫɾ�������Ӷ���
		delete client;
	}

	locker_->unlock();

	client = NEW hsclient(addr, cache_enable_, retry_enable_);

	if (!client->open_tbl(dbn, tbl, idx, flds)) {