diff options
| author | Kaloian Manassiev <kaloian.manassiev@mongodb.com> | 2021-01-13 10:19:10 -0500 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-01-13 19:20:47 +0000 |
| commit | d237b2fce711579fe24ea9c9dc2722604a16bbe1 (patch) | |
| tree | 5e8c9b3b62aadc66f1b4bf7a2ec4f1f380f52782 /src/mongo/db/s/migration_source_manager.cpp | |
| parent | e9832de6783c21520f05ff64ada4c488ff13f521 (diff) | |
| download | mongo-d237b2fce711579fe24ea9c9dc2722604a16bbe1.tar.gz | |
SERVER-53742 Do not try to waitForDelete if migration cleanup failed
Diffstat (limited to 'src/mongo/db/s/migration_source_manager.cpp')
| -rw-r--r-- | src/mongo/db/s/migration_source_manager.cpp | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/mongo/db/s/migration_source_manager.cpp b/src/mongo/db/s/migration_source_manager.cpp index a1ae8f973ed..298e45f3e50 100644 --- a/src/mongo/db/s/migration_source_manager.cpp +++ b/src/mongo/db/s/migration_source_manager.cpp @@ -543,8 +543,11 @@ Status MigrationSourceManager::commitChunkMetadataOnConfig() { "range"_attr = redact(range.toString()), "migrationId"_attr = _coordinator->getMigrationId()); - invariant(_cleanupCompleteFuture); - auto deleteStatus = _cleanupCompleteFuture->getNoThrow(_opCtx); + Status deleteStatus = _cleanupCompleteFuture + ? _cleanupCompleteFuture->getNoThrow(_opCtx) + : Status(ErrorCodes::Error(5089002), + "Not honouring the 'waitForDelete' request because migration coordinator " + "cleanup didn't succeed"); if (!deleteStatus.isOK()) { return {ErrorCodes::OrphanedRangeCleanUpFailed, orphanedRangeCleanUpErrMsg + redact(deleteStatus)}; |