Method GetRoleInfo

src/server/server.cc:1323–1369

}

std::string Server::GetRoleInfo() {
  if (IsSlave()) {
    std::vector<std::string> roles;
    roles.emplace_back("slave");
    roles.emplace_back(master_host_);
    roles.emplace_back(std::to_string(master_port_));

    auto state = GetReplicationState();
    if (state == kReplConnected) {
      roles.emplace_back("connected");
    } else if (state == kReplFetchMeta || state == kReplFetchSST) {
      roles.emplace_back("sync");
    } else {
      roles.emplace_back("connecting");
    }
    roles.emplace_back(std::to_string(storage->LatestSeqNumber()));
    return redis::ArrayOfBulkStrings(roles);
  } else {
    std::vector<std::string> list;

    {
      std::shared_lock<std::shared_mutex> guard(slave_threads_mu_);
      for (const auto &slave : slave_threads_) {
        if (slave->IsStopped()) continue;

        list.emplace_back(redis::ArrayOfBulkStrings({
            slave->GetConn()->GetAnnounceIP(),
            std::to_string(slave->GetConn()->GetListeningPort()),
            std::to_string(slave->GetAckSeq()),
        }));
      }
    }

    auto multi_len = 2;
    if (list.size() > 0) {
      multi_len = 3;
    }
    std::string info;
    info.append(redis::MultiLen(multi_len));
    info.append(redis::BulkString("master"));
    info.append(redis::BulkString(std::to_string(storage->LatestSeqNumber())));
    if (list.size() > 0) {
      info.append(redis::Array(list));
    }
    return info;
  }
}

std::string Server::GetLastRandomKeyCursor() {
  std::string cursor;