summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/operation_sharding_state.cpp
diff options
context:
space:
mode:
authorGeert Bosch <geert@mongodb.com>2016-08-18 19:36:15 +0100
committerGeert Bosch <geert@mongodb.com>2016-08-22 17:04:08 +0100
commitc14515630a02136b60e49c8e15e7135cf8153497 (patch)
tree057758a3c991dc988f75e4df6a0e61789ad3f3e7 /src/mongo/db/s/operation_sharding_state.cpp
parente576de40f3629649c453f437ad18a2a86b433509 (diff)
downloadmongo-c14515630a02136b60e49c8e15e7135cf8153497.tar.gz
SERVER-24771 Use view namespace in cursors for aggregate/getMore
Diffstat (limited to 'src/mongo/db/s/operation_sharding_state.cpp')
-rw-r--r--src/mongo/db/s/operation_sharding_state.cpp5
1 files changed, 5 insertions, 0 deletions
diff --git a/src/mongo/db/s/operation_sharding_state.cpp b/src/mongo/db/s/operation_sharding_state.cpp
index b1ba9e0e16f..a940ffc01df 100644
--- a/src/mongo/db/s/operation_sharding_state.cpp
+++ b/src/mongo/db/s/operation_sharding_state.cpp
@@ -90,6 +90,11 @@ void OperationShardingState::setShardVersion(NamespaceString nss, ChunkVersion n
_hasVersion = true;
}
+void OperationShardingState::unsetShardVersion(NamespaceString nss) {
+ invariant(!_hasVersion || _ns == nss);
+ _clear();
+}
+
bool OperationShardingState::waitForMigrationCriticalSectionSignal(OperationContext* txn) {
// Must not block while holding a lock
invariant(!txn->lockState()->isLocked());