aboutsummaryrefslogtreecommitdiffstats
path: root/config-proxy
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2021-11-15 14:52:32 +0100
committerHarald Musum <musum@yahooinc.com>2021-11-15 14:52:32 +0100
commit672ad4413047c277e06adee1a408f10bbc50b5d6 (patch)
tree331a717fdbdfd0b25922d64b1f146ba8e1d82631 /config-proxy
parent3db0193e1998ef5ed3f176c4f46cc4c4c08f9000 (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.java17
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() + "'");