diff options
Diffstat (limited to 'src/mongo/db/s/move_chunk_command.cpp')
| -rw-r--r-- | src/mongo/db/s/move_chunk_command.cpp | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/mongo/db/s/move_chunk_command.cpp b/src/mongo/db/s/move_chunk_command.cpp index 12e93857473..1e1f14335d8 100644 --- a/src/mongo/db/s/move_chunk_command.cpp +++ b/src/mongo/db/s/move_chunk_command.cpp @@ -248,7 +248,9 @@ public: // 3. - auto moveChunkStartStatus = chunkMoveState.start(shardKeyPattern); + const auto migrationSessionId = MigrationSessionId::generate(chunkMoveState.getFromShard(), + chunkMoveState.getToShard()); + auto moveChunkStartStatus = chunkMoveState.start(migrationSessionId, shardKeyPattern); if (!moveChunkStartStatus.isOK()) { warning() << moveChunkStartStatus.toString(); @@ -268,6 +270,7 @@ public: BSONObjBuilder recvChunkStartBuilder; recvChunkStartBuilder.append("_recvChunkStart", ns); + migrationSessionId.append(&recvChunkStartBuilder); recvChunkStartBuilder.append("from", chunkMoveState.getFromShardCS().toString()); recvChunkStartBuilder.append("fromShardName", chunkMoveState.getFromShard()); recvChunkStartBuilder.append("toShardName", chunkMoveState.getToShard()); @@ -466,7 +469,7 @@ public: return appendCommandStatus(result, Status(lockStatus.code(), msg)); } - uassertStatusOK(chunkMoveState.commitMigration()); + uassertStatusOK(chunkMoveState.commitMigration(migrationSessionId)); timing.done(5); MONGO_FAIL_POINT_PAUSE_WHILE_SET(moveChunkHangAtStep5); |