summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/migration_destination_manager.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/s/migration_destination_manager.cpp')
-rw-r--r--src/mongo/db/s/migration_destination_manager.cpp10
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();