natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

get ocd on log capitalization

This commit is contained in:
Jonathan Ellis 2014-01-28 15:31:10 -06:00
parent 9c9552aead
commit 752415ed91
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/java/org/apache/cassandra/service/CassandraDaemon.java
View File

@ -472,7 +472,7 @@ public class CassandraDaemon
final int GOSSIP_SETTLE_POLL_INTERVAL_MS = 1000; final int GOSSIP_SETTLE_POLL_INTERVAL_MS = 1000;
final int GOSSIP_SETTLE_POLL_SUCCESSES_REQUIRED = 3; final int GOSSIP_SETTLE_POLL_SUCCESSES_REQUIRED = 3;
logger.info("waiting for gossip to settle before accepting client requests..."); logger.info("Waiting for gossip to settle before accepting client requests...");
Uninterruptibles.sleepUninterruptibly(GOSSIP_SETTLE_MIN_WAIT_MS, TimeUnit.MILLISECONDS); Uninterruptibles.sleepUninterruptibly(GOSSIP_SETTLE_MIN_WAIT_MS, TimeUnit.MILLISECONDS);
int totalPolls = 0; int totalPolls = 0;
int numOkay = 0; int numOkay = 0;
@ -486,12 +486,12 @@ public class CassandraDaemon
totalPolls++; totalPolls++;
if (active == 0 && pending == 0) if (active == 0 && pending == 0)
{ {
logger.debug("gossip looks settled. CompletedTasks: {}", completed); logger.debug("Gossip looks settled. CompletedTasks: {}", completed);
numOkay++; numOkay++;
} }
else else
{ {
logger.info("gossip not settled after {} polls. Gossip Stage active/pending/completed: {}/{}/{}", totalPolls, active, pending, completed); logger.info("Gossip not settled after {} polls. Gossip Stage active/pending/completed: {}/{}/{}", totalPolls, active, pending, completed);
numOkay = 0; numOkay = 0;
} }
if (forceAfter > 0 && totalPolls > forceAfter) if (forceAfter > 0 && totalPolls > forceAfter)
@ -501,7 +501,10 @@ public class CassandraDaemon
break; break;
} }
} }
logger.info("gossip settled after {} extra polls; proceeding", totalPolls - GOSSIP_SETTLE_POLL_SUCCESSES_REQUIRED); if (totalPolls > GOSSIP_SETTLE_POLL_SUCCESSES_REQUIRED)
logger.info("Gossip settled after {} extra polls; proceeding", totalPolls - GOSSIP_SETTLE_POLL_SUCCESSES_REQUIRED);
else
logger.debug("Gossip settled after {} extra polls; proceeding", totalPolls - GOSSIP_SETTLE_POLL_SUCCESSES_REQUIRED);
} }
public static void stop(String[] args) public static void stop(String[] args)