Github user jolynch commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/212#discussion_r228386285
--- Diff:
src/java/org/apache/cassandra/net/StartupClusterConnectivityChecker.java ---
@@ -213,4 +261,11 @@ boolean incrementAndCheck(InetAddressAndPort address)
return acks.computeIfAbsent(address, addr -> new
AtomicInteger(0)).incrementAndGet() == threshold;
}
}
+
+ private String fmtBlocker(Integer size, Integer count)
--- End diff --
I killed it.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]