SERVER-61930: Individual health observers should return an error if a

timeout period elapses when doing a single health check.

1 files changed, 32 insertions, 1 deletions

diff --git a/src/mongo/db/process_health/health_observer_test.cpp b/src/mongo/db/process_health/health_observer_test.cpp
index 55a9fa2c85e..b8dce4fb768 100644
--- a/src/mongo/db/process_health/health_observer_test.cpp
+++ b/src/mongo/db/process_health/health_observer_test.cpp
@@ -106,7 +106,7 @@ TEST_F(FaultManagerTest, Stats) {
 
 TEST_F(FaultManagerTest, ProgressMonitorCheck) {
     AtomicWord<bool> shouldBlock{true};
-    registerMockHealthObserver(FaultFacetType::kMock1, [this, &shouldBlock] {
+    registerMockHealthObserver(FaultFacetType::kMock1, [&shouldBlock] {
         while (shouldBlock.load()) {
             sleepFor(Milliseconds(1));
         }
@@ -170,6 +170,37 @@ TEST_F(FaultManagerTest, PeriodicHealthCheckOnErrorMakesBadHealthStatus) {
     });
 }
 
+TEST_F(FaultManagerTest,
+       DeadlineFutureCausesTransientFaultWhenObserverBlocksAndGetsResolvedWhenObserverUnblocked) {
+    resetManager(std::make_unique<FaultManagerConfig>());
+    RAIIServerParameterControllerForTest _flagController{"featureFlagHealthMonitoring", true};
+    RAIIServerParameterControllerForTest _serverParamController{"activeFaultDurationSecs", 5};
+
+    AtomicWord<bool> shouldBlock{true};
+    registerMockHealthObserver(FaultFacetType::kMock1,
+                               [&shouldBlock] {
+                                   while (shouldBlock.load()) {
+                                       sleepFor(Milliseconds(1));
+                                   }
+                                   return 0.0;
+                               },
+                               Milliseconds(100));
+
+    ASSERT_TRUE(manager().getFaultState() == FaultState::kStartupCheck);
+
+    auto initialHealthCheckFuture = manager().startPeriodicHealthChecks();
+
+    assertSoon([this] {
+        return manager().currentFault() && manager().getFaultState() == FaultState::kStartupCheck;
+    });
+
+    shouldBlock.store(false);
+
+    assertSoon([this] { return manager().getFaultState() == FaultState::kOk; });
+
+    resetManager();  // Before fields above go out of scope.
+}
+
 }  // namespace
 }  // namespace process_health
 }  // namespace mongo