diff options
| author | Haakon Dybdahl <dybdahl@yahoo-inc.com> | 2016-09-27 08:01:40 +0200 |
|---|---|---|
| committer | Haakon Dybdahl <dybdahl@yahoo-inc.com> | 2016-09-27 08:01:40 +0200 |
| commit | 688c67e56176e8d13a7a0d508221ed0e07c80162 (patch) | |
| tree | 9400e26353b7e2714dfccfe0ec4cc2d29fc4a73a /vespa-http-client | |
| parent | 7964d78bc1a262a746019ea6752ce9a21eb805a8 (diff) | |
Take retries into account as well for extermly slow clusters, that have experience failures.
Diffstat (limited to 'vespa-http-client')
| -rw-r--r-- | vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/api/FeedClientImpl.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/api/FeedClientImpl.java b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/api/FeedClientImpl.java index e6ff8593e71..d7f001eff31 100644 --- a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/api/FeedClientImpl.java +++ b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/api/FeedClientImpl.java @@ -27,8 +27,9 @@ public class FeedClientImpl implements FeedClient { public FeedClientImpl( SessionParams sessionParams, ResultCallback resultCallback, ScheduledThreadPoolExecutor timeoutExecutor) { - this.closeTimeoutMs = sessionParams.getFeedParams().getServerTimeout(TimeUnit.MILLISECONDS) + - sessionParams.getFeedParams().getClientTimeout(TimeUnit.MILLISECONDS); + this.closeTimeoutMs = sessionParams.getConnectionParams().getMaxRetries() * ( + sessionParams.getFeedParams().getServerTimeout(TimeUnit.MILLISECONDS) + + sessionParams.getFeedParams().getClientTimeout(TimeUnit.MILLISECONDS)); this.operationProcessor = new OperationProcessor( new IncompleteResultsThrottler( sessionParams.getThrottlerMinSize(), |