summaryrefslogtreecommitdiff
path: root/src/mongo/client/dbclient_rs.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/client/dbclient_rs.cpp')
-rw-r--r--src/mongo/client/dbclient_rs.cpp8
1 files changed, 6 insertions, 2 deletions
diff --git a/src/mongo/client/dbclient_rs.cpp b/src/mongo/client/dbclient_rs.cpp
index 7d398bce6bb..acd2f116d7f 100644
--- a/src/mongo/client/dbclient_rs.cpp
+++ b/src/mongo/client/dbclient_rs.cpp
@@ -422,7 +422,10 @@ DBClientConnection& DBClientReplicaSet::secondaryConn() {
bool DBClientReplicaSet::connect() {
// Returns true if there are any up hosts.
const ReadPreferenceSetting anyUpHost(ReadPreference::Nearest, TagSet());
- return _getMonitor()->getHostOrRefresh(anyUpHost).getNoThrow().isOK();
+ return _getMonitor()
+ ->getHostOrRefresh(anyUpHost, CancelationToken::uncancelable())
+ .getNoThrow()
+ .isOK();
}
template <typename Authenticate>
@@ -759,7 +762,8 @@ DBClientConnection* DBClientReplicaSet::selectNodeUsingTags(
ReplicaSetMonitorPtr monitor = _getMonitor();
- auto selectedNodeStatus = monitor->getHostOrRefresh(*readPref).getNoThrow();
+ auto selectedNodeStatus =
+ monitor->getHostOrRefresh(*readPref, CancelationToken::uncancelable()).getNoThrow();
if (!selectedNodeStatus.isOK()) {
LOGV2_DEBUG(20138,
3,