summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/mongo/s/client/version_manager.cpp9
1 files changed, 4 insertions, 5 deletions
diff --git a/src/mongo/s/client/version_manager.cpp b/src/mongo/s/client/version_manager.cpp
index 8ad759b2b48..69a4ab67b5a 100644
--- a/src/mongo/s/client/version_manager.cpp
+++ b/src/mongo/s/client/version_manager.cpp
@@ -266,11 +266,10 @@ bool checkShardVersion(OperationContext* opCtx,
auto const catalogCache = Grid::get(opCtx)->catalogCache();
- if (authoritative) {
- Grid::get(opCtx)->catalogCache()->onEpochChange(nss);
- }
+ auto routingInfoStatus = authoritative
+ ? catalogCache->getCollectionRoutingInfoWithRefresh(opCtx, nss)
+ : catalogCache->getCollectionRoutingInfo(opCtx, nss);
- auto routingInfoStatus = catalogCache->getCollectionRoutingInfo(opCtx, nss);
if (!routingInfoStatus.isOK()) {
return false;
}
@@ -380,7 +379,7 @@ bool checkShardVersion(OperationContext* opCtx,
return true;
}
- Grid::get(opCtx)->catalogCache()->onEpochChange(nss);
+ (void)catalogCache->getCollectionRoutingInfoWithRefresh(opCtx, nss);
const int maxNumTries = 7;
if (tryNumber < maxNumTries) {