feat: verify node internal address

deepflowio · Feb 28, 2025 · bfca9bc · bfca9bc
1 parent 3cd2f94
commit bfca9bc
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/server/controller/cloud/common/net.go b/server/controller/cloud/common/net.go
@@ -66,6 +66,8 @@ func TidyIPString(ipsString []string) (v4Prefix, v6Prefix []netaddr.IPPrefix, er
 				ipS = ipS + "/32"
 			case strings.Contains(ipS, ":"):
 				ipS = ipS + "/128"
+			default:
+				continue
 			}
 		}
 		ipPrefix, prefixErr := netaddr.ParseIPPrefix(ipS)

diff --git a/server/controller/cloud/kubernetes_gather/pod_node.go b/server/controller/cloud/kubernetes_gather/pod_node.go
@@ -60,6 +60,10 @@ func (k *KubernetesGather) getPodNodes() (podNodes []model.PodNode, nodeNetwork,
 				continue
 			}
 			nIP := nodeIPitem.Get("address").MustString()
+			if nIP == "" {
+				log.Warningf("invalid node internal address (%s)", nIP)
+				continue
+			}
 			nodeIPs = append(nodeIPs, nIP)
 		}
 		if len(nodeIPs) == 0 {