Repository: cassandra Updated Branches: refs/heads/trunk a052dbfe6 -> 7efe1ccc5
remove dead field 'windowSize' Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/7efe1ccc Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/7efe1ccc Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/7efe1ccc Branch: refs/heads/trunk Commit: 7efe1ccc5b9fda790b469ac96bc8c86599b08357 Parents: a052dbf Author: Dave Brosius <[email protected]> Authored: Fri Sep 30 00:25:18 2016 -0400 Committer: Dave Brosius <[email protected]> Committed: Fri Sep 30 00:25:59 2016 -0400 ---------------------------------------------------------------------- .../org/apache/cassandra/net/RateBasedBackPressureState.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/7efe1ccc/src/java/org/apache/cassandra/net/RateBasedBackPressureState.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/net/RateBasedBackPressureState.java b/src/java/org/apache/cassandra/net/RateBasedBackPressureState.java index c19f277..7bcfd6d 100644 --- a/src/java/org/apache/cassandra/net/RateBasedBackPressureState.java +++ b/src/java/org/apache/cassandra/net/RateBasedBackPressureState.java @@ -48,7 +48,6 @@ import org.apache.cassandra.utils.concurrent.IntervalLock; class RateBasedBackPressureState extends IntervalLock implements BackPressureState { private final InetAddress host; - private final long windowSize; final SlidingTimeRate incomingRate; final SlidingTimeRate outgoingRate; final RateLimiter rateLimiter; @@ -57,9 +56,8 @@ class RateBasedBackPressureState extends IntervalLock implements BackPressureSta { super(timeSource); this.host = host; - this.windowSize = windowSize; - this.incomingRate = new SlidingTimeRate(timeSource, this.windowSize, this.windowSize / 10, TimeUnit.MILLISECONDS); - this.outgoingRate = new SlidingTimeRate(timeSource, this.windowSize, this.windowSize / 10, TimeUnit.MILLISECONDS); + this.incomingRate = new SlidingTimeRate(timeSource, windowSize, windowSize / 10, TimeUnit.MILLISECONDS); + this.outgoingRate = new SlidingTimeRate(timeSource, windowSize, windowSize / 10, TimeUnit.MILLISECONDS); this.rateLimiter = RateLimiter.create(Double.POSITIVE_INFINITY); }
