diff options
author | Abdul Qadeer <abdul.qadeer@mongodb.com> | 2022-06-14 21:15:42 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-06-14 22:05:04 +0000 |
commit | 01eb71cdb1ec643de2dacf439814e46b6ca0650b (patch) | |
tree | d1be5baa3775b505a276ca2d8ef98dc8b27fcd8c /src/mongo/db/s/resharding/resharding_recipient_service.cpp | |
parent | 731cfef274177f5a2df4b5d700ae6d62a4e54abe (diff) | |
download | mongo-01eb71cdb1ec643de2dacf439814e46b6ca0650b.tar.gz |
SERVER-50729 Wrap resharding_util in resharding namespace
Diffstat (limited to 'src/mongo/db/s/resharding/resharding_recipient_service.cpp')
-rw-r--r-- | src/mongo/db/s/resharding/resharding_recipient_service.cpp | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/mongo/db/s/resharding/resharding_recipient_service.cpp b/src/mongo/db/s/resharding/resharding_recipient_service.cpp index d64e180304d..f52e3b8a3a7 100644 --- a/src/mongo/db/s/resharding/resharding_recipient_service.cpp +++ b/src/mongo/db/s/resharding/resharding_recipient_service.cpp @@ -728,8 +728,8 @@ ExecutorFuture<void> ReshardingRecipientService::RecipientStateMachine:: .then([this, &factory] { auto opCtx = factory.makeOperationContext(&cc()); for (const auto& donor : _donorShards) { - auto stashNss = - getLocalConflictStashNamespace(_metadata.getSourceUUID(), donor.getShardId()); + auto stashNss = resharding::getLocalConflictStashNamespace( + _metadata.getSourceUUID(), donor.getShardId()); AutoGetCollection stashColl(opCtx.get(), stashNss, MODE_IS); uassert(5356800, "Resharding completed with non-empty stash collections", @@ -902,7 +902,7 @@ void ReshardingRecipientService::RecipientStateMachine::_transitionToError( Status abortReason, const CancelableOperationContextFactory& factory) { auto newRecipientCtx = _recipientCtx; newRecipientCtx.setState(RecipientStateEnum::kError); - emplaceTruncatedAbortReasonIfExists(newRecipientCtx, abortReason); + resharding::emplaceTruncatedAbortReasonIfExists(newRecipientCtx, abortReason); _transitionState(std::move(newRecipientCtx), boost::none, boost::none, factory); } @@ -1168,10 +1168,10 @@ void ReshardingRecipientService::RecipientStateMachine::_restoreMetrics( progressDocList; for (const auto& donor : _donorShards) { { - AutoGetCollection oplogBufferColl( - opCtx.get(), - getLocalOplogBufferNamespace(_metadata.getSourceUUID(), donor.getShardId()), - MODE_IS); + AutoGetCollection oplogBufferColl(opCtx.get(), + resharding::getLocalOplogBufferNamespace( + _metadata.getSourceUUID(), donor.getShardId()), + MODE_IS); if (oplogBufferColl) { oplogEntriesFetched += oplogBufferColl->numRecords(opCtx.get()); } |