summaryrefslogtreecommitdiffstats
path: root/slobrok
diff options
context:
space:
mode:
authorArne H Juul <arnej27959@users.noreply.github.com>2021-09-17 14:32:07 +0200
committerGitHub <noreply@github.com>2021-09-17 14:32:07 +0200
commit0dd24fccd012608867b9ff0c7378044855d99cdb (patch)
tree760d3b37efcf46dcc4409fa9661ade131bd393cb /slobrok
parent52d29c6357b238844cb82df3c5eb0094aed74e1a (diff)
parentf89337f7d97e958a9c9797a80cac82208157c0fc (diff)
Merge pull request #19191 from vespa-engine/arnej/always-new-logic
no need to check useNewLogic() here
Diffstat (limited to 'slobrok')
-rw-r--r--slobrok/src/vespa/slobrok/server/sbenv.cpp11
1 files changed, 1 insertions, 10 deletions
diff --git a/slobrok/src/vespa/slobrok/server/sbenv.cpp b/slobrok/src/vespa/slobrok/server/sbenv.cpp
index 4bd55ee67f4..d1f60b85681 100644
--- a/slobrok/src/vespa/slobrok/server/sbenv.cpp
+++ b/slobrok/src/vespa/slobrok/server/sbenv.cpp
@@ -121,20 +121,11 @@ SBEnv::SBEnv(const ConfigShim &shim, bool)
_exchanger(*this, _rpcsrvmap),
_rpcsrvmap()
{
- if (useNewLogic()) {
- srandom(time(nullptr) ^ getpid());
- // note: feedback loop between these two:
- _localMonitorSubscription = MapSubscription::subscribe(_consensusMap, _localRpcMonitorMap);
- _consensusSubscription = MapSubscription::subscribe(_localRpcMonitorMap.dispatcher(), _consensusMap);
- _globalHistorySubscription = MapSubscription::subscribe(_consensusMap, _globalVisibleHistory);
- _rpcHooks.initRPC(getSupervisor());
- return;
- }
srandom(time(nullptr) ^ getpid());
// note: feedback loop between these two:
_localMonitorSubscription = MapSubscription::subscribe(_consensusMap, _localRpcMonitorMap);
_consensusSubscription = MapSubscription::subscribe(_localRpcMonitorMap.dispatcher(), _consensusMap);
- _globalHistorySubscription = MapSubscription::subscribe(_rpcsrvmap.proxy(), _globalVisibleHistory);
+ _globalHistorySubscription = MapSubscription::subscribe(_consensusMap, _globalVisibleHistory);
_rpcHooks.initRPC(getSupervisor());
}