From ed1cb73ffc7ec11f29ff11886dec7219e2e48ba5 Mon Sep 17 00:00:00 2001
From: LFC <luofucong@greptime.com>
Date: Tue, 28 Mar 2023 13:50:35 +0800
Subject: [PATCH] fix: a minor misuse of tokio::select (#1266)

---
 src/meta-srv/src/handler/failure_handler/runner.rs | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/meta-srv/src/handler/failure_handler/runner.rs b/src/meta-srv/src/handler/failure_handler/runner.rs
index d0b517c1d1..74922fa765 100644
--- a/src/meta-srv/src/handler/failure_handler/runner.rs
+++ b/src/meta-srv/src/handler/failure_handler/runner.rs
@@ -16,7 +16,7 @@ use std::ops::DerefMut;
 use std::sync::Arc;
 use std::time::{Duration, Instant};
 
-use common_telemetry::error;
+use common_telemetry::{error, warn};
 use common_time::util::current_time_millis;
 use dashmap::mapref::multiple::RefMulti;
 use dashmap::DashMap;
@@ -111,6 +111,10 @@ impl FailureDetectRunner {
                             detector.heartbeat(heartbeat.heartbeat_time);
                         }
                     }
+                    else => {
+                        warn!("Both control and heartbeat senders are closed, quit receiving.");
+                        break;
+                    }
                 }
             }
         });