summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/rename_collection_participant_service.cpp
diff options
context:
space:
mode:
authorPierlauro Sciarelli <pierlauro.sciarelli@mongodb.com>2021-12-24 08:50:15 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-12-24 09:15:11 +0000
commitebe76b776d7f183d8d7d0df9db860abe273b8aad (patch)
tree1cc074dc3b3684804e2e53ee7567e8785b49d76f /src/mongo/db/s/rename_collection_participant_service.cpp
parent9766c982d67c2a8584e329f024d702d8e2c8138e (diff)
downloadmongo-ebe76b776d7f183d8d7d0df9db860abe273b8aad.tar.gz
SERVER-62243 Wait for vector clock document majority-commit without timeout
Diffstat (limited to 'src/mongo/db/s/rename_collection_participant_service.cpp')
-rw-r--r--src/mongo/db/s/rename_collection_participant_service.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/s/rename_collection_participant_service.cpp b/src/mongo/db/s/rename_collection_participant_service.cpp
index 568534c83cd..62da2326850 100644
--- a/src/mongo/db/s/rename_collection_participant_service.cpp
+++ b/src/mongo/db/s/rename_collection_participant_service.cpp
@@ -198,12 +198,12 @@ void RenameParticipantInstance::_enterPhase(Phase newPhase) {
PersistentTaskStore<StateDoc> store(NamespaceString::kShardingRenameParticipantsNamespace);
if (_doc.getPhase() == Phase::kUnset) {
- store.add(opCtx.get(), newDoc, WriteConcerns::kMajorityWriteConcern);
+ store.add(opCtx.get(), newDoc, WriteConcerns::kMajorityWriteConcernShardingTimeout);
} else {
store.update(opCtx.get(),
BSON(StateDoc::kFromNssFieldName << fromNss().ns()),
newDoc.toBSON(),
- WriteConcerns::kMajorityWriteConcern);
+ WriteConcerns::kMajorityWriteConcernShardingTimeout);
}
_doc = std::move(newDoc);
@@ -219,7 +219,7 @@ void RenameParticipantInstance::_removeStateDocument(OperationContext* opCtx) {
PersistentTaskStore<StateDoc> store(NamespaceString::kShardingRenameParticipantsNamespace);
store.remove(opCtx,
BSON(StateDoc::kFromNssFieldName << fromNss().ns()),
- WriteConcerns::kMajorityWriteConcern);
+ WriteConcerns::kMajorityWriteConcernShardingTimeout);
_doc = {};
}