summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/sharded_agg_helpers.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/sharded_agg_helpers.h')
-rw-r--r--src/mongo/db/pipeline/sharded_agg_helpers.h8
1 files changed, 2 insertions, 6 deletions
diff --git a/src/mongo/db/pipeline/sharded_agg_helpers.h b/src/mongo/db/pipeline/sharded_agg_helpers.h
index 13a20fee607..c63ac997a32 100644
--- a/src/mongo/db/pipeline/sharded_agg_helpers.h
+++ b/src/mongo/db/pipeline/sharded_agg_helpers.h
@@ -245,13 +245,9 @@ auto shardVersionRetry(OperationContext* opCtx,
str::stream() << "StaleConfig error on unexpected namespace. Expected "
<< nss << ", received " << staleInfo->getNss());
catalogCache->invalidateShardOrEntireCollectionEntryForShardedCollection(
- opCtx,
- nss,
- staleInfo->getVersionWanted(),
- staleInfo->getVersionReceived(),
- staleInfo->getShardId());
+ nss, staleInfo->getVersionWanted(), staleInfo->getShardId());
} else {
- catalogCache->onEpochChange(nss);
+ catalogCache->invalidateCollectionEntry_LINEARIZABLE(nss);
}
if (!logAndTestMaxRetries(e)) {
throw;