diff options
Diffstat (limited to 'src/mongo/client/replica_set_monitor_interface.h')
| -rw-r--r-- | src/mongo/client/replica_set_monitor_interface.h | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/mongo/client/replica_set_monitor_interface.h b/src/mongo/client/replica_set_monitor_interface.h index 741f2e30af4..7faacadf9c1 100644 --- a/src/mongo/client/replica_set_monitor_interface.h +++ b/src/mongo/client/replica_set_monitor_interface.h @@ -36,6 +36,7 @@ #include "mongo/client/mongo_uri.h" #include "mongo/client/replica_set_change_notifier.h" +#include "mongo/util/cancelation.h" #include "mongo/util/duration.h" #include "mongo/util/net/hostandport.h" #include "mongo/util/time_support.h" @@ -78,11 +79,11 @@ public: * Known errors are: * FailedToSatisfyReadPreference, if node cannot be found, which matches the read preference. */ - virtual SemiFuture<HostAndPort> getHostOrRefresh( - const ReadPreferenceSetting& readPref, Milliseconds maxWait = kDefaultFindHostTimeout) = 0; + virtual SemiFuture<HostAndPort> getHostOrRefresh(const ReadPreferenceSetting& readPref, + const CancelationToken& cancelToken) = 0; virtual SemiFuture<std::vector<HostAndPort>> getHostsOrRefresh( - const ReadPreferenceSetting& readPref, Milliseconds maxWait = kDefaultFindHostTimeout) = 0; + const ReadPreferenceSetting& readPref, const CancelationToken& cancelToken) = 0; /** * Returns the host the RSM thinks is the current primary or uasserts. |