diff options
author | Martin Polden <mpolden@mpolden.no> | 2023-01-24 15:55:02 +0100 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2023-01-25 13:52:14 +0100 |
commit | c8b79df01200ed375c7da04ab8c7fcc897a67f46 (patch) | |
tree | 1affce90a5ddce16051c4136f1bb5f3e6cb0c105 /controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/NameServiceDispatcher.java | |
parent | 16b5b25f8c7512c122bb3e7c1cd5c412f8506c48 (diff) |
Minor simplification and javadoc improvements
Diffstat (limited to 'controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/NameServiceDispatcher.java')
-rw-r--r-- | controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/NameServiceDispatcher.java | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/NameServiceDispatcher.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/NameServiceDispatcher.java index e8cb8e30cd2..e4841618852 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/NameServiceDispatcher.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/NameServiceDispatcher.java @@ -8,7 +8,7 @@ import com.yahoo.vespa.hosted.controller.persistence.CuratorDb; import java.time.Clock; import java.time.Duration; -import java.util.ArrayList; +import java.time.Instant; import java.util.logging.Level; /** @@ -39,15 +39,15 @@ public class NameServiceDispatcher extends ControllerMaintainer { // Dispatch 1 request per second on average. Note that this is not entirely accurate because a NameService // implementation may need to perform multiple API-specific requests to execute a single NameServiceRequest int requestCount = trueIntervalInSeconds(); - NameServiceQueue initial; + final NameServiceQueue initial; try (var lock = db.lockNameServiceQueue()) { initial = db.readNameServiceQueue(); } if (initial.requests().isEmpty() || requestCount == 0) return 1.0; - var instant = clock.instant(); - var remaining = initial.dispatchTo(nameService, requestCount); - var dispatched = initial.minus(remaining); + Instant instant = clock.instant(); + NameServiceQueue remaining = initial.dispatchTo(nameService, requestCount); + NameServiceQueue dispatched = initial.without(remaining); if (!dispatched.requests().isEmpty()) { Level logLevel = controller().system().isCd() ? Level.INFO : Level.FINE; |