We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 339d5b8 commit 9944ae0Copy full SHA for 9944ae0
src/sdam/monitor.rs
@@ -122,13 +122,15 @@ impl HeartbeatMonitor {
122
None => break,
123
};
124
125
+ // subscribe to check requests before performing the check in case one comes in
126
+ // after the check completes
127
+ let mut topology_check_requests_subscriber =
128
+ topology.subscribe_to_topology_check_requests();
129
+
130
if self.check_server(&topology, &server).await {
131
topology.notify_topology_changed();
132
}
133
- let mut topology_check_requests_subscriber =
- topology.subscribe_to_topology_check_requests();
-
134
// drop strong reference to topology before going back to sleep in case it drops off
135
// in between checks.
136
drop(topology);
0 commit comments