summaryrefslogtreecommitdiffstats
path: root/filedistribution
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2021-04-28 08:27:55 +0200
committerHarald Musum <musum@verizonmedia.com>2021-04-28 08:27:55 +0200
commit50945a2b6d44ffd72ca4fb8a6e5259b4ed7acd93 (patch)
tree5410180703be293ddc1063bdd0bd7072f64bd3a4 /filedistribution
parente79af49a3159e5505cd3e5f2605c299d38fe40cd (diff)
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
Diffstat (limited to 'filedistribution')
-rw-r--r--filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java2
-rw-r--r--filedistribution/src/test/java/com/yahoo/vespa/filedistribution/FileDownloaderTest.java2
2 files changed, 2 insertions, 2 deletions
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;
}