diff options
author | Martin Polden <mpolden@mpolden.no> | 2021-06-02 13:52:36 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-06-02 13:52:36 +0200 |
commit | d893c9710c98e73cdcdcc16925f3102ae48c694a (patch) | |
tree | 5db35abdbccbd098f68116ad63225c8797570e7e /controller-server | |
parent | 97578df771bcc6a1f8e3773d7c31c920d327097b (diff) |
Bump capacity of DNS request queue (#18090)
Diffstat (limited to 'controller-server')
-rw-r--r-- | controller-server/src/main/java/com/yahoo/vespa/hosted/controller/dns/NameServiceForwarder.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/dns/NameServiceForwarder.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/dns/NameServiceForwarder.java index d9928bffba4..f8c390edb3b 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/dns/NameServiceForwarder.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/dns/NameServiceForwarder.java @@ -28,7 +28,7 @@ import java.util.stream.Collectors; */ public class NameServiceForwarder { - private static final int maxQueuedRequests = 200; + private static final int QUEUE_CAPACITY = 300; private static final Logger log = Logger.getLogger(NameServiceForwarder.class.getName()); @@ -73,13 +73,13 @@ public class NameServiceForwarder { try (Lock lock = db.lockNameServiceQueue()) { NameServiceQueue queue = db.readNameServiceQueue(); var queued = queue.requests().size(); - if (queued >= maxQueuedRequests) { + if (queued >= QUEUE_CAPACITY) { log.log(Level.WARNING, "Queue is at capacity (size: " + queued + "), dropping older " + "requests. This likely means that the name service is not successfully " + "executing requests"); } log.log(Level.FINE, () -> "Queueing name service request: " + request); - db.writeNameServiceQueue(queue.with(request, priority).last(maxQueuedRequests)); + db.writeNameServiceQueue(queue.with(request, priority).last(QUEUE_CAPACITY)); } } |