summaryrefslogtreecommitdiff
path: root/src/mongo/db/s
diff options
context:
space:
mode:
authorCheahuychou Mao <cheahuychou.mao@mongodb.com>2020-01-30 00:09:44 -0500
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2020-01-30 22:57:07 +0000
commit9cda0c48d4f251f65639417396f06309e562e524 (patch)
treea2392772245b047652b7c0f18afc9d3f67e24d27 /src/mongo/db/s
parentb5f6ba41162d69984bf0c8a041d03c720a78d5bf (diff)
downloadmongo-9cda0c48d4f251f65639417396f06309e562e524.tar.gz
SERVER-45707 Test that range deletion tasks are eventually deleted even if collection is dropped before migration coordination is resumed
create mode 100644 jstests/sharding/delete_range_deletion_tasks_on_stepup_after_drop_collection.js
Diffstat (limited to 'src/mongo/db/s')
-rw-r--r--src/mongo/db/s/migration_util.cpp4
1 files changed, 4 insertions, 0 deletions
diff --git a/src/mongo/db/s/migration_util.cpp b/src/mongo/db/s/migration_util.cpp
index d98acf3f32d..f99f37ed79d 100644
--- a/src/mongo/db/s/migration_util.cpp
+++ b/src/mongo/db/s/migration_util.cpp
@@ -63,6 +63,8 @@ namespace mongo {
namespace migrationutil {
namespace {
+MONGO_FAIL_POINT_DEFINE(hangBeforeFilteringMetadataRefresh);
+
const char kSourceShard[] = "source";
const char kDestinationShard[] = "destination";
const char kIsDonorShard[] = "isDonorShard";
@@ -551,6 +553,8 @@ void resumeMigrationCoordinationsOnStepUp(ServiceContext* serviceContext) {
ensureChunkVersionIsGreaterThan(
opCtx, doc.getRange(), doc.getPreMigrationChunkVersion());
+ hangBeforeFilteringMetadataRefresh.pauseWhileSet();
+
refreshFilteringMetadataUntilSuccess(opCtx, doc.getNss());
auto refreshedMetadata = [&] {