diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-07-07 09:12:10 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-07-07 09:12:10 +0000 |
commit | 6c5fbad5e8051ff2d09f5fd1a9c2f6035e1084df (patch) | |
tree | 252686305bb0118ec147d53d91fc01589cec150c /storage | |
parent | d458686d8ab70ce2bcd6e36fb39dab143da6b5e4 (diff) |
GC unused numThreads too.
Diffstat (limited to 'storage')
-rw-r--r-- | storage/src/vespa/storage/config/stor-communicationmanager.def | 4 | ||||
-rw-r--r-- | storage/src/vespa/storage/storageserver/communicationmanager.cpp | 1 |
2 files changed, 0 insertions, 5 deletions
diff --git a/storage/src/vespa/storage/config/stor-communicationmanager.def b/storage/src/vespa/storage/config/stor-communicationmanager.def index ba0368964c1..4c4c9ce615d 100644 --- a/storage/src/vespa/storage/config/stor-communicationmanager.def +++ b/storage/src/vespa/storage/config/stor-communicationmanager.def @@ -38,10 +38,6 @@ mbus.tcp_no_delay bool default=true restart ## Number of threads for network. mbus.num_network_threads int default=1 restart -## Number of workers threads for messagebus -## 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 diff --git a/storage/src/vespa/storage/storageserver/communicationmanager.cpp b/storage/src/vespa/storage/storageserver/communicationmanager.cpp index 16ee59bffb1..7fb6685a8b5 100644 --- a/storage/src/vespa/storage/storageserver/communicationmanager.cpp +++ b/storage/src/vespa/storage/storageserver/communicationmanager.cpp @@ -352,7 +352,6 @@ void CommunicationManager::configure(std::unique_ptr<CommunicationManagerConfig> LOG(debug, "setting up slobrok config from id: '%s", _configUri.getConfigId().c_str()); mbus::RPCNetworkParams params(_configUri); params.setConnectionExpireSecs(config->mbus.rpctargetcache.ttl); - 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)); |