diff options
Diffstat (limited to 'src/mongo/db/repl')
5 files changed, 14 insertions, 14 deletions
diff --git a/src/mongo/db/repl/oplog_buffer_collection.cpp b/src/mongo/db/repl/oplog_buffer_collection.cpp index caa7cbd3803..799bf539ca7 100644 --- a/src/mongo/db/repl/oplog_buffer_collection.cpp +++ b/src/mongo/db/repl/oplog_buffer_collection.cpp @@ -208,10 +208,10 @@ void OplogBufferCollection::_push(WithLock, DocumentValidationSettings::kDisableSchemaValidation | DocumentValidationSettings::kDisableInternalValidation); - write_ops::Insert insertOp(_nss); + write_ops::InsertCommandRequest insertOp(_nss); insertOp.setDocuments(std::move(docsToInsert)); - insertOp.setWriteCommandBase([] { - write_ops::WriteCommandBase wcb; + insertOp.setWriteCommandRequestBase([] { + write_ops::WriteCommandRequestBase wcb; wcb.setOrdered(true); return wcb; }()); diff --git a/src/mongo/db/repl/tenant_collection_cloner.cpp b/src/mongo/db/repl/tenant_collection_cloner.cpp index d63cc3fe63b..087e0da1261 100644 --- a/src/mongo/db/repl/tenant_collection_cloner.cpp +++ b/src/mongo/db/repl/tenant_collection_cloner.cpp @@ -539,10 +539,10 @@ void TenantCollectionCloner::insertDocumentsCallback( DocumentValidationSettings::kDisableSchemaValidation | DocumentValidationSettings::kDisableInternalValidation); - write_ops::Insert insertOp(_existingNss.value_or(_sourceNss)); + write_ops::InsertCommandRequest insertOp(_existingNss.value_or(_sourceNss)); insertOp.setDocuments(std::move(docs)); - insertOp.setWriteCommandBase([] { - write_ops::WriteCommandBase wcb; + insertOp.setWriteCommandRequestBase([] { + write_ops::WriteCommandRequestBase wcb; wcb.setOrdered(true); return wcb; }()); diff --git a/src/mongo/db/repl/tenant_migration_donor_service.cpp b/src/mongo/db/repl/tenant_migration_donor_service.cpp index 24d1114e98b..c75d034f49c 100644 --- a/src/mongo/db/repl/tenant_migration_donor_service.cpp +++ b/src/mongo/db/repl/tenant_migration_donor_service.cpp @@ -884,7 +884,7 @@ TenantMigrationDonorService::Instance::_fetchAndStoreRecipientClusterTimeKeyDocs const auto nss = NamespaceString::kKeysCollectionNamespace; const auto cmdObj = [&] { - FindCommand request(NamespaceStringOrUUID{nss}); + FindCommandRequest request(NamespaceStringOrUUID{nss}); request.setReadConcern( repl::ReadConcernArgs(repl::ReadConcernLevel::kMajorityReadConcern) .toBSONInner()); diff --git a/src/mongo/db/repl/tenant_migration_recipient_service.cpp b/src/mongo/db/repl/tenant_migration_recipient_service.cpp index 0118613271f..d5d3df7f823 100644 --- a/src/mongo/db/repl/tenant_migration_recipient_service.cpp +++ b/src/mongo/db/repl/tenant_migration_recipient_service.cpp @@ -870,8 +870,8 @@ void TenantMigrationRecipientService::Instance::_getStartOpTimesFromDonor(WithLo _stateDoc.setStartFetchingDonorOpTime(startFetchingDonorOpTime); } -AggregateCommand TenantMigrationRecipientService::Instance::_makeCommittedTransactionsAggregation() - const { +AggregateCommandRequest +TenantMigrationRecipientService::Instance::_makeCommittedTransactionsAggregation() const { auto opCtx = cc().makeOperationContext(); auto expCtx = makeExpressionContext(opCtx.get()); @@ -888,8 +888,8 @@ AggregateCommand TenantMigrationRecipientService::Instance::_makeCommittedTransa expCtx, startFetchingTimestamp, getTenantId()) ->serializeToBson(); - AggregateCommand aggRequest(NamespaceString::kSessionTransactionsTableNamespace, - std::move(serializedPipeline)); + AggregateCommandRequest aggRequest(NamespaceString::kSessionTransactionsTableNamespace, + std::move(serializedPipeline)); auto readConcern = repl::ReadConcernArgs( boost::optional<LogicalTime>(startFetchingTimestamp), @@ -1126,8 +1126,8 @@ TenantMigrationRecipientService::Instance::_fetchRetryableWritesOplogBeforeStart expCtx, startFetchingTimestamp, getTenantId()) ->serializeToBson(); - AggregateCommand aggRequest(NamespaceString::kSessionTransactionsTableNamespace, - std::move(serializedPipeline)); + AggregateCommandRequest aggRequest(NamespaceString::kSessionTransactionsTableNamespace, + std::move(serializedPipeline)); auto readConcernArgs = repl::ReadConcernArgs( boost::optional<repl::ReadConcernLevel>(repl::ReadConcernLevel::kMajorityReadConcern)); diff --git a/src/mongo/db/repl/tenant_migration_recipient_service.h b/src/mongo/db/repl/tenant_migration_recipient_service.h index 58e65811412..09bda6cbe39 100644 --- a/src/mongo/db/repl/tenant_migration_recipient_service.h +++ b/src/mongo/db/repl/tenant_migration_recipient_service.h @@ -378,7 +378,7 @@ public: * Creates an aggregation pipeline to fetch transaction entries with 'lastWriteOpTime' < * 'startFetchingDonorOpTime' and 'state: committed'. */ - AggregateCommand _makeCommittedTransactionsAggregation() const; + AggregateCommandRequest _makeCommittedTransactionsAggregation() const; /** * Processes a committed transaction entry from the donor. Updates the recipient's |