Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

server: Extract triggerCorruptAlarm to function

Browse Source 
Signed-off-by: Marek Siarkowicz <siarkowicz@google.com>
This commit is contained in:
Marek Siarkowicz
2022-06-13 13:56:52 +02:00
parent 204c0319a1
commit d32de2c410
1 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
server/etcdserver/corrupt.go
View File

@@ -175,14 +175,7 @@ func (s *EtcdServer) checkHashKV() error {
return return
} }
alarmed = true alarmed = true
a := &pb.AlarmRequest{ s.triggerCorruptAlarm(id)
MemberID: id,
Action: pb.AlarmRequest_ACTIVATE,
Alarm: pb.AlarmType_CORRUPT,
}
s.GoAttach(func() {
s.raftRequest(s.ctx, pb.InternalRaftRequest{Alarm: a})
})
} }
if h2 != h && rev2 == rev && crev == crev2 { if h2 != h && rev2 == rev && crev == crev2 {
@@ -245,6 +238,17 @@ func (s *EtcdServer) checkHashKV() error {
return nil 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 { type peerInfo struct {
id types.ID id types.ID
eps []string eps []string