diff options
Diffstat (limited to 'src/mongo/db/process_health/fault_manager.cpp')
-rw-r--r-- | src/mongo/db/process_health/fault_manager.cpp | 5 |
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. |