in adapters/adapters-base/src/main/java/org/apache/cassandra/sidecar/adapters/base/TokenRangeReplicaProvider.java [291:310]
String of(String endpoint)
{
if (joiningNodes.contains(endpoint))
{
GossipInfoResponse.GossipInfo gossipInfoEntry = gossipInfo.get(endpoint);
if (gossipInfoEntry != null)
{
LOGGER.debug("Found gossipInfoEntry={}", gossipInfoEntry);
String hostStatus = gossipInfoEntry.status();
String hostStatusWithPort = gossipInfoEntry.statusWithPort();
if ((hostStatus != null && hostStatus.startsWith("BOOT_REPLACE,")) ||
(hostStatusWithPort != null && hostStatusWithPort.startsWith("BOOT_REPLACE,")))
{
return NodeState.REPLACING.displayName();
}
}
}
return super.of(endpoint);
}