diff options
author | Harald Musum <musum@verizonmedia.com> | 2022-12-12 07:58:21 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-12-12 07:58:21 +0100 |
commit | 9975923a8e1be6fafb69fe14737301119b84b295 (patch) | |
tree | f9e144ab90864150a357cc14bf35a26fee2e71c3 /vespa-feed-client | |
parent | 1800b10360e51e11e3cda04719909c37cc9d6a72 (diff) |
Revert "Limit max inflight from outside apache client"
Diffstat (limited to 'vespa-feed-client')
-rw-r--r-- | vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/StaticThrottler.java | 4 |
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. } |