From 06b5b50f22d53797b6ce6fdb3883655a316d108c Mon Sep 17 00:00:00 2001 From: jeremyhi Date: Mon, 15 Apr 2024 16:46:17 +0800 Subject: [PATCH] chore: debt 3696 --- src/meta-client/src/client.rs | 6 ------ src/meta-srv/src/election/etcd.rs | 2 +- 2 files changed, 1 insertion(+), 7 deletions(-) diff --git a/src/meta-client/src/client.rs b/src/meta-client/src/client.rs index fed97c568193..ddb169ebc5d5 100644 --- a/src/meta-client/src/client.rs +++ b/src/meta-client/src/client.rs @@ -468,28 +468,24 @@ impl MetaClient { Ok(res) } - #[inline] pub fn heartbeat_client(&self) -> Result { self.heartbeat.clone().context(NotStartedSnafu { name: "heartbeat_client", }) } - #[inline] pub fn store_client(&self) -> Result { self.store.clone().context(NotStartedSnafu { name: "store_client", }) } - #[inline] pub fn lock_client(&self) -> Result { self.lock.clone().context(NotStartedSnafu { name: "lock_client", }) } - #[inline] pub fn procedure_client(&self) -> Result { self.procedure.clone().context(NotStartedSnafu { name: "procedure_client", @@ -502,12 +498,10 @@ impl MetaClient { }) } - #[inline] pub fn channel_config(&self) -> &ChannelConfig { self.channel_manager.config() } - #[inline] pub fn id(&self) -> Id { self.id } diff --git a/src/meta-srv/src/election/etcd.rs b/src/meta-srv/src/election/etcd.rs index 695808a78728..0b615c78e6e0 100644 --- a/src/meta-srv/src/election/etcd.rs +++ b/src/meta-srv/src/election/etcd.rs @@ -166,7 +166,7 @@ impl Election for EtcdElection { if let Some(res) = receiver.message().await.context(error::EtcdFailedSnafu)? { if res.ttl() <= 0 { - // Failed to keep alive, just break the loop. + warn!("Candidate lease expired, key: {}", self.candidate_key()); break; } }