summaryrefslogtreecommitdiff
path: root/src/mongo/client/sdam/topology_manager_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/client/sdam/topology_manager_test.cpp')
-rw-r--r--src/mongo/client/sdam/topology_manager_test.cpp26
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];