diff options
Diffstat (limited to 'src/mongo/client/sdam/topology_manager_test.cpp')
-rw-r--r-- | src/mongo/client/sdam/topology_manager_test.cpp | 26 |
1 files changed, 12 insertions, 14 deletions
diff --git a/src/mongo/client/sdam/topology_manager_test.cpp b/src/mongo/client/sdam/topology_manager_test.cpp index fb78bfbbf3f..bc9e9256f1a 100644 --- a/src/mongo/client/sdam/topology_manager_test.cpp +++ b/src/mongo/client/sdam/topology_manager_test.cpp @@ -74,9 +74,8 @@ TEST_F(TopologyManagerTestFixture, ShouldUpdateTopologyVersionOnSuccess) { ASSERT(serverDescription->getTopologyVersion() == boost::none); // If previous topologyVersion is boost::none, should update to new topologyVersion - auto isMasterOutcome = IsMasterOutcome(serverDescription->getAddress(), - kBsonTopologyVersionLow, - duration_cast<IsMasterRTT>(mongo::Milliseconds(40))); + auto isMasterOutcome = IsMasterOutcome( + serverDescription->getAddress(), kBsonTopologyVersionLow, mongo::Milliseconds(40)); topologyManager.onServerDescription(isMasterOutcome); topologyDescription = topologyManager.getTopologyDescription(); auto newServerDescription = topologyDescription->getServers()[0]; @@ -84,9 +83,8 @@ TEST_F(TopologyManagerTestFixture, ShouldUpdateTopologyVersionOnSuccess) { kBsonTopologyVersionLow.getObjectField("topologyVersion")); // If previous topologyVersion is <= new topologyVersion, should update to new topologyVersion - isMasterOutcome = IsMasterOutcome(serverDescription->getAddress(), - kBsonTopologyVersionHigh, - duration_cast<IsMasterRTT>(mongo::Milliseconds(40))); + isMasterOutcome = IsMasterOutcome( + serverDescription->getAddress(), kBsonTopologyVersionHigh, mongo::Milliseconds(40)); topologyManager.onServerDescription(isMasterOutcome); topologyDescription = topologyManager.getTopologyDescription(); newServerDescription = topologyDescription->getServers()[0]; @@ -104,9 +102,8 @@ TEST_F(TopologyManagerTestFixture, ShouldUpdateTopologyVersionOnErrorIfSent) { ASSERT(serverDescription->getTopologyVersion() == boost::none); // If previous topologyVersion is boost::none, should update to new topologyVersion - auto isMasterOutcome = IsMasterOutcome(serverDescription->getAddress(), - kBsonTopologyVersionLow, - duration_cast<IsMasterRTT>(mongo::Milliseconds(40))); + auto isMasterOutcome = IsMasterOutcome( + serverDescription->getAddress(), kBsonTopologyVersionLow, mongo::Milliseconds(40)); topologyManager.onServerDescription(isMasterOutcome); topologyDescription = topologyManager.getTopologyDescription(); auto newServerDescription = topologyDescription->getServers()[0]; @@ -133,9 +130,8 @@ TEST_F(TopologyManagerTestFixture, ShouldNotUpdateServerDescriptionIfNewTopology ASSERT(serverDescription->getTopologyVersion() == boost::none); // If previous topologyVersion is boost::none, should update to new topologyVersion - auto isMasterOutcome = IsMasterOutcome(serverDescription->getAddress(), - kBsonTopologyVersionHigh, - duration_cast<IsMasterRTT>(mongo::Milliseconds(40))); + auto isMasterOutcome = IsMasterOutcome( + serverDescription->getAddress(), kBsonTopologyVersionHigh, mongo::Milliseconds(40)); topologyManager.onServerDescription(isMasterOutcome); topologyDescription = topologyManager.getTopologyDescription(); auto newServerDescription = topologyDescription->getServers()[0]; @@ -143,7 +139,8 @@ TEST_F(TopologyManagerTestFixture, ShouldNotUpdateServerDescriptionIfNewTopology kBsonTopologyVersionHigh.getObjectField("topologyVersion")); // If isMasterOutcome is not successful, should preserve old topologyVersion - isMasterOutcome = IsMasterOutcome(serverDescription->getAddress(), kBsonTopologyVersionLow); + isMasterOutcome = IsMasterOutcome( + serverDescription->getAddress(), kBsonTopologyVersionLow, mongo::Milliseconds(40)); topologyManager.onServerDescription(isMasterOutcome); topologyDescription = topologyManager.getTopologyDescription(); newServerDescription = topologyDescription->getServers()[0]; @@ -161,7 +158,8 @@ TEST_F(TopologyManagerTestFixture, ShouldNowIncrementPoolResetCounterOnSuccess) ASSERT_EQUALS(serverDescription->getPoolResetCounter(), 0); // If isMasterOutcome is successful, poolResetCounter should remain the same - IsMasterOutcome isMasterOutcome(serverDescription->getAddress(), kBsonOk); + IsMasterOutcome isMasterOutcome( + serverDescription->getAddress(), kBsonOk, mongo::Milliseconds(40)); topologyManager.onServerDescription(isMasterOutcome); topologyDescription = topologyManager.getTopologyDescription(); auto newServerDescription = topologyDescription->getServers()[0]; |