Method WakeupWaitConnections

src/server/server.cc:747–771

}

void Server::WakeupWaitConnections(rocksdb::SequenceNumber seq) {
  std::unique_lock<std::shared_mutex> guard(wait_contexts_mu_);

  // find the last entry with target_seq > seq, which cannot wakeup
  auto end_it = wait_contexts_.upper_bound(seq);
  for (auto it = wait_contexts_.begin(); it != end_it;) {
    // Count how many replicas have reached the target sequence
    size_t reached_replicas = GetReplicasReachedSequence(it->second.target_seq);

    // If enough replicas have reached the target sequence, wake up the connection
    if (reached_replicas >= it->second.num_replicas) {
      // Send the response with the number of replicas that have reached the target sequence
      it->second.conn->Reply(redis::Integer(reached_replicas));

      auto s = it->second.conn->Owner()->EnableWriteEvent(it->second.conn->GetFD());
      if (!s.IsOK()) {
        ERROR("[server] Failed to enable write event on WAIT connection {}: {}", it->second.conn->GetFD(), s.Msg());
      }
      it = wait_contexts_.erase(it);
      DecrBlockedClientNum();
      continue;
    }
    ++it;
  }
}

void Server::WakeupWaitConnection(redis::Connection *conn, rocksdb::SequenceNumber seq) {
  std::unique_lock<std::shared_mutex> guard(wait_contexts_mu_);