From 70fbc0b3e72a3b8a99ba9c0d95c109fb0b0b2019 Mon Sep 17 00:00:00 2001 From: Marek Siarkowicz Date: Mon, 13 Jun 2022 13:56:52 +0200 Subject: [PATCH] server: Extract triggerCorruptAlarm to function Signed-off-by: Marek Siarkowicz --- server/etcdserver/corrupt.go | 20 ++++++++++++-------- 1 file changed, 12 insertions(+), 8 deletions(-) diff --git a/server/etcdserver/corrupt.go b/server/etcdserver/corrupt.go index 133bcafb6..c8a0437dc 100644 --- a/server/etcdserver/corrupt.go +++ b/server/etcdserver/corrupt.go @@ -174,14 +174,7 @@ func (s *EtcdServer) checkHashKV() error { return } alarmed = true - a := &pb.AlarmRequest{ - MemberID: id, - Action: pb.AlarmRequest_ACTIVATE, - Alarm: pb.AlarmType_CORRUPT, - } - s.GoAttach(func() { - s.raftRequest(s.ctx, pb.InternalRaftRequest{Alarm: a}) - }) + s.triggerCorruptAlarm(id) } if h2 != h && rev2 == rev && crev == crev2 { @@ -244,6 +237,17 @@ func (s *EtcdServer) checkHashKV() error { return nil } +func (s *EtcdServer) triggerCorruptAlarm(id uint64) { + a := &pb.AlarmRequest{ + MemberID: id, + Action: pb.AlarmRequest_ACTIVATE, + Alarm: pb.AlarmType_CORRUPT, + } + s.GoAttach(func() { + s.raftRequest(s.ctx, pb.InternalRaftRequest{Alarm: a}) + }) +} + type peerInfo struct { id types.ID eps []string