diff options
Diffstat (limited to 'src/mongo/db/s/migration_util.cpp')
| -rw-r--r-- | src/mongo/db/s/migration_util.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/mongo/db/s/migration_util.cpp b/src/mongo/db/s/migration_util.cpp index 89b1a5d8f3a..2a821beb1f8 100644 --- a/src/mongo/db/s/migration_util.cpp +++ b/src/mongo/db/s/migration_util.cpp @@ -690,7 +690,8 @@ void notifyChangeStreamsOnRecipientFirstChunk(OperationContext* opCtx, auto const serviceContext = opCtx->getClient()->getServiceContext(); - UninterruptibleLockGuard noInterrupt(opCtx->lockState()); + // TODO (SERVER-71444): Fix to be interruptible or document exception. + UninterruptibleLockGuard noInterrupt(opCtx->lockState()); // NOLINT. AutoGetOplog oplogWrite(opCtx, OplogAccessMode::kWrite); writeConflictRetry( opCtx, "migrateChunkToNewShard", NamespaceString::kRsOplogNamespace.ns(), [&] { @@ -722,7 +723,8 @@ void notifyChangeStreamsOnDonorLastChunk(OperationContext* opCtx, auto const serviceContext = opCtx->getClient()->getServiceContext(); - UninterruptibleLockGuard noInterrupt(opCtx->lockState()); + // TODO (SERVER-71444): Fix to be interruptible or document exception. + UninterruptibleLockGuard noInterrupt(opCtx->lockState()); // NOLINT. AutoGetOplog oplogWrite(opCtx, OplogAccessMode::kWrite); writeConflictRetry( opCtx, "migrateLastChunkFromShard", NamespaceString::kRsOplogNamespace.ns(), [&] { |