diff options
Diffstat (limited to 'src/mongo/db/s/migration_destination_manager.cpp')
-rw-r--r-- | src/mongo/db/s/migration_destination_manager.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/mongo/db/s/migration_destination_manager.cpp b/src/mongo/db/s/migration_destination_manager.cpp index 3066f645590..c55e1e6fec9 100644 --- a/src/mongo/db/s/migration_destination_manager.cpp +++ b/src/mongo/db/s/migration_destination_manager.cpp @@ -291,7 +291,7 @@ MigrationDestinationManager::State MigrationDestinationManager::getState() const return _state; } -void MigrationDestinationManager::setState(State newState) { +void MigrationDestinationManager::_setState(State newState) { stdx::lock_guard<Latch> sl(_mutex); _state = newState; _stateChangedCV.notify_all(); @@ -1063,7 +1063,7 @@ void MigrationDestinationManager::_migrateDriver(OperationContext* outerOpCtx) { repl::OpTime lastOpApplied; { // 3. Initial bulk clone - setState(CLONE); + _setState(CLONE); _sessionMigration->start(opCtx->getServiceContext()); @@ -1177,7 +1177,7 @@ void MigrationDestinationManager::_migrateDriver(OperationContext* outerOpCtx) { { // 4. Do bulk of mods - setState(CATCHUP); + _setState(CATCHUP); while (true) { auto res = uassertStatusOKWithContext( @@ -1272,7 +1272,7 @@ void MigrationDestinationManager::_migrateDriver(OperationContext* outerOpCtx) { { // 5. Wait for commit - setState(STEADY); + _setState(STEADY); bool transferAfterCommit = false; while (getState() == STEADY || getState() == COMMIT_START) { @@ -1344,7 +1344,7 @@ void MigrationDestinationManager::_migrateDriver(OperationContext* outerOpCtx) { return; } - setState(DONE); + _setState(DONE); timing.done(6); migrateThreadHangAtStep6.pauseWhileSet(); |