Details
-
Task
-
Resolution: Duplicate
-
Major - P3
-
None
-
None
-
None
-
Sharding 2018-04-09
Description
This logic is implemented in several places of cluster_find and cluster_aggregate
if (isSnapshotRead) {
|
std::set<ShardId> shardIds = {shardId};
|
atClusterTime = computeAtClusterTime(opCtx, shardIds);
|
bool isSameShardIds = verifyTargetedShardsAtClusterTime(opCtx, shardIds, atClusterTime);
|
if (!isSameShardIds) { // use the current clusterTime if chunks moved
|
atClusterTime = LogicalClock::get(opCtx)->getClusterTime();
|
}
|
}
|
Build a helper to keep it in one place.
Attachments
Issue Links
- duplicates
-
SERVER-33027 compute atClusterTime
-
- Closed
-