diff options
author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2019-02-28 15:07:14 +0100 |
---|---|---|
committer | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2019-02-28 15:07:14 +0100 |
commit | c2298dbbd1d9fa2394c188060ff080895446f472 (patch) | |
tree | 5fcc32e32210b21c676cd04c331fc5c34c85f023 /configserver | |
parent | ac551a4c549975b2fad58207d613e5db4e7b9f71 (diff) |
Don't do request parsing on jrt transport thread
Parsing the slime request body should not be performed on the jrt
transport thread as this will reduce max throughput.
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; + } } |