summaryrefslogtreecommitdiffstats
path: root/config-proxy
diff options
context:
space:
mode:
authorHarald Musum <musum@oath.com>2017-11-07 11:22:04 +0100
committerHarald Musum <musum@oath.com>2017-11-07 11:22:04 +0100
commite1a47d5e9a82251ec76728943e7b5559d0b96e7c (patch)
treea82309ba01933d995a45f32a8d39716c46e41ac2 /config-proxy
parent3844115235cf56c977aa580a3cd56f81ebfcc520 (diff)
Synchronize access when making copy in the right place
Diffstat (limited to 'config-proxy')
-rw-r--r--config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileDownloader.java2
-rw-r--r--config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileReferenceDownloader.java4
2 files changed, 3 insertions, 3 deletions
diff --git a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileDownloader.java b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileDownloader.java
index 21e9b7f160b..3977bbd5bfb 100644
--- a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileDownloader.java
+++ b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileDownloader.java
@@ -142,7 +142,7 @@ public class FileDownloader {
}
ImmutableSet<FileReference> queuedForDownload() {
- return ImmutableSet.copyOf(fileReferenceDownloader.queuedForDownload().keySet());
+ return ImmutableSet.copyOf(fileReferenceDownloader.queuedForDownload());
}
}
diff --git a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileReferenceDownloader.java b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileReferenceDownloader.java
index 07b2094ef35..775a50cfb37 100644
--- a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileReferenceDownloader.java
+++ b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileReferenceDownloader.java
@@ -81,8 +81,8 @@ class FileReferenceDownloader {
}
}
- Map<FileReference, SettableFuture<Optional<File>>> queuedForDownload() {
- return queuedForDownload;
+ synchronized ImmutableSet<FileReference> queuedForDownload() {
+ return ImmutableSet.copyOf(queuedForDownload.keySet());
}
private synchronized void completedDownloading(FileReference fileReference, File file) {