Method get_array

lib_acl_cpp/src/redis/redis_client.cpp:311–338

}

redis_result* redis_client::get_array(socket_stream& conn, dbuf_pool* dbuf)
{
	string& buf = conn.get_buf();
	buf.clear();
	if (!conn.gets(buf)) {
		logger_error("gets error, server: %s", conn.get_peer(true));
		return NULL;
	}

	redis_result* rr = new(dbuf) redis_result(dbuf);
	rr->set_type(REDIS_RESULT_ARRAY);
	int count = atoi(buf.c_str());
	if (count <= 0) {
		return rr;
	}

	rr->set_size((size_t) count);

	for (int i = 0; i < count; i++) {
		redis_result* child = get_object(conn, dbuf);
		if (child == NULL) {
			return NULL;
		}
		rr->put(child, i);
	}

	return rr;
}

redis_result* redis_client::get_object(socket_stream& conn, dbuf_pool* dbuf)
{