summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/read_concern_args_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/read_concern_args_test.cpp')
-rw-r--r--src/mongo/db/repl/read_concern_args_test.cpp116
1 files changed, 64 insertions, 52 deletions
diff --git a/src/mongo/db/repl/read_concern_args_test.cpp b/src/mongo/db/repl/read_concern_args_test.cpp
index 57364f07d14..75843f5a945 100644
--- a/src/mongo/db/repl/read_concern_args_test.cpp
+++ b/src/mongo/db/repl/read_concern_args_test.cpp
@@ -38,12 +38,13 @@ namespace {
TEST(ReadAfterParse, ReadAfterOnly) {
ReadConcernArgs readAfterOpTime;
- ASSERT_OK(readAfterOpTime.initialize(BSON("find"
- << "test" << ReadConcernArgs::kReadConcernFieldName
- << BSON(ReadConcernArgs::kAfterOpTimeFieldName
- << BSON(OpTime::kTimestampFieldName
- << Timestamp(20, 30)
- << OpTime::kTermFieldName << 2)))));
+ ASSERT_OK(readAfterOpTime.initialize(BSON(
+ "find"
+ << "test"
+ << ReadConcernArgs::kReadConcernFieldName
+ << BSON(ReadConcernArgs::kAfterOpTimeFieldName
+ << BSON(OpTime::kTimestampFieldName << Timestamp(20, 30) << OpTime::kTermFieldName
+ << 2)))));
ASSERT_EQ(Timestamp(20, 30), readAfterOpTime.getOpTime().getTimestamp());
ASSERT_EQ(2, readAfterOpTime.getOpTime().getTerm());
@@ -54,7 +55,8 @@ TEST(ReadAfterParse, ReadCommitLevelOnly) {
ReadConcernArgs readAfterOpTime;
ASSERT_OK(
readAfterOpTime.initialize(BSON("find"
- << "test" << ReadConcernArgs::kReadConcernFieldName
+ << "test"
+ << ReadConcernArgs::kReadConcernFieldName
<< BSON(ReadConcernArgs::kLevelFieldName << "majority"))));
ASSERT_TRUE(readAfterOpTime.getOpTime().isNull());
@@ -63,13 +65,15 @@ TEST(ReadAfterParse, ReadCommitLevelOnly) {
TEST(ReadAfterParse, ReadCommittedFullSpecification) {
ReadConcernArgs readAfterOpTime;
- ASSERT_OK(readAfterOpTime.initialize(
- BSON("find"
- << "test" << ReadConcernArgs::kReadConcernFieldName
- << BSON(ReadConcernArgs::kAfterOpTimeFieldName
- << BSON(OpTime::kTimestampFieldName << Timestamp(20, 30)
- << OpTime::kTermFieldName << 2)
- << ReadConcernArgs::kLevelFieldName << "majority"))));
+ ASSERT_OK(readAfterOpTime.initialize(BSON(
+ "find"
+ << "test"
+ << ReadConcernArgs::kReadConcernFieldName
+ << BSON(ReadConcernArgs::kAfterOpTimeFieldName
+ << BSON(OpTime::kTimestampFieldName << Timestamp(20, 30) << OpTime::kTermFieldName
+ << 2)
+ << ReadConcernArgs::kLevelFieldName
+ << "majority"))));
ASSERT_EQ(Timestamp(20, 30), readAfterOpTime.getOpTime().getTimestamp());
ASSERT_EQ(2, readAfterOpTime.getOpTime().getTerm());
@@ -87,24 +91,26 @@ TEST(ReadAfterParse, Empty) {
TEST(ReadAfterParse, BadRootType) {
ReadConcernArgs readAfterOpTime;
- ASSERT_NOT_OK(
- readAfterOpTime.initialize(BSON("find"
- << "test" << ReadConcernArgs::kReadConcernFieldName
- << "x")));
+ ASSERT_NOT_OK(readAfterOpTime.initialize(BSON("find"
+ << "test"
+ << ReadConcernArgs::kReadConcernFieldName
+ << "x")));
}
TEST(ReadAfterParse, BadOpTimeType) {
ReadConcernArgs readAfterOpTime;
ASSERT_NOT_OK(
readAfterOpTime.initialize(BSON("find"
- << "test" << ReadConcernArgs::kReadConcernFieldName
+ << "test"
+ << ReadConcernArgs::kReadConcernFieldName
<< BSON(ReadConcernArgs::kAfterOpTimeFieldName << 2))));
}
TEST(ReadAfterParse, OpTimeNotNeededForValidReadConcern) {
ReadConcernArgs readAfterOpTime;
ASSERT_OK(readAfterOpTime.initialize(BSON("find"
- << "test" << ReadConcernArgs::kReadConcernFieldName
+ << "test"
+ << ReadConcernArgs::kReadConcernFieldName
<< BSONObj())));
}
@@ -112,47 +118,49 @@ TEST(ReadAfterParse, NoOpTimeTS) {
ReadConcernArgs readAfterOpTime;
ASSERT_NOT_OK(
readAfterOpTime.initialize(BSON("find"
- << "test" << ReadConcernArgs::kReadConcernFieldName
+ << "test"
+ << ReadConcernArgs::kReadConcernFieldName
<< BSON(ReadConcernArgs::kAfterOpTimeFieldName
<< BSON(OpTime::kTimestampFieldName << 2)))));
}
TEST(ReadAfterParse, NoOpTimeTerm) {
ReadConcernArgs readAfterOpTime;
- ASSERT_NOT_OK(
- readAfterOpTime.initialize(BSON("find"
- << "test" << ReadConcernArgs::kReadConcernFieldName
- << BSON(ReadConcernArgs::kAfterOpTimeFieldName
- << BSON(OpTime::kTermFieldName << 2)))));
+ ASSERT_NOT_OK(readAfterOpTime.initialize(BSON("find"
+ << "test"
+ << ReadConcernArgs::kReadConcernFieldName
+ << BSON(ReadConcernArgs::kAfterOpTimeFieldName
+ << BSON(OpTime::kTermFieldName << 2)))));
}
TEST(ReadAfterParse, BadOpTimeTSType) {
ReadConcernArgs readAfterOpTime;
- ASSERT_NOT_OK(
- readAfterOpTime.initialize(BSON("find"
- << "test" << ReadConcernArgs::kReadConcernFieldName
- << BSON(ReadConcernArgs::kAfterOpTimeFieldName
- << BSON(OpTime::kTimestampFieldName
- << BSON("x" << 1) << OpTime::kTermFieldName
- << 2)))));
+ ASSERT_NOT_OK(readAfterOpTime.initialize(
+ BSON("find"
+ << "test"
+ << ReadConcernArgs::kReadConcernFieldName
+ << BSON(ReadConcernArgs::kAfterOpTimeFieldName
+ << BSON(OpTime::kTimestampFieldName << BSON("x" << 1) << OpTime::kTermFieldName
+ << 2)))));
}
TEST(ReadAfterParse, BadOpTimeTermType) {
ReadConcernArgs readAfterOpTime;
- ASSERT_NOT_OK(
- readAfterOpTime.initialize(BSON("find"
- << "test" << ReadConcernArgs::kReadConcernFieldName
- << BSON(ReadConcernArgs::kAfterOpTimeFieldName
- << BSON(OpTime::kTimestampFieldName
- << Timestamp(1, 0) << OpTime::kTermFieldName
- << "y")))));
+ ASSERT_NOT_OK(readAfterOpTime.initialize(BSON(
+ "find"
+ << "test"
+ << ReadConcernArgs::kReadConcernFieldName
+ << BSON(ReadConcernArgs::kAfterOpTimeFieldName
+ << BSON(OpTime::kTimestampFieldName << Timestamp(1, 0) << OpTime::kTermFieldName
+ << "y")))));
}
TEST(ReadAfterParse, BadLevelType) {
ReadConcernArgs readAfterOpTime;
ASSERT_EQ(ErrorCodes::TypeMismatch,
readAfterOpTime.initialize(BSON("find"
- << "test" << ReadConcernArgs::kReadConcernFieldName
+ << "test"
+ << ReadConcernArgs::kReadConcernFieldName
<< BSON(ReadConcernArgs::kLevelFieldName << 7))));
}
@@ -160,7 +168,8 @@ TEST(ReadAfterParse, BadLevelValue) {
ReadConcernArgs readAfterOpTime;
ASSERT_EQ(ErrorCodes::FailedToParse,
readAfterOpTime.initialize(BSON("find"
- << "test" << ReadConcernArgs::kReadConcernFieldName
+ << "test"
+ << ReadConcernArgs::kReadConcernFieldName
<< BSON(ReadConcernArgs::kLevelFieldName
<< "seven is not a real level"))));
}
@@ -169,7 +178,8 @@ TEST(ReadAfterParse, BadOption) {
ReadConcernArgs readAfterOpTime;
ASSERT_EQ(ErrorCodes::InvalidOptions,
readAfterOpTime.initialize(BSON("find"
- << "test" << ReadConcernArgs::kReadConcernFieldName
+ << "test"
+ << ReadConcernArgs::kReadConcernFieldName
<< BSON("asdf" << 1))));
}
@@ -188,10 +198,10 @@ TEST(ReadAfterSerialize, ReadAfterOnly) {
ReadConcernArgs readAfterOpTime(OpTime(Timestamp(20, 30), 2), boost::none);
readAfterOpTime.appendInfo(&builder);
- BSONObj expectedObj(BSON(ReadConcernArgs::kReadConcernFieldName
- << BSON(ReadConcernArgs::kAfterOpTimeFieldName << BSON(
- OpTime::kTimestampFieldName
- << Timestamp(20, 30) << OpTime::kTermFieldName << 2))));
+ BSONObj expectedObj(BSON(
+ ReadConcernArgs::kReadConcernFieldName << BSON(
+ ReadConcernArgs::kAfterOpTimeFieldName << BSON(
+ OpTime::kTimestampFieldName << Timestamp(20, 30) << OpTime::kTermFieldName << 2))));
ASSERT_EQ(expectedObj, builder.done());
}
@@ -213,11 +223,13 @@ TEST(ReadAfterSerialize, FullSpecification) {
ReadConcernLevel::kMajorityReadConcern);
readAfterOpTime.appendInfo(&builder);
- BSONObj expectedObj(BSON(ReadConcernArgs::kReadConcernFieldName << BSON(
- ReadConcernArgs::kLevelFieldName
- << "majority" << ReadConcernArgs::kAfterOpTimeFieldName
- << BSON(OpTime::kTimestampFieldName
- << Timestamp(20, 30) << OpTime::kTermFieldName << 2))));
+ BSONObj expectedObj(BSON(
+ ReadConcernArgs::kReadConcernFieldName
+ << BSON(ReadConcernArgs::kLevelFieldName
+ << "majority"
+ << ReadConcernArgs::kAfterOpTimeFieldName
+ << BSON(OpTime::kTimestampFieldName << Timestamp(20, 30) << OpTime::kTermFieldName
+ << 2))));
ASSERT_EQ(expectedObj, builder.done());
}
View Lorry Controller Status