diff options
Diffstat (limited to 'src/mongo/db/s/move_chunk_command.cpp')
| -rw-r--r-- | src/mongo/db/s/move_chunk_command.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/mongo/db/s/move_chunk_command.cpp b/src/mongo/db/s/move_chunk_command.cpp index 37fdf0065f3..f818da93283 100644 --- a/src/mongo/db/s/move_chunk_command.cpp +++ b/src/mongo/db/s/move_chunk_command.cpp @@ -120,29 +120,29 @@ public: // where we might have changed a shard's host by removing/adding a shard with the same name. Grid::get(opCtx)->shardRegistry()->reload(opCtx); - auto scopedRegisterMigration = + auto scopedMigration = uassertStatusOK(shardingState->registerDonateChunk(moveChunkRequest)); Status status = {ErrorCodes::InternalError, "Uninitialized value"}; // Check if there is an existing migration running and if so, join it - if (scopedRegisterMigration.mustExecute()) { + if (scopedMigration.mustExecute()) { try { _runImpl(opCtx, moveChunkRequest); status = Status::OK(); } catch (const DBException& e) { status = e.toStatus(); } catch (const std::exception& e) { - scopedRegisterMigration.complete( + scopedMigration.signalComplete( {ErrorCodes::InternalError, str::stream() << "Severe error occurred while running moveChunk command: " << e.what()}); throw; } - scopedRegisterMigration.complete(status); + scopedMigration.signalComplete(status); } else { - status = scopedRegisterMigration.waitForCompletion(opCtx); + status = scopedMigration.waitForCompletion(opCtx); } if (status == ErrorCodes::ChunkTooBig) { |