diff options
author | Pierlauro Sciarelli <pierlauro.sciarelli@mongodb.com> | 2021-12-24 08:50:15 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-12-24 09:15:11 +0000 |
commit | ebe76b776d7f183d8d7d0df9db860abe273b8aad (patch) | |
tree | 1cc074dc3b3684804e2e53ee7567e8785b49d76f /src/mongo/db/s/rename_collection_participant_service.cpp | |
parent | 9766c982d67c2a8584e329f024d702d8e2c8138e (diff) | |
download | mongo-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.cpp | 6 |
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 = {}; } |