summaryrefslogtreecommitdiffstats
path: root/storage
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-07-07 09:12:10 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2022-07-07 09:12:10 +0000
commit6c5fbad5e8051ff2d09f5fd1a9c2f6035e1084df (patch)
tree252686305bb0118ec147d53d91fc01589cec150c /storage
parentd458686d8ab70ce2bcd6e36fb39dab143da6b5e4 (diff)
GC unused numThreads too.
Diffstat (limited to 'storage')
-rw-r--r--storage/src/vespa/storage/config/stor-communicationmanager.def4
-rw-r--r--storage/src/vespa/storage/storageserver/communicationmanager.cpp1
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));