Browse Source

initialize failover peer map

Abhishek Kondur 1 year ago
parent
commit
670f06f3d0
1 changed files with 6 additions and 0 deletions
  1. 6 0
      pro/logic/failover.go

+ 6 - 0
pro/logic/failover.go

@@ -9,6 +9,12 @@ import (
 )
 )
 
 
 func SetFailOverCtx(failOverNode, victimNode, peerNode models.Node) error {
 func SetFailOverCtx(failOverNode, victimNode, peerNode models.Node) error {
+	if peerNode.FailOverPeers == nil {
+		peerNode.FailOverPeers = make(map[string]struct{})
+	}
+	if victimNode.FailOverPeers == nil {
+		victimNode.FailOverPeers = make(map[string]struct{})
+	}
 	peerNode.FailOverPeers[victimNode.ID.String()] = struct{}{}
 	peerNode.FailOverPeers[victimNode.ID.String()] = struct{}{}
 	victimNode.FailOverPeers[peerNode.ID.String()] = struct{}{}
 	victimNode.FailOverPeers[peerNode.ID.String()] = struct{}{}
 	victimNode.FailedOverBy = failOverNode.ID
 	victimNode.FailedOverBy = failOverNode.ID