diff options
Diffstat (limited to 'src/mongo/db/s/migration_util_test.cpp')
-rw-r--r-- | src/mongo/db/s/migration_util_test.cpp | 23 |
1 files changed, 23 insertions, 0 deletions
diff --git a/src/mongo/db/s/migration_util_test.cpp b/src/mongo/db/s/migration_util_test.cpp index e6e4deaebbd..2aafa4e6c5f 100644 --- a/src/mongo/db/s/migration_util_test.cpp +++ b/src/mongo/db/s/migration_util_test.cpp @@ -378,6 +378,29 @@ TEST_F(MigrationUtilsTest, TestInvalidUUID) { using SubmitRangeDeletionTaskTest = MigrationUtilsTest; +TEST_F(SubmitRangeDeletionTaskTest, + FailsAndDeletesTaskIfFilteringMetadataIsUnknownEvenAfterRefresh) { + auto opCtx = operationContext(); + + const auto uuid = UUID::gen(); + auto deletionTask = createDeletionTask(kNss, uuid, 0, 10); + + PersistentTaskStore<RangeDeletionTask> store(opCtx, NamespaceString::kRangeDeletionNamespace); + store.add(opCtx, deletionTask); + ASSERT_EQ(store.count(opCtx), 1); + + // Make the refresh triggered by submitting the task return an empty result. + auto result = stdx::async(stdx::launch::async, + [this, uuid] { respondToMetadataRefreshRequestsWithError(); }); + + auto submitTaskFuture = migrationutil::submitRangeDeletionTask(opCtx, deletionTask); + + // The task should not have been submitted, and the task's entry should have been removed from + // the persistent store. + ASSERT_FALSE(submitTaskFuture.get(opCtx)); + ASSERT_EQ(store.count(opCtx), 0); +} + TEST_F(SubmitRangeDeletionTaskTest, SucceedsIfFilteringMetadataUUIDMatchesTaskUUID) { auto opCtx = operationContext(); |