| 334 | } |
| 335 | |
| 336 | void redis_pipeline_channel::all_failed() |
| 337 | { |
| 338 | for (std::list<redis_pipeline_message*>::iterator it = msgs_.begin(); |
| 339 | it != msgs_.end(); ++it) { |
| 340 | (*it)->push(NULL); |
| 341 | } |
| 342 | } |
| 343 | |
| 344 | bool redis_pipeline_channel::handle_messages() |
| 345 | { |