diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-12-08 19:33:46 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-12-08 19:33:46 +0100 |
commit | 08548b78355a3c4fbe1a82e2e54d03156a108b01 (patch) | |
tree | 720d04da136e71f13e289694912b0a65a0236667 /filedistribution | |
parent | f83c2be974ce171d7d2d32fdf642f5b8bf69fcfa (diff) |
Implement the chunked transfer.
Diffstat (limited to 'filedistribution')
-rw-r--r-- | filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReceiver.java | 16 |
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; |