diff options
author | Harald Musum <musum@yahooinc.com> | 2021-11-15 14:52:32 +0100 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2021-11-15 14:52:32 +0100 |
commit | 672ad4413047c277e06adee1a408f10bbc50b5d6 (patch) | |
tree | 331a717fdbdfd0b25922d64b1f146ba8e1d82631 /config-proxy | |
parent | 3db0193e1998ef5ed3f176c4f46cc4c4c08f9000 (diff) |
Remove unused method
RPC method filedistribution.setFileReferencesToDownload is only used
between config servers, remove config proxy implementation
Diffstat (limited to 'config-proxy')
-rw-r--r-- | config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileDistributionRpcServer.java | 17 |
1 files changed, 1 insertions, 16 deletions
diff --git a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileDistributionRpcServer.java b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileDistributionRpcServer.java index 8f9e5edc337..8b9d1f34154 100644 --- a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileDistributionRpcServer.java +++ b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileDistributionRpcServer.java @@ -4,23 +4,20 @@ package com.yahoo.vespa.config.proxy.filedistribution; import com.yahoo.concurrent.DaemonThreadFactory; import com.yahoo.config.FileReference; import com.yahoo.jrt.DoubleArray; -import com.yahoo.jrt.Int32Value; import com.yahoo.jrt.Method; import com.yahoo.jrt.Request; import com.yahoo.jrt.StringArray; import com.yahoo.jrt.StringValue; import com.yahoo.jrt.Supervisor; -import java.util.logging.Level; import com.yahoo.vespa.filedistribution.FileDownloader; -import com.yahoo.vespa.filedistribution.FileReferenceDownload; import java.io.File; -import java.util.Arrays; import java.util.Map; import java.util.Optional; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; +import java.util.logging.Level; import java.util.logging.Logger; import java.util.stream.Collectors; @@ -67,10 +64,6 @@ class FileDistributionRpcServer { .methodDesc("download status for file references") .returnDesc(0, "file references", "array of file references") .returnDesc(1, "download status", "percentage downloaded of each file reference in above array")); - supervisor.addMethod(new Method("filedistribution.setFileReferencesToDownload", "S", "i", this::setFileReferencesToDownload) - .methodDesc("set which file references to download") - .paramDesc(0, "file references", "file reference to download") - .returnDesc(0, "ret", "0 if success, 1 otherwise")); } @@ -105,14 +98,6 @@ class FileDistributionRpcServer { req.returnValues().add(new DoubleArray(downloadStatusArray)); } - private void setFileReferencesToDownload(Request req) { - log.log(Level.FINE, () -> "Received method call '" + req.methodName() + "' with parameters : " + req.parameters()); - Arrays.stream(req.parameters().get(0).asStringArray()) - .map(FileReference::new) - .forEach(fileReference -> downloader.downloadIfNeeded(new FileReferenceDownload(fileReference))); - req.returnValues().add(new Int32Value(0)); - } - private void downloadFile(Request req) { FileReference fileReference = new FileReference(req.parameters().get(0).asString()); log.log(Level.FINE, () -> "getFile() called for file reference '" + fileReference.value() + "'"); |