diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-11-07 23:22:37 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-11-07 23:22:37 +0100 |
commit | cbd7624e53113aa5c7861b3de9fa036c133e554b (patch) | |
tree | 52581da9f47cc609d51aed647cd0834f3c23e62e /configserver | |
parent | 06dcf9923c9a81bb3d06211f1a9fc44af3fc22ee (diff) |
Update receiveFile to new signature.
Diffstat (limited to 'configserver')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileServer.java | 10 | ||||
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java | 2 |
2 files changed, 8 insertions, 4 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileServer.java b/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileServer.java index 581293c3128..4b0b19a34d0 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileServer.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileServer.java @@ -52,21 +52,25 @@ public class FileServer { } private void serveFile(String fileName, Target target) { - Request fileBlob = new Request("receiveFile"); + Request fileBlob = new Request("filedistribution.receiveFile"); File file = new File(getPath(new FileReference(fileName))); fileBlob.parameters().add(new StringValue(fileName)); + fileBlob.parameters().add(new StringValue(fileName)); byte [] blob = new byte [0]; boolean success = false; + String errorDescription = "OK"; try { blob = IOUtils.readFileBytes(file); success = true; } catch (IOException e) { - log.warning("Failed reading file '" + file.getAbsolutePath() + "' for sending to '" + target.toString() + "'."); + errorDescription = "Failed reading file '" + file.getAbsolutePath() + "'"; + log.warning(errorDescription + "for sending to '" + target.toString() + "'."); } XXHash64 hasher = XXHashFactory.fastestInstance().hash64(); fileBlob.parameters().add(new DataValue(blob)); - fileBlob.parameters().add(new Int32Value(success ? 0 : 1)); fileBlob.parameters().add(new Int64Value(hasher.hash(ByteBuffer.wrap(blob), 0))); + fileBlob.parameters().add(new Int32Value(success ? 0 : 1)); + fileBlob.parameters().add(new StringValue(success ? "OK" : errorDescription)); target.invokeSync(fileBlob, 600); } } diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java index 25652eb5ace..3ae6a8a1af9 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java @@ -198,7 +198,7 @@ public class RpcServer implements Runnable, ReloadListener, TenantListener { getSupervisor().addMethod(new Method("printStatistics", "", "s", this, "printStatistics") .methodDesc("printStatistics") .returnDesc(0, "statistics", "Statistics for server")); - getSupervisor().addMethod(new Method("serveFile", "s", "is", this, "serveFile")); + getSupervisor().addMethod(new Method("filedistribution.serveFile", "s", "is", this, "serveFile")); } /** |