summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorBjørn Christian Seime <bjorncs@verizonmedia.com>2019-02-28 15:07:14 +0100
committerBjørn Christian Seime <bjorncs@verizonmedia.com>2019-02-28 15:07:14 +0100
commitc2298dbbd1d9fa2394c188060ff080895446f472 (patch)
tree5fcc32e32210b21c676cd04c331fc5c34c85f023 /configserver
parentac551a4c549975b2fad58207d613e5db4e7b9f71 (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.java1
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java7
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;
+ }
}