| 784 | } |
| 785 | |
| 786 | void Server::CleanupWaitConnection(redis::Connection *conn) { |
| 787 | std::unique_lock<std::shared_mutex> guard(wait_contexts_mu_); |
| 788 | cleanupWaitConnection(conn); |
| 789 | } |
| 790 | |
| 791 | void Server::cleanupWaitConnection(redis::Connection *conn) { |
| 792 | // Remove all wait contexts that match the given connection |