summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorLamont Nelson <lamont.nelson@mongodb.com>2020-02-25 18:15:22 -0500
committerLamont Nelson <lamont.nelson@mongodb.com>2020-02-25 18:15:22 -0500
commit6357aefa448812c9f29f71bc7f418d7b944b79ee (patch)
treed3f5339188f0f5d434510b39bf9566171065dbeb
parent3b4d8f8933e773776abeb5bfb92e2d720d156744 (diff)
downloadmongo-6357aefa448812c9f29f71bc7f418d7b944b79ee.tar.gz
shutdown executor after shutting down rsm
-rw-r--r--src/mongo/client/replica_set_monitor_manager.cpp7
1 files changed, 2 insertions, 5 deletions
diff --git a/src/mongo/client/replica_set_monitor_manager.cpp b/src/mongo/client/replica_set_monitor_manager.cpp
index 57749b142a7..c315a61af98 100644
--- a/src/mongo/client/replica_set_monitor_manager.cpp
+++ b/src/mongo/client/replica_set_monitor_manager.cpp
@@ -181,11 +181,6 @@ void ReplicaSetMonitorManager::shutdown() {
taskExecutor = std::exchange(_taskExecutor, {});
}
- if (taskExecutor) {
- LOGV2_DEBUG(20188, 1, "Shutting down task executor used for monitoring replica sets");
- taskExecutor->shutdown();
- }
-
for (auto& [name, monitor] : monitors) {
auto anchor = monitor.lock();
if (!anchor) {
@@ -195,6 +190,8 @@ void ReplicaSetMonitorManager::shutdown() {
}
if (taskExecutor) {
+ LOGV2_DEBUG(20188, 1, "Shutting down task executor used for monitoring replica sets");
+ taskExecutor->shutdown();
taskExecutor->join();
}
}