fix: a minor misuse of tokio::select (#1266)

This commit is contained in:
LFC
2023-03-28 13:50:35 +08:00
committed by GitHub
parent 0ffa628c22
commit ed1cb73ffc

View File

@@ -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;
}
}
}
});