| 365 | } |
| 366 | |
| 367 | redis_result* redis_client::get_objects(socket_stream& conn, |
| 368 | dbuf_pool* dbuf, size_t nobjs) |
| 369 | { |
| 370 | acl_assert(nobjs >= 1); |
| 371 | |
| 372 | redis_result* objs = new(dbuf) redis_result(dbuf); |
| 373 | objs->set_type(REDIS_RESULT_ARRAY); |
| 374 | objs->set_size(nobjs); |
| 375 | |
| 376 | for (size_t i = 0; i < nobjs; i++) { |
| 377 | redis_result* obj = get_object(conn, dbuf); |
| 378 | if (obj == NULL) { |
| 379 | return NULL; |
| 380 | } |
| 381 | objs->put(obj, i); |
| 382 | } |
| 383 | return objs; |
| 384 | } |
| 385 | |
| 386 | const redis_result* redis_client::run(dbuf_pool* dbuf, const string& req, |
| 387 | size_t nchildren, int* rw_timeout /* = NULL */) |
no test coverage detected