diff options
Diffstat (limited to 'src/mongo/db/s/move_primary_source_manager.cpp')
| -rw-r--r-- | src/mongo/db/s/move_primary_source_manager.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/db/s/move_primary_source_manager.cpp b/src/mongo/db/s/move_primary_source_manager.cpp index c4df7775f6a..2739c02ae8f 100644 --- a/src/mongo/db/s/move_primary_source_manager.cpp +++ b/src/mongo/db/s/move_primary_source_manager.cpp @@ -108,7 +108,7 @@ Status MovePrimarySourceManager::clone(OperationContext* opCtx) { auto scopedDss = DatabaseShardingState::assertDbLockedAndAcquire( opCtx, getNss().dbName(), DSSAcquisitionMode::kExclusive); - scopedDss->setMovePrimarySourceManager(opCtx, this); + scopedDss->setMovePrimaryInProgress(opCtx); } _state = kCloning; @@ -511,7 +511,7 @@ void MovePrimarySourceManager::_cleanup(OperationContext* opCtx) { auto scopedDss = DatabaseShardingState::assertDbLockedAndAcquire( opCtx, getNss().dbName(), DSSAcquisitionMode::kExclusive); - scopedDss->clearMovePrimarySourceManager(opCtx); + scopedDss->unsetMovePrimaryInProgress(opCtx); DatabaseHolder::get(opCtx)->clearDbInfo(opCtx, getNss().dbName()); // Leave the critical section if we're still registered. |