rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-01-06 21:32:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: add log on leader stepdown (#1450)

Browse Source
This commit is contained in:
JeremyHi
2023-04-24 19:16:57 +08:00
committed by GitHub
parent 2cf828da3c
commit 6d247f73fd
2 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/meta-srv/src/election/etcd.rs
View File

@@ -134,9 +134,7 @@ impl Election for EtcdElection {
.context(error::EtcdFailedSnafu)?; .context(error::EtcdFailedSnafu)?;
if let Some(leader) = res.leader() { if let Some(leader) = res.leader() {
let (mut keeper, mut receiver) = self let (mut keeper, mut receiver) = lease_client
.client
.lease_client()
.keep_alive(lease_id) .keep_alive(lease_id)
.await .await
.context(error::EtcdFailedSnafu)?; .context(error::EtcdFailedSnafu)?;
@@ -165,11 +163,13 @@ impl Election for EtcdElection {
} }
} }
} else { } else {
if let Err(e) = self if self.is_leader.load(Ordering::Relaxed) {
.leader_watcher if let Err(e) = self
.send(LeaderChangeMessage::StepDown(Arc::new(leader.clone()))) .leader_watcher
{ .send(LeaderChangeMessage::StepDown(Arc::new(leader.clone())))
error!("Failed to send leader change message, error: {e}"); {
error!("Failed to send leader change message, error: {e}");
}
} }
break; break;
} }

4
src/meta-srv/src/metasrv.rs
View File

@@ -141,9 +141,9 @@ impl MetaSrv {
error!("Failed to recover procedures, error: {e}"); error!("Failed to recover procedures, error: {e}");
} }
} }
LeaderChangeMessage::StepDown(_) => { LeaderChangeMessage::StepDown(leader) => {
// TODO(LFC): TBC // TODO(LFC): TBC
unimplemented!() error!("Leader :{:?} step down", leader);
} }
} }
} }