Added retry of the GetAllPeers status check.

Author: gamolina

shared/connection.go

@@ -863,7 +863,15 @@ func (m *Conn) GetAllPeerStatus() {
 
 	// Get the node status for all nodes in the cluster
 	for k, v := range m.nodeMap {
-		status, err := m.getNodeStatusForIndex(v)
+		var status *pb.StatusMessage
+		err := Retry(5, 5 * time.Second, func() (err error) {
+			var errx error
+			status, err = m.getNodeStatusForIndex(v)
+			if errx != nil {
+				err = errx
+			}
+			return
+		})
 
 		// u.Debug("GetAllPeerStatus getNodeStatusForIndex", m.owner, k, v, status.NodeState)
 		if err == nil {

version.txt

@@ -1,3 +1,3 @@
-quanta 0.9.16-rc-3
+quanta 0.9.16-rc-4