diff options
Diffstat (limited to 'configserver')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/rpc/GetConfigProcessor.java | 1 | ||||
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java | 7 |
2 files changed, 5 insertions, 3 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/GetConfigProcessor.java b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/GetConfigProcessor.java index db863064834..a7c04f33d5f 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/GetConfigProcessor.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/GetConfigProcessor.java @@ -141,6 +141,7 @@ class GetConfigProcessor implements Runnable { } @Override public void run() { + rpcServer.hostLivenessTracker().receivedRequestFrom(request.getClientHostName()); Pair<GetConfigContext, Long> delayed = getConfig(request); if (delayed != null) { 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 e8abecc3236..061a3b3302b 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 @@ -152,9 +152,7 @@ public class RpcServer implements Runnable, ReloadListener, TenantListener { log.log(LogLevel.SPAM, getConfigMethodName); } req.detach(); - JRTServerConfigRequestV3 request = JRTServerConfigRequestV3.createFromRequest(req); - addToRequestQueue(request); - hostLivenessTracker.receivedRequestFrom(request.getClientHostName()); + addToRequestQueue(JRTServerConfigRequestV3.createFromRequest(req)); } /** @@ -560,4 +558,7 @@ public class RpcServer implements Runnable, ReloadListener, TenantListener { req.returnValues().add(new Int32Value(0)); } + HostLivenessTracker hostLivenessTracker() { + return hostLivenessTracker; + } } |