cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject [5/6] git commit: rename
Date Tue, 01 Jul 2014 03:49:14 GMT
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/trunk
Commit: 3ae5559ee5e842443cab9fa4b1a08a79f24b5d2b
Parents: ecac587
Author: Jonathan Ellis <jbellis@apache.org>
Authored: Mon Jun 30 20:48:58 2014 -0700
Committer: Jonathan Ellis <jbellis@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)


Mime
View raw message