| 556 | } |
| 557 | |
| 558 | box<redis_pipeline_message>* redis_client_pipeline::create_box() |
| 559 | { |
| 560 | switch (box_type_) { |
| 561 | case BOX_TYPE_TBOX: |
| 562 | return new tbox<redis_pipeline_message>(false); |
| 563 | case BOX_TYPE_TBOX_ARRAY: |
| 564 | return new tbox_array<redis_pipeline_message>(false); |
| 565 | case BOX_TYPE_MBOX: |
| 566 | default: |
| 567 | return new mbox<redis_pipeline_message>(false, false); |
| 568 | } |
| 569 | } |
| 570 | |
| 571 | // Called after the thread started |
| 572 | // @override from acl::thread |
no outgoing calls
no test coverage detected