summaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/search/dispatch/rpc
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@gmail.com>2022-05-18 17:26:10 +0200
committerJon Bratseth <bratseth@gmail.com>2022-05-18 17:26:10 +0200
commit0217d33b34c7841e4e8476bb301b81c97ba208fa (patch)
treef616b6ca46cdefbadcddb845b7d0c365fef7df77 /container-search/src/main/java/com/yahoo/search/dispatch/rpc
parenta7ee9c1ba3b65fea3866dcb95e4ceb1d84ca0f4d (diff)
No functional changes
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/rpc')
-rw-r--r--container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcPing.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcPing.java b/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcPing.java
index 32706d2f2c1..8e99f4948ce 100644
--- a/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcPing.java
+++ b/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcPing.java
@@ -67,7 +67,7 @@ public class RpcPing implements Pinger, Client.ResponseReceiver {
var ping = SearchProtocol.MonitorRequest.newBuilder().build().toByteArray();
double timeoutSeconds = ((double) clusterMonitor.getConfiguration().getRequestTimeout()) / 1000.0;
Compressor.Compression compressionResult = resourcePool.compressor().compress(PING_COMPRESSION, ping);
- connection.request(RPC_METHOD, compressionResult.type(), ping.length, compressionResult.data(),this, timeoutSeconds);
+ connection.request(RPC_METHOD, compressionResult.type(), ping.length, compressionResult.data(), this, timeoutSeconds);
}
private Pong decodeReply(ProtobufResponse response) throws InvalidProtocolBufferException {
@@ -91,7 +91,7 @@ public class RpcPing implements Pinger, Client.ResponseReceiver {
if (node.isLastReceivedPong(pingSequenceId)) {
pongHandler.handle(toPong(response));
} else {
- //TODO Reduce to debug or remove once we have enumerated what happens here.
+ // TODO: Reduce to debug or remove once we have enumerated what happens here.
log.info("Pong " + pingSequenceId + " from node " + node.key() + " in group " + node.group() +
" with hostname " + node.hostname() + " received too late, latest is " + node.getLastReceivedPongId());
}