Method get_result

lib_acl_cpp/src/redis/redis_client_pipeline.cpp:193–218

}

const redis_result* redis_pipeline_channel::get_result(socket_stream& conn,
	redis_pipeline_message& msg) const
{
	dbuf_pool* dbuf = msg.get_dbuf();
	assert(dbuf);

	const int* timeout = msg.get_timeout();
	if (timeout) {
		conn.set_rw_timeout(*timeout);
	}

	const redis_result* result;
	size_t nchild = msg.get_nchild();
	if (nchild >= 1) {
		result = client_->get_objects(conn, dbuf, nchild);
	} else {
		result = client_->get_object(conn, dbuf);
	}

	if (result == NULL) {
		logger_error("Can't get result");
		return NULL;
	}

	return result;
}

bool redis_pipeline_channel::handle_result(redis_pipeline_message* msg,
	const redis_result* result) const