diff --git a/concurrency-limits-core/src/main/java/com/netflix/concurrency/limits/limit/Gradient2Limit.java b/concurrency-limits-core/src/main/java/com/netflix/concurrency/limits/limit/Gradient2Limit.java index f706f1a7..90c95b80 100644 --- a/concurrency-limits-core/src/main/java/com/netflix/concurrency/limits/limit/Gradient2Limit.java +++ b/concurrency-limits-core/src/main/java/com/netflix/concurrency/limits/limit/Gradient2Limit.java @@ -230,7 +230,7 @@ private Gradient2Limit(Builder builder) { this.minLimit = builder.minLimit; this.queueSize = builder.queueSize; this.smoothing = builder.smoothing; - this.shortRtt = new SingleMeasurement(); // new ExpAvgMeasurement(builder.shortWindow,10); + this.shortRtt = new SingleMeasurement(); this.longRtt = new ExpAvgMeasurement(builder.longWindow, 10); this.longRttSampleListener = builder.registry.registerDistribution(MetricIds.MIN_RTT_NAME); diff --git a/concurrency-limits-core/src/main/java/com/netflix/concurrency/limits/limiter/AbstractPartitionedLimiter.java b/concurrency-limits-core/src/main/java/com/netflix/concurrency/limits/limiter/AbstractPartitionedLimiter.java index 1651cc71..fe47933b 100644 --- a/concurrency-limits-core/src/main/java/com/netflix/concurrency/limits/limiter/AbstractPartitionedLimiter.java +++ b/concurrency-limits-core/src/main/java/com/netflix/concurrency/limits/limiter/AbstractPartitionedLimiter.java @@ -269,6 +269,7 @@ private void releasePartition(Partition partition) { @Override protected void onNewLimit(int newLimit) { + super.onNewLimit(newLimit); partitions.forEach((name, partition) -> partition.updateLimit(newLimit)); }