summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/migration_util.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/s/migration_util.cpp')
-rw-r--r--src/mongo/db/s/migration_util.cpp5
1 files changed, 3 insertions, 2 deletions
diff --git a/src/mongo/db/s/migration_util.cpp b/src/mongo/db/s/migration_util.cpp
index a8dfbbbe235..05896b00291 100644
--- a/src/mongo/db/s/migration_util.cpp
+++ b/src/mongo/db/s/migration_util.cpp
@@ -518,7 +518,7 @@ void resubmitRangeDeletionsOnStepUp(ServiceContext* serviceContext) {
void dropRangeDeletionsCollection(OperationContext* opCtx) {
DBDirectClient client(opCtx);
client.dropCollection(NamespaceString::kRangeDeletionNamespace.toString(),
- WriteConcerns::kMajorityWriteConcern);
+ WriteConcerns::kMajorityWriteConcernShardingTimeout);
}
template <typename Callable>
@@ -1109,7 +1109,8 @@ void persistMigrationRecipientRecoveryDocument(
PersistentTaskStore<MigrationRecipientRecoveryDocument> store(
NamespaceString::kMigrationRecipientsNamespace);
try {
- store.add(opCtx, migrationRecipientDoc, WriteConcerns::kMajorityWriteConcern);
+ store.add(
+ opCtx, migrationRecipientDoc, WriteConcerns::kMajorityWriteConcernShardingTimeout);
} catch (const ExceptionFor<ErrorCodes::DuplicateKey>&) {
// Convert a DuplicateKey error to an anonymous error.
uasserted(6064502,