diff options
author | Harald Musum <musum@oath.com> | 2017-12-14 10:38:19 +0100 |
---|---|---|
committer | Harald Musum <musum@oath.com> | 2017-12-14 10:38:19 +0100 |
commit | 0f1b5a16edc9c15316143d6b9e2a3e8ef3a3beef (patch) | |
tree | bfc7af6c41f323f3d7e9a47097708e1bee2d8155 /filedistribution | |
parent | f88c3596a68dd107a13d53f35a8f458accb5df07 (diff) |
Do async file distribution (when preparing application) when file distributor disable
Also: Don't cancel future when getting dile references started by async file distribution
Diffstat (limited to 'filedistribution')
-rw-r--r-- | filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileDownloader.java | 4 | ||||
-rw-r--r-- | filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java | 3 |
2 files changed, 3 insertions, 4 deletions
diff --git a/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileDownloader.java b/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileDownloader.java index 05bcaacb107..727786cdc78 100644 --- a/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileDownloader.java +++ b/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileDownloader.java @@ -54,7 +54,7 @@ public class FileDownloader { } } - public Future<Optional<File>> getFutureFile(FileReference fileReference) { + private Future<Optional<File>> getFutureFile(FileReference fileReference) { Objects.requireNonNull(fileReference, "file reference cannot be null"); File directory = new File(downloadDirectory, fileReference.value()); log.log(LogLevel.DEBUG, "Checking if there is a file in '" + directory.getAbsolutePath() + "' "); @@ -77,7 +77,7 @@ public class FileDownloader { if (fileReferenceDownloader.isDownloading(fileReference)) { log.log(LogLevel.DEBUG, "Already downloading '" + fileReference.value() + "'"); } else { - queueForAsyncDownload(fileReference).cancel(false); + queueForAsyncDownload(fileReference); } }); } 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 b8402c8aacf..509231ba7ff 100644 --- a/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java +++ b/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java @@ -77,7 +77,7 @@ public class FileReferenceDownloader { } void addToDownloadQueue(FileReferenceDownload fileReferenceDownload) { - log.log(LogLevel.DEBUG, "Will download file reference '" + fileReferenceDownload.fileReference().value() + "'"); + log.log(LogLevel.DEBUG, "Will download file reference '" + fileReferenceDownload.fileReference().value() + "' with timeout " + downloadTimeout); downloadExecutor.submit(() -> startDownload(downloadTimeout, fileReferenceDownload)); } @@ -140,7 +140,6 @@ public class FileReferenceDownloader { } } return null; - } private void execute(Request request, Connection connection) { |