summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorHarald Musum <musum@oath.com>2017-12-09 10:58:17 +0100
committerHarald Musum <musum@oath.com>2017-12-09 10:58:17 +0100
commitebe646e39c4227097b2f67e19fffb399e963fef2 (patch)
treee25b794edc878efabc744ffbf9ce49e21c5eb178 /configserver
parent46947a0782d08c2a58514f12ca788d7dfd9f11a2 (diff)
Fix some issues related to RPC methods for file distribution
Diffstat (limited to 'configserver')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java11
1 files changed, 4 insertions, 7 deletions
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 15147d522f3..a09087ad8d3 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
@@ -467,9 +467,6 @@ public class RpcServer implements Runnable, ReloadListener, TenantListener {
fileBlob.parameters().add(new StringValue(fileData.filename()));
fileBlob.parameters().add(new StringValue(fileData.type().name()));
fileBlob.parameters().add(new Int64Value(fileData.size()));
- fileBlob.parameters().add(new Int64Value(fileData.xxhash()));
- fileBlob.parameters().add(new Int32Value(status.getCode()));
- fileBlob.parameters().add(new StringValue(status.getDescription()));
target.invokeSync(fileBlob, 600);
if (fileBlob.isError()) {
log.warning("Failed delivering reference '" + fileData.fileReference().value() + "' with file '" + fileData.filename() + "' to " +
@@ -502,12 +499,12 @@ public class RpcServer implements Runnable, ReloadListener, TenantListener {
}
int retCode = request.returnValues().get(0).asInt32();
if (retCode != 0) {
- throw new IllegalArgumentException("Unknow error from target '" + target.toString() + "' during rpc call " + request.methodName());
+ throw new IllegalArgumentException("Unknown error from target '" + target.toString() + "' during rpc call " + request.methodName());
}
return request.returnValues().get(1).asInt32();
}
private void sendPart(int session, FileReference ref, int partId, byte [] buf) {
- Request request = new Request(FileReceiver.RECEIVE_EOF_METHOD);
+ Request request = new Request(FileReceiver.RECEIVE_PART_METHOD);
request.parameters().add(new StringValue(ref.value()));
request.parameters().add(new Int32Value(session));
request.parameters().add(new Int32Value(partId));
@@ -519,7 +516,7 @@ public class RpcServer implements Runnable, ReloadListener, TenantListener {
}
int retCode = request.returnValues().get(0).asInt32();
if (retCode != 0) {
- throw new IllegalArgumentException("Unknow error from target '" + target.toString() + "' during rpc call " + request.methodName());
+ throw new IllegalArgumentException("Unknown error from target '" + target.toString() + "' during rpc call " + request.methodName());
}
}
private void sendEof(int session, FileReferenceData fileData, FileServer.ReplayStatus status) {
@@ -536,7 +533,7 @@ public class RpcServer implements Runnable, ReloadListener, TenantListener {
}
int retCode = request.returnValues().get(0).asInt32();
if (retCode != 0) {
- throw new IllegalArgumentException("Unknow error from target '" + target.toString() + "' during rpc call " + request.methodName());
+ throw new IllegalArgumentException("Unknown error from target '" + target.toString() + "' during rpc call " + request.methodName());
}
}
}