diff options
| author | Arne Juul <arnej@verizonmedia.com> | 2021-08-19 11:03:05 +0000 |
|---|---|---|
| committer | Arne Juul <arnej@verizonmedia.com> | 2021-08-20 10:27:45 +0000 |
| commit | 665b3ff09c7d6141c79d19b6791a8079c1c6fe77 (patch) | |
| tree | 762bd53682c26744b02f9f0331cdb13f9ea5fd8d /slobrok | |
| parent | 5cd9ae6578cb7a48b67d512d9991257dc15ea037 (diff) | |
stop listening to events from the old RpcServerMap, make feedback loop instead
Diffstat (limited to 'slobrok')
| -rw-r--r-- | slobrok/src/vespa/slobrok/server/sbenv.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/slobrok/src/vespa/slobrok/server/sbenv.cpp b/slobrok/src/vespa/slobrok/server/sbenv.cpp index 1b52b85f736..cf612a187bb 100644 --- a/slobrok/src/vespa/slobrok/server/sbenv.cpp +++ b/slobrok/src/vespa/slobrok/server/sbenv.cpp @@ -116,7 +116,8 @@ SBEnv::SBEnv(const ConfigShim &shim) _rpcsrvmap() { srandom(time(nullptr) ^ getpid()); - _localMonitorSubscription = MapSubscription::subscribe(_rpcsrvmap.proxy(), _localRpcMonitorMap); + // note: feedback loop between these two: + _localMonitorSubscription = MapSubscription::subscribe(_consensusMap, _localRpcMonitorMap); _consensusSubscription = MapSubscription::subscribe(_localRpcMonitorMap.dispatcher(), _consensusMap); // TODO: use consensus as source here: _globalHistorySubscription = MapSubscription::subscribe(_rpcsrvmap.proxy(), _globalVisibleHistory); |