diff options
author | Bernard Gorman <bernard.gorman@gmail.com> | 2021-03-24 14:07:04 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-04-02 21:51:14 +0000 |
commit | ea51edf33aa685e8b8d4692ee42b8c0e8e9cfb98 (patch) | |
tree | a3866340e9e80201eb9c9b675200700cc30ad53d /src/mongo/s/write_ops/batch_write_op_test.cpp | |
parent | 0198bcfb938ccd788f90a2f5e6156871cf18330f (diff) | |
download | mongo-ea51edf33aa685e8b8d4692ee42b8c0e8e9cfb98.tar.gz |
SERVER-54975 Rename IDL parser classes to use CommandRequest and CommandReply suffixes
Diffstat (limited to 'src/mongo/s/write_ops/batch_write_op_test.cpp')
-rw-r--r-- | src/mongo/s/write_ops/batch_write_op_test.cpp | 112 |
1 files changed, 56 insertions, 56 deletions
diff --git a/src/mongo/s/write_ops/batch_write_op_test.cpp b/src/mongo/s/write_ops/batch_write_op_test.cpp index 3e52a01db1f..224aa009b69 100644 --- a/src/mongo/s/write_ops/batch_write_op_test.cpp +++ b/src/mongo/s/write_ops/batch_write_op_test.cpp @@ -127,7 +127,7 @@ TEST_F(BatchWriteOpTest, SingleOp) { // Do single-target, single doc batch write op BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); + write_ops::InsertCommandRequest insertOp(nss); insertOp.setDocuments({BSON("x" << 1)}); return insertOp; }()); @@ -160,7 +160,7 @@ TEST_F(BatchWriteOpTest, SingleError) { // Do single-target, single doc batch write op BatchedCommandRequest request([&] { - write_ops::Delete deleteOp(nss); + write_ops::DeleteCommandRequest deleteOp(nss); deleteOp.setDeletes({buildDelete(BSON("x" << 1), false)}); return deleteOp; }()); @@ -199,7 +199,7 @@ TEST_F(BatchWriteOpTest, SingleTargetError) { // Do untargetable delete op BatchedCommandRequest request([&] { - write_ops::Delete deleteOp(nss); + write_ops::DeleteCommandRequest deleteOp(nss); deleteOp.setDeletes({buildDelete(BSON("x" << 1), false)}); return deleteOp; }()); @@ -233,7 +233,7 @@ TEST_F(BatchWriteOpTest, SingleWriteConcernErrorOrdered) { auto targeter = initTargeterFullRange(nss, endpoint); BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); + write_ops::InsertCommandRequest insertOp(nss); insertOp.setDocuments({BSON("x" << 1)}); return insertOp; }()); @@ -275,7 +275,7 @@ TEST_F(BatchWriteOpTest, SingleStaleError) { auto targeter = initTargeterFullRange(nss, endpoint); BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); + write_ops::InsertCommandRequest insertOp(nss); insertOp.setDocuments({BSON("x" << 1)}); return insertOp; }()); @@ -330,7 +330,7 @@ TEST_F(BatchWriteOpTest, MultiOpSameShardOrdered) { // Do single-target, multi-doc batch write op BatchedCommandRequest request([&] { - write_ops::Update updateOp(nss); + write_ops::UpdateCommandRequest updateOp(nss); updateOp.setUpdates( {buildUpdate(BSON("x" << 1), false), buildUpdate(BSON("x" << 2), false)}); return updateOp; @@ -367,9 +367,9 @@ TEST_F(BatchWriteOpTest, MultiOpSameShardUnordered) { // Do single-target, multi-doc batch write op BatchedCommandRequest request([&] { - write_ops::Update updateOp(nss); - updateOp.setWriteCommandBase([] { - write_ops::WriteCommandBase wcb; + write_ops::UpdateCommandRequest updateOp(nss); + updateOp.setWriteCommandRequestBase([] { + write_ops::WriteCommandRequestBase wcb; wcb.setOrdered(false); return wcb; }()); @@ -411,7 +411,7 @@ TEST_F(BatchWriteOpTest, MultiOpTwoShardsOrdered) { // Do multi-target, multi-doc batch write op BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); + write_ops::InsertCommandRequest insertOp(nss); insertOp.setDocuments({BSON("x" << -1), BSON("x" << 1)}); return insertOp; }()); @@ -478,9 +478,9 @@ TEST_F(BatchWriteOpTest, MultiOpTwoShardsUnordered) { // Do multi-target, multi-doc batch write op BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); - insertOp.setWriteCommandBase([] { - write_ops::WriteCommandBase wcb; + write_ops::InsertCommandRequest insertOp(nss); + insertOp.setWriteCommandRequestBase([] { + write_ops::WriteCommandRequestBase wcb; wcb.setOrdered(false); return wcb; }()); @@ -524,7 +524,7 @@ TEST_F(BatchWriteOpTest, MultiOpTwoShardsEachOrdered) { // Do multi-target, multi-doc batch write op BatchedCommandRequest request([&] { - write_ops::Delete deleteOp(nss); + write_ops::DeleteCommandRequest deleteOp(nss); deleteOp.setDeletes({buildDelete(BSON("x" << GTE << -1 << LT << 2), true), buildDelete(BSON("x" << GTE << -2 << LT << 1), true)}); return deleteOp; @@ -580,9 +580,9 @@ TEST_F(BatchWriteOpTest, MultiOpTwoShardsEachUnordered) { // Do multi-target, multi-doc batch write op BatchedCommandRequest request([&] { - write_ops::Update updateOp(nss); - updateOp.setWriteCommandBase([] { - write_ops::WriteCommandBase wcb; + write_ops::UpdateCommandRequest updateOp(nss); + updateOp.setWriteCommandRequestBase([] { + write_ops::WriteCommandRequestBase wcb; wcb.setOrdered(false); return wcb; }()); @@ -627,7 +627,7 @@ TEST_F(BatchWriteOpTest, MultiOpOneOrTwoShardsOrdered) { auto targeter = initTargeterSplitRange(nss, endpointA, endpointB); BatchedCommandRequest request([&] { - write_ops::Delete deleteOp(nss); + write_ops::DeleteCommandRequest deleteOp(nss); deleteOp.setDeletes({ // These go to the same shard buildDelete(BSON("x" << -1), false), @@ -722,9 +722,9 @@ TEST_F(BatchWriteOpTest, MultiOpOneOrTwoShardsUnordered) { auto targeter = initTargeterSplitRange(nss, endpointA, endpointB); BatchedCommandRequest request([&] { - write_ops::Update updateOp(nss); - updateOp.setWriteCommandBase([] { - write_ops::WriteCommandBase wcb; + write_ops::UpdateCommandRequest updateOp(nss); + updateOp.setWriteCommandRequestBase([] { + write_ops::WriteCommandRequestBase wcb; wcb.setOrdered(false); return wcb; }()); @@ -776,9 +776,9 @@ TEST_F(BatchWriteOpTest, MultiOpSingleShardErrorUnordered) { auto targeter = initTargeterSplitRange(nss, endpointA, endpointB); BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); - insertOp.setWriteCommandBase([] { - write_ops::WriteCommandBase wcb; + write_ops::InsertCommandRequest insertOp(nss); + insertOp.setWriteCommandRequestBase([] { + write_ops::WriteCommandRequestBase wcb; wcb.setOrdered(false); return wcb; }()); @@ -837,9 +837,9 @@ TEST_F(BatchWriteOpTest, MultiOpTwoShardErrorsUnordered) { auto targeter = initTargeterSplitRange(nss, endpointA, endpointB); BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); - insertOp.setWriteCommandBase([] { - write_ops::WriteCommandBase wcb; + write_ops::InsertCommandRequest insertOp(nss); + insertOp.setWriteCommandRequestBase([] { + write_ops::WriteCommandRequestBase wcb; wcb.setOrdered(false); return wcb; }()); @@ -895,9 +895,9 @@ TEST_F(BatchWriteOpTest, MultiOpPartialSingleShardErrorUnordered) { auto targeter = initTargeterSplitRange(nss, endpointA, endpointB); BatchedCommandRequest request([&] { - write_ops::Delete deleteOp(nss); - deleteOp.setWriteCommandBase([] { - write_ops::WriteCommandBase wcb; + write_ops::DeleteCommandRequest deleteOp(nss); + deleteOp.setWriteCommandRequestBase([] { + write_ops::WriteCommandRequestBase wcb; wcb.setOrdered(false); return wcb; }()); @@ -958,7 +958,7 @@ TEST_F(BatchWriteOpTest, MultiOpPartialSingleShardErrorOrdered) { auto targeter = initTargeterSplitRange(nss, endpointA, endpointB); BatchedCommandRequest request([&] { - write_ops::Delete deleteOp(nss); + write_ops::DeleteCommandRequest deleteOp(nss); deleteOp.setDeletes({buildDelete(BSON("x" << GTE << -1 << LT << 2), true), buildDelete(BSON("x" << GTE << -2 << LT << 1), true)}); return deleteOp; @@ -1019,9 +1019,9 @@ TEST_F(BatchWriteOpTest, MultiOpErrorAndWriteConcernErrorUnordered) { auto targeter = initTargeterFullRange(nss, endpoint); BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); - insertOp.setWriteCommandBase([] { - write_ops::WriteCommandBase wcb; + write_ops::InsertCommandRequest insertOp(nss); + insertOp.setWriteCommandRequestBase([] { + write_ops::WriteCommandRequestBase wcb; wcb.setOrdered(false); return wcb; }()); @@ -1064,9 +1064,9 @@ TEST_F(BatchWriteOpTest, SingleOpErrorAndWriteConcernErrorOrdered) { auto targeter = initTargeterSplitRange(nss, endpointA, endpointB); BatchedCommandRequest request([&] { - write_ops::Update updateOp(nss); - updateOp.setWriteCommandBase([] { - write_ops::WriteCommandBase wcb; + write_ops::UpdateCommandRequest updateOp(nss); + updateOp.setWriteCommandRequestBase([] { + write_ops::WriteCommandRequestBase wcb; wcb.setOrdered(false); return wcb; }()); @@ -1119,7 +1119,7 @@ TEST_F(BatchWriteOpTest, MultiOpFailedTargetOrdered) { auto targeter = initTargeterHalfRange(nss, endpoint); BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); + write_ops::InsertCommandRequest insertOp(nss); insertOp.setDocuments({BSON("x" << -1), BSON("x" << 2), BSON("x" << -2)}); return insertOp; }()); @@ -1174,9 +1174,9 @@ TEST_F(BatchWriteOpTest, MultiOpFailedTargetUnordered) { auto targeter = initTargeterHalfRange(nss, endpoint); BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); - insertOp.setWriteCommandBase([] { - write_ops::WriteCommandBase wcb; + write_ops::InsertCommandRequest insertOp(nss); + insertOp.setWriteCommandRequestBase([] { + write_ops::WriteCommandRequestBase wcb; wcb.setOrdered(false); return wcb; }()); @@ -1229,7 +1229,7 @@ TEST_F(BatchWriteOpTest, MultiOpFailedBatchOrdered) { auto targeter = initTargeterSplitRange(nss, endpointA, endpointB); BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); + write_ops::InsertCommandRequest insertOp(nss); insertOp.setDocuments({BSON("x" << -1), BSON("x" << 2), BSON("x" << 3)}); return insertOp; }()); @@ -1277,9 +1277,9 @@ TEST_F(BatchWriteOpTest, MultiOpFailedBatchUnordered) { auto targeter = initTargeterSplitRange(nss, endpointA, endpointB); BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); - insertOp.setWriteCommandBase([] { - write_ops::WriteCommandBase wcb; + write_ops::InsertCommandRequest insertOp(nss); + insertOp.setWriteCommandRequestBase([] { + write_ops::WriteCommandRequestBase wcb; wcb.setOrdered(false); return wcb; }()); @@ -1334,7 +1334,7 @@ TEST_F(BatchWriteOpTest, MultiOpAbortOrdered) { auto targeter = initTargeterSplitRange(nss, endpointA, endpointB); BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); + write_ops::InsertCommandRequest insertOp(nss); insertOp.setDocuments({BSON("x" << -1), BSON("x" << 2), BSON("x" << 3)}); return insertOp; }()); @@ -1379,9 +1379,9 @@ TEST_F(BatchWriteOpTest, MultiOpAbortUnordered) { auto targeter = initTargeterSplitRange(nss, endpointA, endpointB); BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); - insertOp.setWriteCommandBase([] { - write_ops::WriteCommandBase wcb; + write_ops::InsertCommandRequest insertOp(nss); + insertOp.setWriteCommandRequestBase([] { + write_ops::WriteCommandRequestBase wcb; wcb.setOrdered(false); return wcb; }()); @@ -1420,7 +1420,7 @@ TEST_F(BatchWriteOpTest, MultiOpTwoWCErrors) { auto targeter = initTargeterSplitRange(nss, endpointA, endpointB); BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); + write_ops::InsertCommandRequest insertOp(nss); insertOp.setDocuments({BSON("x" << -1), BSON("x" << 2)}); return insertOp; }()); @@ -1473,9 +1473,9 @@ TEST_F(BatchWriteOpLimitTests, OneBigDoc) { // Do single-target, single doc batch write op BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); - insertOp.setWriteCommandBase([] { - write_ops::WriteCommandBase wcb; + write_ops::InsertCommandRequest insertOp(nss); + insertOp.setWriteCommandRequestBase([] { + write_ops::WriteCommandRequestBase wcb; wcb.setOrdered(false); return wcb; }()); @@ -1508,7 +1508,7 @@ TEST_F(BatchWriteOpLimitTests, OneBigOneSmall) { const std::string bigString(BSONObjMaxUserSize, 'x'); BatchedCommandRequest request([&] { - write_ops::Update updateOp(nss); + write_ops::UpdateCommandRequest updateOp(nss); updateOp.setUpdates({buildUpdate(BSON("x" << 1), BSON("data" << bigString), false), buildUpdate(BSON("x" << 2), BSONObj(), false)}); return updateOp; @@ -1575,7 +1575,7 @@ TEST_F(BatchWriteOpTransactionTest, ThrowTargetingErrorsInTransaction_Delete) { // Untargetable delete op. BatchedCommandRequest deleteRequest([&] { - write_ops::Delete deleteOp(nss); + write_ops::DeleteCommandRequest deleteOp(nss); deleteOp.setDeletes({buildDelete(BSON("x" << 1), false)}); return deleteOp; }()); @@ -1605,7 +1605,7 @@ TEST_F(BatchWriteOpTransactionTest, ThrowTargetingErrorsInTransaction_Update) { // Untargetable update op. BatchedCommandRequest updateRequest([&] { - write_ops::Update updateOp(nss); + write_ops::UpdateCommandRequest updateOp(nss); updateOp.setUpdates({buildUpdate(BSON("x" << 1), BSONObj(), false)}); return updateOp; }()); |