rename
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/3ae5559e Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/3ae5559e Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/3ae5559e Branch: refs/heads/cassandra-2.1 Commit: 3ae5559ee5e842443cab9fa4b1a08a79f24b5d2b Parents: ecac587 Author: Jonathan Ellis <[email protected]> Authored: Mon Jun 30 20:48:58 2014 -0700 Committer: Jonathan Ellis <[email protected]> Committed: Mon Jun 30 20:48:58 2014 -0700 ---------------------------------------------------------------------- src/java/org/apache/cassandra/streaming/StreamManager.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/3ae5559e/src/java/org/apache/cassandra/streaming/StreamManager.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/streaming/StreamManager.java b/src/java/org/apache/cassandra/streaming/StreamManager.java index 6dfb1ac..f40be99 100644 --- a/src/java/org/apache/cassandra/streaming/StreamManager.java +++ b/src/java/org/apache/cassandra/streaming/StreamManager.java @@ -63,17 +63,17 @@ public class StreamManager implements StreamManagerMBean public static class StreamRateLimiter { - private static final double ONE_MEGA_BYTE = (1024 * 1024) / 8; // from bits + private static final double ONE_MEGA_BIT = (1024 * 1024) / 8; // from bits private static final RateLimiter limiter = RateLimiter.create(Double.MAX_VALUE); private static final RateLimiter interDCLimiter = RateLimiter.create(Double.MAX_VALUE); private final boolean isLocalDC; public StreamRateLimiter(InetAddress peer) { - double throughput = ((double) DatabaseDescriptor.getStreamThroughputOutboundMegabitsPerSec()) * ONE_MEGA_BYTE; + double throughput = ((double) DatabaseDescriptor.getStreamThroughputOutboundMegabitsPerSec()) * ONE_MEGA_BIT; mayUpdateThroughput(throughput, limiter); - double interDCThroughput = ((double) DatabaseDescriptor.getInterDCStreamThroughputOutboundMegabitsPerSec()) * ONE_MEGA_BYTE; + double interDCThroughput = ((double) DatabaseDescriptor.getInterDCStreamThroughputOutboundMegabitsPerSec()) * ONE_MEGA_BIT; mayUpdateThroughput(interDCThroughput, interDCLimiter); if (DatabaseDescriptor.getLocalDataCenter() != null && DatabaseDescriptor.getEndpointSnitch() != null)
