Skip to content

Commit

Permalink
chore: apply suggestions from CR
Browse files Browse the repository at this point in the history
  • Loading branch information
WenyXu committed Jul 12, 2024
1 parent 7dda31c commit 640e462
Showing 1 changed file with 5 additions and 2 deletions.
7 changes: 5 additions & 2 deletions src/meta-srv/src/election/etcd.rs
Original file line number Diff line number Diff line change
Expand Up @@ -256,15 +256,18 @@ impl Election for EtcdElection {
}
}

if self.is_leader.load(Ordering::Relaxed) {
if self
.is_leader
.compare_exchange(true, false, Ordering::Relaxed, Ordering::Relaxed)
.is_ok()
{
if let Err(e) = self
.leader_watcher
.send(LeaderChangeMessage::StepDown(Arc::new(leader.clone())))
{
error!(e; "Failed to send leader change message");
}
}
self.is_leader.store(false, Ordering::Relaxed);
}

Ok(())
Expand Down

0 comments on commit 640e462

Please sign in to comment.