You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2014/07/01 05:49:13 UTC
[4/6] git commit: rename
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 <jb...@apache.org>
Authored: Mon Jun 30 20:48:58 2014 -0700
Committer: Jonathan Ellis <jb...@apache.org>
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)