diff options
Diffstat (limited to 'src/mongo/db/repl/topology_coordinator_impl_test.cpp')
| -rw-r--r-- | src/mongo/db/repl/topology_coordinator_impl_test.cpp | 28 |
1 files changed, 20 insertions, 8 deletions
diff --git a/src/mongo/db/repl/topology_coordinator_impl_test.cpp b/src/mongo/db/repl/topology_coordinator_impl_test.cpp index 1a3916c77ae..27711e3fcf7 100644 --- a/src/mongo/db/repl/topology_coordinator_impl_test.cpp +++ b/src/mongo/db/repl/topology_coordinator_impl_test.cpp @@ -1321,6 +1321,7 @@ TEST_F(TopoCoordTest, ReplSetGetStatus) { Date_t curTime = heartbeatTime + uptimeSecs; Timestamp electionTime(1, 2); OpTime oplogProgress(Timestamp(3, 4), 0); + OpTime oplogDurable(Timestamp(3, 4), 1); OpTime lastCommittedOpTime(Timestamp(2, 3), -1); OpTime readConcernMajorityOpTime(Timestamp(4, 5), -1); std::string setName = "mySet"; @@ -1331,7 +1332,7 @@ TEST_F(TopoCoordTest, ReplSetGetStatus) { hb.setElectionTime(electionTime); hb.setHbMsg("READY"); hb.setAppliedOpTime(oplogProgress); - hb.setDurableOpTime(oplogProgress); + hb.setDurableOpTime(oplogDurable); StatusWith<ReplSetHeartbeatResponse> hbResponseGood = StatusWith<ReplSetHeartbeatResponse>(hb); updateConfig( @@ -1376,6 +1377,7 @@ TEST_F(TopoCoordTest, ReplSetGetStatus) { curTime, static_cast<unsigned>(durationCount<Seconds>(uptimeSecs)), oplogProgress, + oplogDurable, lastCommittedOpTime, readConcernMajorityOpTime}, &statusBuilder, @@ -1386,9 +1388,14 @@ TEST_F(TopoCoordTest, ReplSetGetStatus) { // Test results for all non-self members ASSERT_EQUALS(setName, rsStatus["set"].String()); ASSERT_EQUALS(curTime.asInt64(), rsStatus["date"].Date().asInt64()); - ASSERT_EQUALS(lastCommittedOpTime.toBSON(), rsStatus["OpTimes"]["lastCommittedOpTime"].Obj()); - ASSERT_EQUALS(readConcernMajorityOpTime.toBSON(), - rsStatus["OpTimes"]["readConcernMajorityOpTime"].Obj()); + ASSERT_EQUALS(lastCommittedOpTime.toBSON(), rsStatus["optimes"]["lastCommittedOpTime"].Obj()); + { + const auto optimes = rsStatus["optimes"].Obj(); + ASSERT_EQUALS(readConcernMajorityOpTime.toBSON(), + optimes["readConcernMajorityOpTime"].Obj()); + ASSERT_EQUALS(oplogProgress.getTimestamp(), optimes["appliedOpTime"].timestamp()); + ASSERT_EQUALS((oplogDurable).getTimestamp(), optimes["durableOpTime"].timestamp()); + } std::vector<BSONElement> memberArray = rsStatus["members"].Array(); ASSERT_EQUALS(4U, memberArray.size()); BSONObj member0Status = memberArray[0].Obj(); @@ -1486,6 +1493,7 @@ TEST_F(TopoCoordTest, NodeReturnsInvalidReplicaSetConfigInResponseToGetStatusWhe curTime, static_cast<unsigned>(durationCount<Seconds>(uptimeSecs)), oplogProgress, + oplogProgress, OpTime(), OpTime()}, &statusBuilder, @@ -2183,6 +2191,7 @@ public: TopologyCoordinator::ReplSetStatusArgs{_firstRequestDate + Milliseconds(4000), 10, OpTime(Timestamp(100, 0), 0), + OpTime(Timestamp(100, 0), 0), OpTime(), OpTime()}, &statusBuilder, @@ -2196,9 +2205,9 @@ public: ASSERT_EQUALS(1, member1Status["health"].Double()); ASSERT_EQUALS(Timestamp(0, 0), - Timestamp(rsStatus["OpTimes"]["lastCommittedOpTime"]["ts"].timestampValue())); - ASSERT_EQUALS(-1LL, rsStatus["OpTimes"]["lastCommittedOpTime"]["t"].numberLong()); - ASSERT_FALSE(rsStatus["OpTimes"].Obj().hasField("readConcernMajorityOpTime")); + Timestamp(rsStatus["optimes"]["lastCommittedOpTime"]["ts"].timestampValue())); + ASSERT_EQUALS(-1LL, rsStatus["optimes"]["lastCommittedOpTime"]["t"].numberLong()); + ASSERT_FALSE(rsStatus["optimes"].Obj().hasField("readConcernMajorityOpTime")); } Date_t firstRequestDate() { @@ -2246,6 +2255,7 @@ public: TopologyCoordinator::ReplSetStatusArgs{firstRequestDate() + Seconds(4), 10, OpTime(Timestamp(100, 0), 0), + OpTime(Timestamp(100, 0), 0), OpTime(), OpTime()}, &statusBuilder, @@ -2562,6 +2572,7 @@ TEST_F(HeartbeatResponseTestTwoRetries, NodeDoesNotRetryHeartbeatsAfterFailingTw TopologyCoordinator::ReplSetStatusArgs{firstRequestDate() + Milliseconds(4900), 10, OpTime(Timestamp(100, 0), 0), + OpTime(Timestamp(100, 0), 0), OpTime(), OpTime()}, &statusBuilder, @@ -2803,6 +2814,7 @@ TEST_F(HeartbeatResponseTestTwoRetries, TopologyCoordinator::ReplSetStatusArgs{firstRequestDate() + Milliseconds(7000), 600, OpTime(Timestamp(100, 0), 0), + OpTime(Timestamp(100, 0), 0), OpTime(), OpTime()}, &statusBuilder, @@ -4255,7 +4267,7 @@ TEST_F(ShutdownInProgressTest, NodeReturnsShutDownInProgressWhenGetReplSetStatus BSONObjBuilder response; getTopoCoord().prepareStatusResponse( cbData(), - TopologyCoordinator::ReplSetStatusArgs{Date_t(), 0, OpTime(), OpTime(), OpTime()}, + TopologyCoordinator::ReplSetStatusArgs{Date_t(), 0, OpTime(), OpTime(), OpTime(), OpTime()}, &response, &result); ASSERT_EQUALS(ErrorCodes::ShutdownInProgress, result); |