| 515 | } |
| 516 | |
| 517 | void Worker::QuitMonitorConn(redis::Connection *conn) { |
| 518 | { |
| 519 | std::lock_guard<std::mutex> guard(conns_mu_); |
| 520 | monitor_conns_.erase(conn->GetFD()); |
| 521 | conns_[conn->GetFD()] = conn; |
| 522 | } |
| 523 | srv->DecrMonitorClientNum(); |
| 524 | conn->DisableFlag(redis::Connection::kMonitor); |
| 525 | } |
| 526 | |
| 527 | void Worker::FeedMonitorConns(redis::Connection *conn, const std::string &response) { |
| 528 | std::unique_lock<std::mutex> lock(conns_mu_); |
no test coverage detected