aboutsummaryrefslogtreecommitdiffstats
path: root/slobrok
diff options
context:
space:
mode:
authorArne H Juul <arnej@yahooinc.com>2021-09-08 10:34:45 +0000
committerArne H Juul <arnej@yahooinc.com>2021-09-08 11:23:22 +0000
commit6e0b70f672ff9706d33563bf6789a4fccf17a192 (patch)
tree9d192ca4d50f04040b1c3288b13f60fdfe80a81f /slobrok
parent8ede2f177da734be371f9dea4e7e503db4d111e5 (diff)
skip diff between worlds when using new logic
Diffstat (limited to 'slobrok')
-rw-r--r--slobrok/src/vespa/slobrok/server/exchange_manager.cpp24
1 files changed, 13 insertions, 11 deletions
diff --git a/slobrok/src/vespa/slobrok/server/exchange_manager.cpp b/slobrok/src/vespa/slobrok/server/exchange_manager.cpp
index 18da01ee526..ccfb8d3bd63 100644
--- a/slobrok/src/vespa/slobrok/server/exchange_manager.cpp
+++ b/slobrok/src/vespa/slobrok/server/exchange_manager.cpp
@@ -127,17 +127,19 @@ ExchangeManager::diffLists(const ServiceMappingList &lhs, const ServiceMappingLi
void
ExchangeManager::healthCheck()
{
- auto oldWorldServices = env().rpcServerMap().allManaged();
- ServiceMappingList oldWorldList;
- for (const auto *nsp : oldWorldServices) {
- oldWorldList.emplace_back(nsp->getName(), nsp->getSpec());
- }
- std::sort(oldWorldList.begin(), oldWorldList.end());
auto newWorldList = env().consensusMap().currentConsensus();
- vespalib::string diff = diffLists(oldWorldList, newWorldList);
- if (! diff.empty()) {
- LOG(warning, "Diff from old world rpcServerMap to new world consensus map: %s",
- diff.c_str());
+ if (! _env.useNewLogic()) {
+ auto oldWorldServices = env().rpcServerMap().allManaged();
+ ServiceMappingList oldWorldList;
+ for (const auto *nsp : oldWorldServices) {
+ oldWorldList.emplace_back(nsp->getName(), nsp->getSpec());
+ }
+ std::sort(oldWorldList.begin(), oldWorldList.end());
+ vespalib::string diff = diffLists(oldWorldList, newWorldList);
+ if (! diff.empty()) {
+ LOG(warning, "Diff from old world rpcServerMap to new world consensus map: %s",
+ diff.c_str());
+ }
}
for (const auto & [ name, partner ] : _partners) {
partner->maybeStartFetch();
@@ -145,7 +147,7 @@ ExchangeManager::healthCheck()
auto remoteList = partner->remoteMap().allMappings();
// 0 is expected (when remote is down)
if (remoteList.size() != 0) {
- diff = diffLists(newWorldList, remoteList);
+ vespalib::string diff = diffLists(newWorldList, remoteList);
if (! diff.empty()) {
LOG(warning, "Diff from consensus map to peer slobrok mirror: %s",
diff.c_str());