diff options
Diffstat (limited to 'src/mongo/db/s/migration_coordinator.cpp')
| -rw-r--r-- | src/mongo/db/s/migration_coordinator.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/mongo/db/s/migration_coordinator.cpp b/src/mongo/db/s/migration_coordinator.cpp index a4fe84afb6d..97d24a6375c 100644 --- a/src/mongo/db/s/migration_coordinator.cpp +++ b/src/mongo/db/s/migration_coordinator.cpp @@ -33,6 +33,7 @@ #include "mongo/db/s/migration_coordinator.h" +#include "mongo/db/logical_clock.h" #include "mongo/db/logical_session_id_helpers.h" #include "mongo/db/s/migration_util.h" #include "mongo/db/s/range_deletion_task_gen.h" @@ -123,6 +124,8 @@ void MigrationCoordinator::startMigration(OperationContext* opCtx) { _waitForDelete ? CleanWhenEnum::kNow : CleanWhenEnum::kDelayed); donorDeletionTask.setPending(true); + const auto clusterTime = LogicalClock::get(opCtx)->getClusterTime(); + donorDeletionTask.setTimestamp(clusterTime.asTimestamp()); migrationutil::persistRangeDeletionTaskLocally( opCtx, donorDeletionTask, WriteConcerns::kMajorityWriteConcern); } @@ -223,6 +226,8 @@ SemiFuture<void> MigrationCoordinator::_commitMigrationOnDonorAndRecipient( _migrationInfo.getDonorShardId(), _migrationInfo.getRange(), _waitForDelete ? CleanWhenEnum::kNow : CleanWhenEnum::kDelayed); + const auto clusterTime = LogicalClock::get(opCtx)->getClusterTime(); + deletionTask.setTimestamp(clusterTime.asTimestamp()); return migrationutil::submitRangeDeletionTask(opCtx, deletionTask).semi(); } |