summaryrefslogtreecommitdiff
path: root/src/mongo/db/ops/write_ops_retryability_test.cpp
diff options
context:
space:
mode:
authorBernard Gorman <bernard.gorman@gmail.com>2021-03-24 14:07:04 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-04-02 21:51:14 +0000
commitea51edf33aa685e8b8d4692ee42b8c0e8e9cfb98 (patch)
treea3866340e9e80201eb9c9b675200700cc30ad53d /src/mongo/db/ops/write_ops_retryability_test.cpp
parent0198bcfb938ccd788f90a2f5e6156871cf18330f (diff)
downloadmongo-ea51edf33aa685e8b8d4692ee42b8c0e8e9cfb98.tar.gz
SERVER-54975 Rename IDL parser classes to use CommandRequest and CommandReply suffixes
Diffstat (limited to 'src/mongo/db/ops/write_ops_retryability_test.cpp')
-rw-r--r--src/mongo/db/ops/write_ops_retryability_test.cpp32
1 files changed, 16 insertions, 16 deletions
diff --git a/src/mongo/db/ops/write_ops_retryability_test.cpp b/src/mongo/db/ops/write_ops_retryability_test.cpp
index 4aa7f3a4748..2d209dbfebb 100644
--- a/src/mongo/db/ops/write_ops_retryability_test.cpp
+++ b/src/mongo/db/ops/write_ops_retryability_test.cpp
@@ -99,9 +99,9 @@ void setUpTxnParticipant(OperationContext* opCtx, std::vector<int> executedStmtI
txnPart.setCommittedStmtIdsForTest(std::move(executedStmtIds));
}
-write_ops::FindAndModifyCommand makeFindAndModifyRequest(
+write_ops::FindAndModifyCommandRequest makeFindAndModifyRequest(
NamespaceString fullNs, BSONObj query, boost::optional<write_ops::UpdateModification> update) {
- auto request = write_ops::FindAndModifyCommand(fullNs);
+ auto request = write_ops::FindAndModifyCommandRequest(fullNs);
request.setQuery(query);
if (update) {
request.setUpdate(std::move(update));
@@ -192,8 +192,8 @@ TEST_F(WriteOpsRetryability, PerformInsertsSuccess) {
repl::UnreplicatedWritesBlock unreplicated(opCtxRaii.get());
setUpReplication(getServiceContext());
- write_ops::Insert insertOp(NamespaceString("foo.bar"));
- insertOp.getWriteCommandBase().setOrdered(true);
+ write_ops::InsertCommandRequest insertOp(NamespaceString("foo.bar"));
+ insertOp.getWriteCommandRequestBase().setOrdered(true);
insertOp.setDocuments({BSON("_id" << 0), BSON("_id" << 1)});
write_ops_exec::WriteResult result = write_ops_exec::performInserts(opCtxRaii.get(), insertOp);
@@ -213,12 +213,12 @@ TEST_F(WriteOpsRetryability, PerformRetryableInsertsSuccess) {
// Set up a retryable write where statements 1 and 2 have already executed.
setUpTxnParticipant(opCtxRaii.get(), {1, 2});
- write_ops::Insert insertOp(NamespaceString("foo.bar"));
- insertOp.getWriteCommandBase().setOrdered(true);
+ write_ops::InsertCommandRequest insertOp(NamespaceString("foo.bar"));
+ insertOp.getWriteCommandRequestBase().setOrdered(true);
// Setup documents that cannot be successfully inserted to show that the retryable logic was
// exercised.
insertOp.setDocuments({BSON("_id" << 0), BSON("_id" << 0)});
- insertOp.getWriteCommandBase().setStmtIds({{1, 2}});
+ insertOp.getWriteCommandRequestBase().setStmtIds({{1, 2}});
write_ops_exec::WriteResult result = write_ops_exec::performInserts(opCtxRaii.get(), insertOp);
// Assert that both writes "succeeded". While there should have been a duplicate key error, the
@@ -240,11 +240,11 @@ TEST_F(WriteOpsRetryability, PerformRetryableInsertsWithBatchedFailure) {
// Set up a retryable write where statement 3 has already executed.
setUpTxnParticipant(opCtxRaii.get(), {3});
- write_ops::Insert insertOp(NamespaceString("foo.bar"));
- insertOp.getWriteCommandBase().setOrdered(false);
+ write_ops::InsertCommandRequest insertOp(NamespaceString("foo.bar"));
+ insertOp.getWriteCommandRequestBase().setOrdered(false);
// Setup documents such that the second will fail insertion.
insertOp.setDocuments({BSON("_id" << 0), BSON("_id" << 0), BSON("_id" << 1)});
- insertOp.getWriteCommandBase().setStmtIds({{1, 2, 3}});
+ insertOp.getWriteCommandRequestBase().setStmtIds({{1, 2, 3}});
write_ops_exec::WriteResult result = write_ops_exec::performInserts(opCtxRaii.get(), insertOp);
// Assert that the third (already executed) write succeeds, despite the second write failing
@@ -264,8 +264,8 @@ TEST_F(WriteOpsRetryability, PerformOrderedInsertsStopsAtError) {
repl::UnreplicatedWritesBlock unreplicated(opCtxRaii.get());
setUpReplication(getServiceContext());
- write_ops::Insert insertOp(NamespaceString("foo.bar"));
- insertOp.getWriteCommandBase().setOrdered(true);
+ write_ops::InsertCommandRequest insertOp(NamespaceString("foo.bar"));
+ insertOp.getWriteCommandRequestBase().setOrdered(true);
// Setup documents such that the second cannot be successfully inserted.
insertOp.setDocuments({BSON("_id" << 0), BSON("_id" << 0), BSON("_id" << 1)});
write_ops_exec::WriteResult result = write_ops_exec::performInserts(opCtxRaii.get(), insertOp);
@@ -285,8 +285,8 @@ TEST_F(WriteOpsRetryability, PerformOrderedInsertsStopsAtBadDoc) {
repl::UnreplicatedWritesBlock unreplicated(opCtxRaii.get());
setUpReplication(getServiceContext());
- write_ops::Insert insertOp(NamespaceString("foo.bar"));
- insertOp.getWriteCommandBase().setOrdered(true);
+ write_ops::InsertCommandRequest insertOp(NamespaceString("foo.bar"));
+ insertOp.getWriteCommandRequestBase().setOrdered(true);
// Setup documents such that the second cannot be successfully inserted.
auto largeBuffer = [](std::int32_t size) {
@@ -317,8 +317,8 @@ TEST_F(WriteOpsRetryability, PerformUnorderedInsertsContinuesAtBadDoc) {
repl::UnreplicatedWritesBlock unreplicated(opCtxRaii.get());
setUpReplication(getServiceContext());
- write_ops::Insert insertOp(NamespaceString("foo.bar"));
- insertOp.getWriteCommandBase().setOrdered(false);
+ write_ops::InsertCommandRequest insertOp(NamespaceString("foo.bar"));
+ insertOp.getWriteCommandRequestBase().setOrdered(false);
// Setup documents such that the second cannot be successfully inserted.
auto largeBuffer = [](std::int32_t size) {