diff options
author | Harald Musum <musum@oath.com> | 2018-04-05 13:01:06 +0200 |
---|---|---|
committer | Harald Musum <musum@oath.com> | 2018-04-05 13:01:06 +0200 |
commit | ebab8a3e2e2183f17e6002f5906b113ea23a5048 (patch) | |
tree | 137e184eb496b07ace7423484d69271d9599d155 /configserver | |
parent | 837e0aad88bb1c11a62d0491302c86ef1df2c533 (diff) |
Do not download only if another download for the same file reference is in progress
Diffstat (limited to 'configserver')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java index a1066524f9c..7844fa14b16 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java @@ -537,7 +537,7 @@ public class RpcServer implements Runnable, ReloadListener, TenantListener { String[] fileReferenceStrings = req.parameters().get(0).asStringArray(); Stream.of(fileReferenceStrings) .map(FileReference::new) - .forEach(fileReference -> downloader.queueForAsyncDownload( + .forEach(fileReference -> downloader.download( new FileReferenceDownload(fileReference, false /* downloadFromOtherSourceIfNotFound */))); req.returnValues().add(new Int32Value(0)); } |