summaryrefslogtreecommitdiff
path: root/src/mongo/db/process_health/fault_manager.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/process_health/fault_manager.cpp')
-rw-r--r--src/mongo/db/process_health/fault_manager.cpp5
1 files changed, 2 insertions, 3 deletions
diff --git a/src/mongo/db/process_health/fault_manager.cpp b/src/mongo/db/process_health/fault_manager.cpp
index 9b203c23823..46c049946c6 100644
--- a/src/mongo/db/process_health/fault_manager.cpp
+++ b/src/mongo/db/process_health/fault_manager.cpp
@@ -158,7 +158,7 @@ void FaultManager::schedulePeriodicHealthCheckThread(bool immediately) {
}
FaultManager::~FaultManager() {
- _managerShuttingDownCancellationSource.cancel();
+ _managerShuttingDownCancellation->store(true);
_taskExecutor->shutdown();
LOGV2(5936601, "Shutting down periodic health checks");
@@ -230,9 +230,8 @@ void FaultManager::healthCheck() {
std::vector<HealthObserver*> observers = FaultManager::getHealthObservers();
// Start checks outside of lock.
- auto token = _managerShuttingDownCancellationSource.token();
for (auto observer : observers) {
- observer->periodicCheck(*this, _taskExecutor, token);
+ observer->periodicCheck(*this, _taskExecutor, _managerShuttingDownCancellation);
}
// Garbage collect all resolved fault facets.