From b54e1aecb0317e7381fbba262bcb29d55af85923 Mon Sep 17 00:00:00 2001 From: Henning Baldersheim Date: Mon, 30 Nov 2020 09:12:36 +0000 Subject: A configurable limit for waking up fnet thread --- .../main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java | 1 + .../resources/configdefinitions/container.jdisc.container-mbus.def | 3 +++ 2 files changed, 4 insertions(+) (limited to 'container-messagebus') diff --git a/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java b/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java index 68b1f5aa5db..795278bca84 100644 --- a/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java +++ b/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java @@ -123,6 +123,7 @@ public final class SessionCache extends AbstractComponent { .setListenPort(mbusConfig.port()) .setNumTargetsPerSpec(mbusConfig.numconnectionspertarget()) .setNumNetworkThreads(mbusConfig.numthreads()) + .setWakeupTriggerCount(mbusConfig.wakeup_trigger_count()) .setOptimization(RPCNetworkParams.Optimization.valueOf(mbusConfig.optimize_for().name())); return SharedMessageBus.newInstance(mbusParams, netParams); } diff --git a/container-messagebus/src/main/resources/configdefinitions/container.jdisc.container-mbus.def b/container-messagebus/src/main/resources/configdefinitions/container.jdisc.container-mbus.def index 9aef2b32a66..40557f00dfb 100644 --- a/container-messagebus/src/main/resources/configdefinitions/container.jdisc.container-mbus.def +++ b/container-messagebus/src/main/resources/configdefinitions/container.jdisc.container-mbus.def @@ -15,6 +15,9 @@ numthreads int default=2 # Optimize for latency, or throughput. optimize_for enum {LATENCY, THROUGHPUT} default=LATENCY +# Number of writeevents before triggering wakeup of network thread. +wakeup_trigger_count int default=1 + # Everying below is deprecated and will go away very soon. # Dynamic throttling is used, and works better than anything else. maxpendingcount int default=2048 -- cgit v1.2.3