| 251 | } |
| 252 | |
| 253 | redis_pipeline_message* redis_command::get_pipeline_message() |
| 254 | { |
| 255 | if (pipe_msg_ != NULL) { |
| 256 | return pipe_msg_; |
| 257 | } |
| 258 | |
| 259 | assert(pipeline_); |
| 260 | |
| 261 | box<redis_pipeline_message>* box = pipeline_->create_box(); |
| 262 | pipe_msg_ = NEW redis_pipeline_message(redis_pipeline_t_cmd, box); |
| 263 | return pipe_msg_; |
| 264 | } |
| 265 | |
| 266 | void redis_command::argv_space(size_t n) |
| 267 | { |
no test coverage detected