diff options
Diffstat (limited to 'src/mongo/db/s/resharding/resharding_donor_service.cpp')
| -rw-r--r-- | src/mongo/db/s/resharding/resharding_donor_service.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/mongo/db/s/resharding/resharding_donor_service.cpp b/src/mongo/db/s/resharding/resharding_donor_service.cpp index e3a82f24d7f..d0a81bb656d 100644 --- a/src/mongo/db/s/resharding/resharding_donor_service.cpp +++ b/src/mongo/db/s/resharding/resharding_donor_service.cpp @@ -90,7 +90,7 @@ Date_t getCurrentTime() { Timestamp generateMinFetchTimestamp(OperationContext* opCtx, const NamespaceString& sourceNss) { // Do a no-op write and use the OpTime as the minFetchTimestamp writeConflictRetry( - opCtx, "resharding donor minFetchTimestamp", NamespaceString::kRsOplogNamespace.ns(), [&] { + opCtx, "resharding donor minFetchTimestamp", NamespaceString::kRsOplogNamespace, [&] { AutoGetDb db(opCtx, sourceNss.dbName(), MODE_IX); Lock::CollectionLock collLock(opCtx, sourceNss, MODE_S); @@ -627,7 +627,7 @@ void ReshardingDonorService::DonorStateMachine:: auto oplog = generateOplogEntry(); writeConflictRetry( - rawOpCtx, "ReshardingBeginOplog", NamespaceString::kRsOplogNamespace.ns(), [&] { + rawOpCtx, "ReshardingBeginOplog", NamespaceString::kRsOplogNamespace, [&] { AutoGetOplog oplogWrite(rawOpCtx, OplogAccessMode::kWrite); WriteUnitOfWork wunit(rawOpCtx); const auto& oplogOpTime = repl::logOp(rawOpCtx, &oplog); @@ -744,7 +744,7 @@ void ReshardingDonorService::DonorStateMachine:: writeConflictRetry( rawOpCtx, "ReshardingBlockWritesOplog", - NamespaceString::kRsOplogNamespace.ns(), + NamespaceString::kRsOplogNamespace, [&] { AutoGetOplog oplogWrite(rawOpCtx, OplogAccessMode::kWrite); WriteUnitOfWork wunit(rawOpCtx); @@ -996,7 +996,7 @@ void ReshardingDonorService::DonorStateMachine::_updateDonorDocument( auto opCtx = _cancelableOpCtxFactory->makeOperationContext(&cc()); const auto& nss = NamespaceString::kDonorReshardingOperationsNamespace; - writeConflictRetry(opCtx.get(), "DonorStateMachine::_updateDonorDocument", nss.toString(), [&] { + writeConflictRetry(opCtx.get(), "DonorStateMachine::_updateDonorDocument", nss, [&] { auto coll = acquireCollection( opCtx.get(), CollectionAcquisitionRequest(NamespaceString(nss), @@ -1028,7 +1028,7 @@ void ReshardingDonorService::DonorStateMachine::_removeDonorDocument( auto opCtx = _cancelableOpCtxFactory->makeOperationContext(&cc()); const auto& nss = NamespaceString::kDonorReshardingOperationsNamespace; - writeConflictRetry(opCtx.get(), "DonorStateMachine::_removeDonorDocument", nss.toString(), [&] { + writeConflictRetry(opCtx.get(), "DonorStateMachine::_removeDonorDocument", nss, [&] { const auto coll = acquireCollection( opCtx.get(), CollectionAcquisitionRequest(NamespaceString(nss), |