From 50945a2b6d44ffd72ca4fb8a6e5259b4ed7acd93 Mon Sep 17 00:00:00 2001 From: Harald Musum Date: Wed, 28 Apr 2021 08:27:55 +0200 Subject: Switch connection only when the current one is failing Subscribers set error on a connection if it fails, so when having many subscribers we should not switch unless the current connection is having errors --- .../java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java | 2 +- .../test/java/com/yahoo/vespa/filedistribution/FileDownloaderTest.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) (limited to 'filedistribution') diff --git a/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java b/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java index 05fbd457a0d..da9d4ceab88 100644 --- a/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java +++ b/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java @@ -127,7 +127,7 @@ public class FileReferenceDownloader { return true; } else { log.log(logLevel, "File reference '" + fileReference + "' not found at " + connection.getAddress()); - connectionPool.switchConnection(); + connectionPool.switchConnection(connection); return false; } } else { diff --git a/filedistribution/src/test/java/com/yahoo/vespa/filedistribution/FileDownloaderTest.java b/filedistribution/src/test/java/com/yahoo/vespa/filedistribution/FileDownloaderTest.java index 1344b7afbb3..d6bae088ee2 100644 --- a/filedistribution/src/test/java/com/yahoo/vespa/filedistribution/FileDownloaderTest.java +++ b/filedistribution/src/test/java/com/yahoo/vespa/filedistribution/FileDownloaderTest.java @@ -341,7 +341,7 @@ public class FileDownloaderTest { } @Override - public Connection switchConnection() { + public Connection switchConnection(Connection connection) { return this; } -- cgit v1.2.3