SERVER-45323 Make MigrationCoordinator persist the decision before sending the decision to itself and the recipient

1 files changed, 6 insertions, 0 deletions

diff --git a/src/mongo/db/s/migration_coordinator.cpp b/src/mongo/db/s/migration_coordinator.cpp
index 8b59fea4366..0ce9e9a5b18 100644
--- a/src/mongo/db/s/migration_coordinator.cpp
+++ b/src/mongo/db/s/migration_coordinator.cpp
@@ -79,6 +79,9 @@ void MigrationCoordinator::startMigration(OperationContext* opCtx, bool waitForD
 }
 
 void MigrationCoordinator::commitMigrationOnDonorAndRecipient(OperationContext* opCtx) {
+    LOG(0) << _logPrefix() << "Making commit decision durable";
+    migrationutil::persistCommitDecision(opCtx, _migrationInfo.getId());
+
     LOG(0) << _logPrefix() << "Deleting range deletion task on recipient";
     migrationutil::deleteRangeDeletionTaskOnRecipient(opCtx,
                                                       _migrationInfo.getRecipientShardId(),
@@ -91,6 +94,9 @@ void MigrationCoordinator::commitMigrationOnDonorAndRecipient(OperationContext*
 }
 
 void MigrationCoordinator::abortMigrationOnDonorAndRecipient(OperationContext* opCtx) {
+    LOG(0) << _logPrefix() << "Making abort decision durable";
+    migrationutil::persistAbortDecision(opCtx, _migrationInfo.getId());
+
     LOG(0) << _logPrefix() << "Deleting range deletion task on donor";
     migrationutil::deleteRangeDeletionTaskLocally(opCtx, _migrationInfo.getId());