Updated Branches: refs/heads/trunk 21deff6c9 -> 56d2296ad
use double math for currentThroughput patch by dbrosius reviewed by jbellis for cassandra 5286 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/56d2296a Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/56d2296a Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/56d2296a Branch: refs/heads/trunk Commit: 56d2296adf281b774aea6598bd8baaa9e77685f3 Parents: 21deff6 Author: Dave Brosius <[email protected]> Authored: Thu Jun 20 21:21:28 2013 -0400 Committer: Dave Brosius <[email protected]> Committed: Thu Jun 20 21:21:28 2013 -0400 ---------------------------------------------------------------------- src/java/org/apache/cassandra/streaming/StreamManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/56d2296a/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 d64cc65..8ea9976 100644 --- a/src/java/org/apache/cassandra/streaming/StreamManager.java +++ b/src/java/org/apache/cassandra/streaming/StreamManager.java @@ -55,7 +55,7 @@ public class StreamManager implements StreamManagerMBean */ public static RateLimiter getRateLimiter() { - double currentThroughput = DatabaseDescriptor.getStreamThroughputOutboundMegabitsPerSec() * 1024 * 1024 / 8 / 1000; + double currentThroughput = ((double) DatabaseDescriptor.getStreamThroughputOutboundMegabitsPerSec()) * 1024 * 1024 / 8 / 1000; // if throughput is set to 0, throttling is disabled if (currentThroughput == 0) currentThroughput = Double.MAX_VALUE;
