diff options
author | Arne H Juul <arnej@yahooinc.com> | 2021-09-08 10:34:45 +0000 |
---|---|---|
committer | Arne H Juul <arnej@yahooinc.com> | 2021-09-08 11:23:22 +0000 |
commit | 6e0b70f672ff9706d33563bf6789a4fccf17a192 (patch) | |
tree | 9d192ca4d50f04040b1c3288b13f60fdfe80a81f /slobrok | |
parent | 8ede2f177da734be371f9dea4e7e503db4d111e5 (diff) |
skip diff between worlds when using new logic
Diffstat (limited to 'slobrok')
-rw-r--r-- | slobrok/src/vespa/slobrok/server/exchange_manager.cpp | 24 |
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()); |