From 05584e3c36dda74570e4b95044eb39f485e4f484 Mon Sep 17 00:00:00 2001
From: Jon Marius Venstad <venstad@gmail.com>
Date: Mon, 21 Jun 2021 11:38:27 +0200
Subject: More aggressive default settings

---
 .../src/main/java/ai/vespa/feed/client/DynamicThrottler.java          | 4 ++--
 .../src/main/java/ai/vespa/feed/client/FeedClientBuilder.java         | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

(limited to 'vespa-feed-client')

diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/DynamicThrottler.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/DynamicThrottler.java
index ad6f7225ee8..6f4e4e752f0 100644
--- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/DynamicThrottler.java
+++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/DynamicThrottler.java
@@ -23,7 +23,7 @@ public class DynamicThrottler extends StaticThrottler {
     private final AtomicLong targetInflight;
     private long updateNanos = 0;
     private final List<AtomicLong> latencies = new ArrayList<>();
-    private final double weight = 0.8; // Higher weight favours higher (own) throughput, at the cost of (shared) latency.
+    private final double weight = 0.9; // Higher weight favours higher (own) throughput, at the cost of (shared) latency.
 
     public DynamicThrottler(FeedClientBuilder builder) {
         super(builder);
@@ -63,7 +63,7 @@ public class DynamicThrottler extends StaticThrottler {
                     choice = target;
                 }
             }
-            long target = (long) ((random() * 0.15 + 0.95) * choice); // Random walk, skewed towards increase.
+            long target = (long) ((random() * 0.25 + 0.90) * choice); // Random walk, skewed towards increase.
             targetInflight.set(max(minInflight, min(maxInflight, target)));
         });
     }
diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/FeedClientBuilder.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/FeedClientBuilder.java
index 8b5eb9efea7..0f685ec5b7f 100644
--- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/FeedClientBuilder.java
+++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/FeedClientBuilder.java
@@ -35,7 +35,7 @@ public class FeedClientBuilder {
     SSLContext sslContext;
     HostnameVerifier hostnameVerifier;
     int connectionsPerEndpoint = 4;
-    int maxStreamsPerConnection = 128;
+    int maxStreamsPerConnection = 4096;
     FeedClient.RetryStrategy retryStrategy = defaultRetryStrategy;
     FeedClient.CircuitBreaker circuitBreaker = new GracePeriodCircuitBreaker(Duration.ofSeconds(1), Duration.ofMinutes(10));
     Path certificateFile;
-- 
cgit v1.2.3