diff options
| author | Kaloian Manassiev <kaloian.manassiev@mongodb.com> | 2015-11-06 12:13:11 -0500 |
|---|---|---|
| committer | Kaloian Manassiev <kaloian.manassiev@mongodb.com> | 2015-11-11 10:16:33 -0500 |
| commit | 67b68b5f094d88753ae2fe14f6d708c9e5b4bfbd (patch) | |
| tree | 17b708763cec3f17e0028c02edd3f54559a4804a /src/mongo/dbtests/replica_set_monitor_test.cpp | |
| parent | 3c090e1ad8b0f6d555396554abad7ea3747961af (diff) | |
| download | mongo-67b68b5f094d88753ae2fe14f6d708c9e5b4bfbd.tar.gz | |
SERVER-21272 Make replica set monitor retry finding hosts
This change makes the replica set monitor retry more than once to find
hosts suitable for a given read preference and fail quickly if none of the
hosts for a given replica set can be reached.
Diffstat (limited to 'src/mongo/dbtests/replica_set_monitor_test.cpp')
| -rw-r--r-- | src/mongo/dbtests/replica_set_monitor_test.cpp | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/mongo/dbtests/replica_set_monitor_test.cpp b/src/mongo/dbtests/replica_set_monitor_test.cpp index 188a85ce966..1e5a7699bea 100644 --- a/src/mongo/dbtests/replica_set_monitor_test.cpp +++ b/src/mongo/dbtests/replica_set_monitor_test.cpp @@ -47,6 +47,7 @@ using std::vector; using std::set; using std::string; using std::unique_ptr; +using unittest::assertGet; // TODO: Port these existing tests here: replmonitor_bad_seed.js, repl_monitor_refresh.js @@ -265,8 +266,8 @@ TEST_F(TwoNodeWithTags, SecDownRetryNoTag) { replSet->restore(secHost); - HostAndPort node = monitor->getHostOrRefresh( - ReadPreferenceSetting(mongo::ReadPreference::SecondaryOnly, TagSet())); + HostAndPort node = assertGet(monitor->getHostOrRefresh( + ReadPreferenceSetting(mongo::ReadPreference::SecondaryOnly, TagSet()), Milliseconds(0))); ASSERT_FALSE(monitor->isPrimary(node)); ASSERT_EQUALS(secHost, node.toString()); @@ -293,8 +294,8 @@ TEST_F(TwoNodeWithTags, SecDownRetryWithTag) { TagSet tags(BSON_ARRAY(BSON("dc" << "ny"))); - HostAndPort node = monitor->getHostOrRefresh( - ReadPreferenceSetting(mongo::ReadPreference::SecondaryOnly, tags)); + HostAndPort node = assertGet(monitor->getHostOrRefresh( + ReadPreferenceSetting(mongo::ReadPreference::SecondaryOnly, tags), Milliseconds(0))); ASSERT_FALSE(monitor->isPrimary(node)); ASSERT_EQUALS(secHost, node.toString()); |