Github user jolynch commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/212#discussion_r225734880
--- 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 --
Heh, yea it is I just thought that it was slightly clearer what it was
doing (so we don't print `Integer.MAX_VALUE` to the log. I'll change it to
`Math.max` instead.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
