Skip to content

Commit

Permalink
Cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
Cameron Zemek authored and smiklosovic committed May 29, 2023
1 parent c34f3a6 commit 616f68f
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions src/java/org/apache/cassandra/gms/Gossiper.java
Expand Up @@ -2265,6 +2265,7 @@ public static void waitToSettle()
final int GOSSIP_SETTLE_MIN_WAIT_MS = CassandraRelevantProperties.GOSSIP_SETTLE_MIN_WAIT_MS.getInt();
final int GOSSIP_SETTLE_POLL_INTERVAL_MS = CassandraRelevantProperties.GOSSIP_SETTLE_POLL_INTERVAL_MS.getInt();
final int GOSSIP_SETTLE_POLL_SUCCESSES_REQUIRED = CassandraRelevantProperties.GOSSIP_SETTLE_POLL_SUCCESSES_REQUIRED.getInt();

logger.info("Waiting for gossip to settle...");
Uninterruptibles.sleepUninterruptibly(GOSSIP_SETTLE_MIN_WAIT_MS, TimeUnit.MILLISECONDS);
int totalPolls = 0;
Expand All @@ -2279,12 +2280,12 @@ public static void waitToSettle()
totalPolls++;
if (currentSize == epSize && currentLive == liveSize)
{
logger.debug("Gossip looks settled with {} states and {} live endpoints after {} polls.", currentSize, currentLive, totalPolls);
logger.debug("Gossip looks settled.");
numOkay++;
}
else
{
logger.info("Gossip not settled with {} states and {} live endpoints after {} polls.", currentSize, currentLive, totalPolls);
logger.info("Gossip not settled after {} polls.", totalPolls);
numOkay = 0;
}
epSize = currentSize;
Expand Down

0 comments on commit 616f68f

Please sign in to comment.