diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-07-04 14:51:37 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-07-04 14:51:37 +0000 |
commit | f88ba160a85a3c326f3e89a0d31f10c9a27ca728 (patch) | |
tree | e86f6b362fa03219c2fddfaee5fb8943f42b13fa /storage | |
parent | b8e236091b22552fc0dea58ff1a038831b42a81d (diff) |
Control events-before-wakeup for mbus too.
Diffstat (limited to 'storage')
-rw-r--r-- | storage/src/vespa/storage/config/stor-communicationmanager.def | 3 | ||||
-rw-r--r-- | storage/src/vespa/storage/storageserver/communicationmanager.cpp | 1 |
2 files changed, 4 insertions, 0 deletions
diff --git a/storage/src/vespa/storage/config/stor-communicationmanager.def b/storage/src/vespa/storage/config/stor-communicationmanager.def index 93156c367d9..75a3344b618 100644 --- a/storage/src/vespa/storage/config/stor-communicationmanager.def +++ b/storage/src/vespa/storage/config/stor-communicationmanager.def @@ -42,6 +42,9 @@ mbus.num_network_threads int default=1 restart ## Any value below 1 will be 1. mbus.num_threads int default=4 restart +## The number of events in the queue of a network (FNET) thread before it is woken up. +mbus.events_before_wakeup int default=1 restart + ## Enable to use above thread pool for encoding replies ## False will use network(fnet) thread mbus.dispatch_on_encode bool default=true restart diff --git a/storage/src/vespa/storage/storageserver/communicationmanager.cpp b/storage/src/vespa/storage/storageserver/communicationmanager.cpp index ab1f72e85d2..a88c339052d 100644 --- a/storage/src/vespa/storage/storageserver/communicationmanager.cpp +++ b/storage/src/vespa/storage/storageserver/communicationmanager.cpp @@ -355,6 +355,7 @@ void CommunicationManager::configure(std::unique_ptr<CommunicationManagerConfig> params.setNumThreads(std::max(1, config->mbus.numThreads)); params.setNumNetworkThreads(std::max(1, config->mbus.numNetworkThreads)); params.setNumRpcTargets(std::max(1, config->mbus.numRpcTargets)); + params.events_before_wakeup(std::max(1, config->mbus.eventsBeforeWakeup)); params.setDispatchOnDecode(config->mbus.dispatchOnDecode); params.setDispatchOnEncode(config->mbus.dispatchOnEncode); params.setTcpNoDelay(config->mbus.tcpNoDelay); |