Method run

lib_acl_cpp/src/redis/redis_client_cluster.cpp:477–606

}

const redis_result* redis_client_cluster::run(redis_command& cmd,
	size_t nchild, int* timeout /* = NULL */)
{
	redis_client* conn = peek_conn(cmd.get_slot());

	// ���û���ҵ����õ����Ӷ�����ֱ�ӷ��� NULL ��ʾ����
	if (conn == NULL) {
		logger_error("peek_conn NULL, slot_: %d", cmd.get_slot());
		return NULL;
	}

	cmd.set_client_addr(*conn);
	conn->set_check_addr(cmd.is_check_addr());

	redis_result_t type;
	bool  last_moved = false;
	int   n = 0;

	dbuf_pool* dbuf    = cmd.get_dbuf();
	redis_request* obj = cmd.get_request_obj();
	string* buf        = cmd.get_request_buf();

	const redis_result* result;

	while (n++ < redirect_max_) {
		// ������������Ƿ�����ڴ��Ƭ��ʽ���ò�ͬ���������
		if (cmd.is_slice_req()) {
			result = conn->run(dbuf, *obj, nchild, timeout);
		} else {
			result = conn->run(dbuf, *buf, nchild, timeout);
		}

		// ��������쳣�Ͽ�������Ҫ��������
		if (conn->eof()) {
			conn = reopen(cmd, conn);
			if (conn == NULL) {
				return result;
			}
			last_moved = true;
			continue;
		}

		if (result == NULL) {
			// �������Ӷ���黹�����ӳض���
			conn->get_pool()->put(conn, true);
			logger_error("result NULL");
			return NULL;
		}

		// ȡ�÷���������Ӧ��������ͣ������зֱ���
		type = result->get_type();

		if (type == REDIS_RESULT_UNKOWN) {
			// �������Ӷ���黹�����ӳض���
			conn->get_pool()->put(conn, true);
			logger_error("unknown result type: %d", type);
			return NULL;
		}