gian/cubefs
1
0
Fork 0
mirror of https://github.com/cubefs/cubefs.git synced 2026-08-02 02:00:56 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(raft): fix raft manager interface convert problem

Browse Source 
with #22357426

Signed-off-by: xiejian <xiejian3@oppo.com>
This commit is contained in:
xiejian 2024-09-24 19:55:59 +08:00 committed by slasher
parent 2a57182e15
commit d2facf68d9
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
blobstore/common/raft/manager.go
View File

@ -609,12 +609,12 @@ func (m *manager) sendQueuedHeartbeatsToNode(
if err := m.transport.SendAsync(ctx, chReq, systemConnectionClass); err != nil {
for i := range beats {
if value, ok := m.groups.Load(beats[i].GroupID); ok {
value.(*internalGroupProcessor).AddUnreachableRemoteReplica(chReq.To)
(*internalGroupProcessor)(value.(*group)).AddUnreachableRemoteReplica(chReq.To)
}
}
for i := range resps {
if value, ok := m.groups.Load(resps[i].GroupID); ok {
value.(*internalGroupProcessor).AddUnreachableRemoteReplica(chReq.To)
(*internalGroupProcessor)(value.(*group)).AddUnreachableRemoteReplica(chReq.To)
}
}