diff options
author | Arne Juul <arnej@verizonmedia.com> | 2021-08-16 20:28:18 +0000 |
---|---|---|
committer | Arne Juul <arnej@verizonmedia.com> | 2021-08-16 20:28:18 +0000 |
commit | 4cecd3851fa611b9ea3203dbbf34114811915179 (patch) | |
tree | d3cd200e4878729fbb5a937c7c318caace970a21 /slobrok | |
parent | 7e29baa6a5902153d3041603c5ea3dc931591425 (diff) |
fix subscribe() calls to match guard names
Diffstat (limited to 'slobrok')
-rw-r--r-- | slobrok/src/vespa/slobrok/server/sbenv.cpp | 7 |
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()); } |