diff options
| author | jonmv <venstad@gmail.com> | 2024-05-09 17:53:16 +0200 |
|---|---|---|
| committer | jonmv <venstad@gmail.com> | 2024-05-09 17:53:16 +0200 |
| commit | cacdf7c9526221c5b8ef86f0de203e815cc69754 (patch) | |
| tree | 06a10637c1a1b27a4a946db1eefbaa686291558a /vespa-feed-client | |
| parent | 9084a5bedd010980f755bb5f4800b18bb0577298 (diff) | |
Use actual target inflight when updating measured throughput
Diffstat (limited to 'vespa-feed-client')
| -rw-r--r-- | vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/DynamicThrottler.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/DynamicThrottler.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/DynamicThrottler.java index 31d91ec3530..81e972fe45d 100644 --- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/DynamicThrottler.java +++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/DynamicThrottler.java @@ -33,7 +33,7 @@ public class DynamicThrottler extends StaticThrottler { @Override public void sent(long __, CompletableFuture<HttpResponse> ___) { - double currentInflight = targetInflight.get(); + double currentInflight = targetInflight(); if (++sent * sent * sent < 1e2 * currentInflight * currentInflight) return; |