| 116 | } |
| 117 | |
| 118 | bool redis_pipeline_channel::start_thread() |
| 119 | { |
| 120 | if (!static_cast<connect_client *>(client_)->open()) { |
| 121 | logger_error("open %s error %s", addr_.c_str(), last_serror()); |
| 122 | return false; |
| 123 | } |
| 124 | this->start(); |
| 125 | return true; |
| 126 | } |
| 127 | |
| 128 | void redis_pipeline_channel::stop_thread() |
| 129 | { |
no test coverage detected