rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-01-10 15:22:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: update frontend heartbeat as well

Browse Source
This commit is contained in:
Ning Sun
2024-06-10 13:39:07 -07:00
parent cb2047dacc
commit a8902890cf
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/frontend/src/heartbeat.rs
View File

@@ -85,7 +85,7 @@ impl HeartbeatTask {
let capture_self = self.clone();
let retry_interval = self.retry_interval;
let _handle = common_runtime::spawn_bg(async move {
let _handle = common_runtime::spawn_hb(async move {
loop {
match resp_stream.message().await {
Ok(Some(resp)) => {
@@ -132,7 +132,7 @@ impl HeartbeatTask {
addr: self.server_addr.clone(),
});
common_runtime::spawn_bg(async move {
common_runtime::spawn_hb(async move {
let sleep = tokio::time::sleep(Duration::from_millis(0));
tokio::pin!(sleep);