diff options
| author | George Wangensteen <george.wangensteen@mongodb.com> | 2022-05-11 18:42:14 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-05-23 23:16:32 +0000 |
| commit | c904c1853594468bbf60cc330d89a5b89b0e6365 (patch) | |
| tree | e6cd5340879d1bb488cd6879d4ffa8a8ff223878 /src/mongo/db/s/migration_util.cpp | |
| parent | 10945bc699a008934c360b922cdd9ac5e6332af8 (diff) | |
| download | mongo-c904c1853594468bbf60cc330d89a5b89b0e6365.tar.gz | |
SERVER-66353 Add concurrency information to OperationContext::setAlwaysInterruptAtStepDownOrUp
Diffstat (limited to 'src/mongo/db/s/migration_util.cpp')
| -rw-r--r-- | src/mongo/db/s/migration_util.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/mongo/db/s/migration_util.cpp b/src/mongo/db/s/migration_util.cpp index 67bbaa75f2d..ee54cadb56b 100644 --- a/src/mongo/db/s/migration_util.cpp +++ b/src/mongo/db/s/migration_util.cpp @@ -372,7 +372,7 @@ ExecutorFuture<void> cleanUpRange(ServiceContext* serviceContext, } auto uniqueOpCtx = tc->makeOperationContext(); auto opCtx = uniqueOpCtx.get(); - opCtx->setAlwaysInterruptAtStepDownOrUp(); + opCtx->setAlwaysInterruptAtStepDownOrUp_UNSAFE(); const NamespaceString& nss = deletionTask.getNss(); @@ -450,7 +450,7 @@ ExecutorFuture<void> submitRangeDeletionTask(OperationContext* opCtx, tc->setSystemOperationKillableByStepdown(lk); } auto uniqueOpCtx = tc->makeOperationContext(); - uniqueOpCtx->setAlwaysInterruptAtStepDownOrUp(); + uniqueOpCtx->setAlwaysInterruptAtStepDownOrUp_UNSAFE(); LOGV2(55557, "cleanUpRange failed due to keyPattern shorter than range " @@ -517,7 +517,7 @@ void resubmitRangeDeletionsOnStepUp(ServiceContext* serviceContext) { } auto opCtx = tc->makeOperationContext(); - opCtx->setAlwaysInterruptAtStepDownOrUp(); + opCtx->setAlwaysInterruptAtStepDownOrUp_UNSAFE(); DBDirectClient client(opCtx.get()); FindCommandRequest findCommand(NamespaceString::kRangeDeletionNamespace); @@ -540,7 +540,7 @@ void resubmitRangeDeletionsOnStepUp(ServiceContext* serviceContext) { } auto opCtx = tc->makeOperationContext(); - opCtx->setAlwaysInterruptAtStepDownOrUp(); + opCtx->setAlwaysInterruptAtStepDownOrUp_UNSAFE(); submitPendingDeletions(opCtx.get()); }) |