diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-11-30 09:12:36 +0000 |
|---|---|---|
| committer | Henning Baldersheim <balder@yahoo-inc.com> | 2020-11-30 09:12:36 +0000 |
| commit | b54e1aecb0317e7381fbba262bcb29d55af85923 (patch) | |
| tree | 567cba69faa3c401a5bfba7b3094eccd44c2ce24 /container-messagebus | |
| parent | 8001f2c4cf42344178cc4ecb0c695ef701b2bbce (diff) | |
A configurable limit for waking up fnet thread
Diffstat (limited to 'container-messagebus')
2 files changed, 4 insertions, 0 deletions
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 |