summaryrefslogtreecommitdiff
path: root/src/mongo
diff options
context:
space:
mode:
authorSilvia Surroca <silvia.surroca@mongodb.com>2022-06-03 12:22:59 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-06-03 13:04:04 +0000
commit69d7a7172fef4e1ef07322aa0122e3357c859a91 (patch)
tree6abe30acf15fab0ab436aadf1061293491de8cb1 /src/mongo
parentcc541819baf3d798f8f0da1edf6f9beda10961a7 (diff)
downloadmongo-69d7a7172fef4e1ef07322aa0122e3357c859a91.tar.gz
SERVER-63314 Remove unused fail points in migration_util.cpp
Diffstat (limited to 'src/mongo')
-rw-r--r--src/mongo/db/s/migration_util.cpp7
1 files changed, 0 insertions, 7 deletions
diff --git a/src/mongo/db/s/migration_util.cpp b/src/mongo/db/s/migration_util.cpp
index a2ec056f48d..bd8600c1518 100644
--- a/src/mongo/db/s/migration_util.cpp
+++ b/src/mongo/db/s/migration_util.cpp
@@ -93,13 +93,10 @@ MONGO_FAIL_POINT_DEFINE(hangInRefreshFilteringMetadataUntilSuccessInterruptible)
MONGO_FAIL_POINT_DEFINE(hangInRefreshFilteringMetadataUntilSuccessThenSimulateErrorUninterruptible);
MONGO_FAIL_POINT_DEFINE(hangInPersistMigrateCommitDecisionInterruptible);
MONGO_FAIL_POINT_DEFINE(hangInPersistMigrateCommitDecisionThenSimulateErrorUninterruptible);
-MONGO_FAIL_POINT_DEFINE(hangInPersistMigrateAbortDecisionInterruptible);
MONGO_FAIL_POINT_DEFINE(hangInPersistMigrateAbortDecisionThenSimulateErrorUninterruptible);
MONGO_FAIL_POINT_DEFINE(hangInDeleteRangeDeletionOnRecipientInterruptible);
MONGO_FAIL_POINT_DEFINE(hangInDeleteRangeDeletionOnRecipientThenSimulateErrorUninterruptible);
-MONGO_FAIL_POINT_DEFINE(hangInDeleteRangeDeletionLocallyInterruptible);
MONGO_FAIL_POINT_DEFINE(hangInDeleteRangeDeletionLocallyThenSimulateErrorUninterruptible);
-MONGO_FAIL_POINT_DEFINE(hangInReadyRangeDeletionOnRecipientInterruptible);
MONGO_FAIL_POINT_DEFINE(hangInReadyRangeDeletionOnRecipientThenSimulateErrorUninterruptible);
MONGO_FAIL_POINT_DEFINE(hangInReadyRangeDeletionLocallyInterruptible);
MONGO_FAIL_POINT_DEFINE(hangInReadyRangeDeletionLocallyThenSimulateErrorUninterruptible);
@@ -845,7 +842,6 @@ void persistAbortDecision(OperationContext* opCtx,
const MigrationCoordinatorDocument& migrationDoc) {
invariant(migrationDoc.getDecision() && *migrationDoc.getDecision() == DecisionEnum::kAborted);
- hangInPersistMigrateAbortDecisionInterruptible.pauseWhileSet(opCtx);
try {
PersistentTaskStore<MigrationCoordinatorDocument> store(
NamespaceString::kMigrationCoordinatorsNamespace);
@@ -891,7 +887,6 @@ void deleteRangeDeletionTaskOnRecipient(OperationContext* opCtx,
void deleteRangeDeletionTaskLocally(OperationContext* opCtx,
const UUID& deletionTaskId,
const WriteConcernOptions& writeConcern) {
- hangInDeleteRangeDeletionLocallyInterruptible.pauseWhileSet(opCtx);
PersistentTaskStore<RangeDeletionTask> store(NamespaceString::kRangeDeletionNamespace);
store.remove(opCtx, BSON(RangeDeletionTask::kIdFieldName << deletionTaskId), writeConcern);
@@ -917,8 +912,6 @@ void markAsReadyRangeDeletionTaskOnRecipient(OperationContext* opCtx,
retryIdempotentWorkAsPrimaryUntilSuccessOrStepdown(
opCtx, "ready remote range deletion", [&](OperationContext* newOpCtx) {
- hangInReadyRangeDeletionOnRecipientInterruptible.pauseWhileSet(newOpCtx);
-
try {
sendWriteCommandToRecipient(
newOpCtx,