| 215 | void IncrFetchFileThread() { fetch_file_threads_num_++; } |
| 216 | void DecrFetchFileThread() { fetch_file_threads_num_--; } |
| 217 | int GetFetchFileThreadNum() const { return fetch_file_threads_num_; } |
| 218 | |
| 219 | int PublishMessage(const std::string &channel, const std::string &msg); |
| 220 | void SubscribeChannel(const std::string &channel, redis::Connection *conn); |