summaryrefslogtreecommitdiffstats
path: root/filedistribution
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-12-08 19:33:46 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2017-12-08 19:33:46 +0100
commit08548b78355a3c4fbe1a82e2e54d03156a108b01 (patch)
tree720d04da136e71f13e289694912b0a65a0236667 /filedistribution
parentf83c2be974ce171d7d2d32fdf642f5b8bf69fcfa (diff)
Implement the chunked transfer.
Diffstat (limited to 'filedistribution')
-rw-r--r--filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReceiver.java16
1 files changed, 8 insertions, 8 deletions
diff --git a/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReceiver.java b/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReceiver.java
index d783ecf97ea..b28e192f8e4 100644
--- a/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReceiver.java
+++ b/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReceiver.java
@@ -29,10 +29,10 @@ import java.util.logging.Logger;
public class FileReceiver {
private final static Logger log = Logger.getLogger(FileReceiver.class.getName());
- private final static String RECEIVE_METHOD = "filedistribution.receiveFile";
- private final static String RECEIVE_META_METHOD = "filedistribution.receiveFileMeta";
- private final static String RECEIVE_PART_METHOD = "filedistribution.receiveFilePart";
- private final static String RECEIVE_EOF_METHOD = "filedistribution.receiveFileEof";
+ public final static String RECEIVE_METHOD = "filedistribution.receiveFile";
+ public final static String RECEIVE_META_METHOD = "filedistribution.receiveFileMeta";
+ public final static String RECEIVE_PART_METHOD = "filedistribution.receiveFilePart";
+ public final static String RECEIVE_EOF_METHOD = "filedistribution.receiveFileEof";
private final Supervisor supervisor;
private final FileReferenceDownloader downloader;
@@ -142,8 +142,8 @@ public class FileReceiver {
List<Method> methods = new ArrayList<>();
methods.add(new Method(RECEIVE_META_METHOD, "sssl", "ii", handler,"receiveFileMeta")
.paramDesc(0, "filereference", "file reference to download")
- .paramDesc(1, "type", "'file' or 'compressed'")
- .paramDesc(2, "filename", "filename")
+ .paramDesc(1, "filename", "filename")
+ .paramDesc(2, "type", "'file' or 'compressed'")
.paramDesc(3, "filelength", "length in bytes of file")
.returnDesc(0, "ret", "0 if success, 1 otherwise")
.returnDesc(1, "session-id", "Session id to be used for this transfer"));
@@ -246,8 +246,8 @@ public class FileReceiver {
public final void receiveFileMeta(Request req) {
log.info("Received method call '" + req.methodName() + "' with parameters : " + req.parameters());
FileReference reference = new FileReference(req.parameters().get(0).asString());
- String type = req.parameters().get(1).asString();
- String fileName = req.parameters().get(2).asString();
+ String fileName = req.parameters().get(1).asString();
+ String type = req.parameters().get(2).asString();
long fileSize = req.parameters().get(3).asInt64();
int sessionId = nextSessionId.getAndIncrement();
int retval = 0;