summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-12-12 08:30:11 +0100
committerGitHub <noreply@github.com>2022-12-12 08:30:11 +0100
commitab374e97ea1cafd5a12778906ae86b292f95b9fa (patch)
treef9e144ab90864150a357cc14bf35a26fee2e71c3
parent1800b10360e51e11e3cda04719909c37cc9d6a72 (diff)
parent9975923a8e1be6fafb69fe14737301119b84b295 (diff)
Merge pull request #25208 from vespa-engine/revert-25193-jonmv/limit-max-inflight-from-client
Revert "Limit max inflight from outside apache client"
-rw-r--r--vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/StaticThrottler.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/StaticThrottler.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/StaticThrottler.java
index 9e7f868e346..1f9cf8e5155 100644
--- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/StaticThrottler.java
+++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/StaticThrottler.java
@@ -21,8 +21,8 @@ public class StaticThrottler implements Throttler {
private final AtomicLong targetX10;
public StaticThrottler(FeedClientBuilderImpl builder) {
- minInflight = min(16L, builder.maxStreamsPerConnection) * builder.connectionsPerEndpoint * builder.endpoints.size();
- maxInflight = (long) builder.maxStreamsPerConnection * builder.connectionsPerEndpoint * builder.endpoints.size();
+ minInflight = 16L * builder.connectionsPerEndpoint * builder.endpoints.size();
+ maxInflight = 256 * minInflight; // 4096 max streams per connection on the server side.
targetX10 = new AtomicLong(10 * maxInflight); // 10x the actual value to allow for smaller updates.
}