aboutsummaryrefslogtreecommitdiffstats
path: root/slobrok
diff options
context:
space:
mode:
authorArne Juul <arnej@verizonmedia.com>2021-08-16 20:28:18 +0000
committerArne Juul <arnej@verizonmedia.com>2021-08-16 20:28:18 +0000
commit4cecd3851fa611b9ea3203dbbf34114811915179 (patch)
treed3cd200e4878729fbb5a937c7c318caace970a21 /slobrok
parent7e29baa6a5902153d3041603c5ea3dc931591425 (diff)
fix subscribe() calls to match guard names
Diffstat (limited to 'slobrok')
-rw-r--r--slobrok/src/vespa/slobrok/server/sbenv.cpp7
1 files changed, 4 insertions, 3 deletions
diff --git a/slobrok/src/vespa/slobrok/server/sbenv.cpp b/slobrok/src/vespa/slobrok/server/sbenv.cpp
index d7cd9556b9f..8267d044cfb 100644
--- a/slobrok/src/vespa/slobrok/server/sbenv.cpp
+++ b/slobrok/src/vespa/slobrok/server/sbenv.cpp
@@ -116,9 +116,10 @@ SBEnv::SBEnv(const ConfigShim &shim)
_rpcsrvmap()
{
srandom(time(nullptr) ^ getpid());
- _localMonitorSubscription = MapSubscription::subscribe(_rpcsrvmap.proxy(), _globalVisibleHistory);
- _consensusSubscription = MapSubscription::subscribe(_rpcsrvmap.proxy(), _localRpcMonitorMap);
- _globalHistorySubscription = MapSubscription::subscribe(_localRpcMonitorMap.dispatcher(), _consensusMap);
+ _localMonitorSubscription = MapSubscription::subscribe(_rpcsrvmap.proxy(), _localRpcMonitorMap);
+ _consensusSubscription = MapSubscription::subscribe(_localRpcMonitorMap.dispatcher(), _consensusMap);
+ // TODO: use consensus as source here:
+ _globalHistorySubscription = MapSubscription::subscribe(_rpcsrvmap.proxy(), _globalVisibleHistory);
_rpcHooks.initRPC(getSupervisor());
}