From: Vratko Polak Date: Fri, 7 Jul 2017 11:14:57 +0000 (+0200) Subject: ProgressTracker: Decrease delay due nearestAllowed X-Git-Tag: release/carbon-sr2~42 X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=commitdiff_plain;h=80e6514d56cd4dc6aa40997dea2b460723148341;hp=2be77b3bcef31ad8b6dbdce073471561d2cf76d6 ProgressTracker: Decrease delay due nearestAllowed If nearestAllowed is in past, that means we have a temporary interval of relatively small demand for tasks. We can reduce delay, as if the time since nearestAllowed was a "delay in advance". This way the queue stays closer to the intended capacity. Change-Id: I40f95ea9cb25ea62d8c65ee78cafc79e9b56cc11 Signed-off-by: Vratko Polak --- diff --git a/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/ProgressTracker.java b/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/ProgressTracker.java index 699c102297..027b35d873 100644 --- a/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/ProgressTracker.java +++ b/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/ProgressTracker.java @@ -219,7 +219,7 @@ abstract class ProgressTracker { * @return estimated tick number when all threads with opened tasks are done waiting */ public long estimateAllowed(final long now) { - return Math.max(now, nearestAllowed) + estimateIsolatedDelay(now); + return Math.max(now, nearestAllowed + estimateIsolatedDelay(now)); } // State-altering public methods.