You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by db...@apache.org on 2013/06/21 03:23:49 UTC
git commit: use double math for currentThroughput patch by dbrosius
reviewed by jbellis for cassandra 5286
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 <db...@apache.org>
Authored: Thu Jun 20 21:21:28 2013 -0400
Committer: Dave Brosius <db...@apache.org>
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;