diff options
author | Arne H Juul <arnej27959@users.noreply.github.com> | 2021-09-17 14:32:07 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-09-17 14:32:07 +0200 |
commit | 0dd24fccd012608867b9ff0c7378044855d99cdb (patch) | |
tree | 760d3b37efcf46dcc4409fa9661ade131bd393cb /slobrok | |
parent | 52d29c6357b238844cb82df3c5eb0094aed74e1a (diff) | |
parent | f89337f7d97e958a9c9797a80cac82208157c0fc (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.cpp | 11 |
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()); } |