fix: network null pointer exceptions

Signed-off-by: wangyizhi1 <[email protected]>

Author: wangyizhi1

pkg/apis/kosmos/v1alpha1/cluster_types.go

@@ -36,20 +36,20 @@ type ClusterSpec struct {
 	ImageRepository string `json:"imageRepository,omitempty"`
 
 	// +optional
-	ClusterLinkOptions ClusterLinkOptions `json:"clusterLinkOptions,omitempty"`
+	ClusterLinkOptions *ClusterLinkOptions `json:"clusterLinkOptions,omitempty"`
 
 	// +optional
-	ClusterTreeOptions ClusterTreeOptions `json:"clusterTreeOptions,omitempty"`
+	ClusterTreeOptions *ClusterTreeOptions `json:"clusterTreeOptions,omitempty"`
 }
 
 type ClusterStatus struct {
 	// ClusterLinkStatus contain the cluster network information
 	// +optional
-	ClusterLinkStatus ClusterLinkStatus `json:"clusterLinkStatus,omitempty"`
+	ClusterLinkStatus *ClusterLinkStatus `json:"clusterLinkStatus,omitempty"`
 
 	// ClusterTreeStatus contain the member cluster leafNode end status
 	// +optional
-	ClusterTreeStatus ClusterTreeStatus `json:"clusterTreeStatus,omitempty"`
+	ClusterTreeStatus *ClusterTreeStatus `json:"clusterTreeStatus,omitempty"`
 }
 
 type ClusterLinkOptions struct {
@@ -173,9 +173,15 @@ type ClusterList struct {
 }
 
 func (c *Cluster) IsP2P() bool {
+	if c.Spec.ClusterLinkOptions == nil {
+		return false
+	}
 	return c.Spec.ClusterLinkOptions.NetworkType == NetworkTypeP2P
 }
 
 func (c *Cluster) IsGateway() bool {
+	if c.Spec.ClusterLinkOptions == nil {
+		return false
+	}
 	return c.Spec.ClusterLinkOptions.NetworkType == NetWorkTypeGateWay
 }

pkg/apis/kosmos/v1alpha1/zz_generated.deepcopy.go

@@ -143,7 +143,17 @@ func BuildRoutes(ctx *Context, target *v1alpha1.ClusterNode, cidrs []string) {
 			}
 
 			gw := ctx.Filter.GetGatewayNodeByClusterName(n.Spec.ClusterName)
+			if gw == nil {
+				klog.Warning("cannot find gateway node, cluster name: %s", n.Spec.ClusterName)
+				continue
+			}
+
 			gwDev := ctx.GetDeviceFromResults(gw.Name, vxLocal)
+			if gwDev == nil {
+				klog.Warning("cannot find the gw dev, nodeName: %s, devName: %s", gw.Name, vxLocal)
+				continue
+			}
+
 			gwIP, _, err := net.ParseCIDR(gwDev.Addr)
 			if err != nil {
 				klog.Warning("cannot parse gw dev addr, nodeName: %s, devName: %s", gw.Name, vxLocal)

pkg/clusterlink/network-manager/handlers/pod_routes.go

@@ -20,6 +20,10 @@ func (h *VxLocalMacCache) Do(c *Context) (err error) {
 	for _, node := range nodes {
 		ipTypes := h.getSupportIPTypes(node, c)
 		gw := c.Filter.GetGatewayNodeByClusterName(node.Spec.ClusterName)
+		if gw == nil {
+			klog.Warning("cannot find gateway node, cluster name: %s", node.Spec.ClusterName)
+			continue
+		}
 
 		for _, ipType := range ipTypes {
 			fdb, arp, err := h.buildVxLocalCachesByNode(c, ipType, gw)

pkg/clusterlink/network-manager/handlers/vxlocal_mac_cache.go

@@ -215,7 +215,7 @@ func (o *CommandJoinOptions) runCluster() error {
 			Kubeconfig:      o.KubeConfigStream,
 			Namespace:       o.Namespace,
 			ImageRepository: o.ImageRegistry,
-			ClusterLinkOptions: v1alpha1.ClusterLinkOptions{
+			ClusterLinkOptions: &v1alpha1.ClusterLinkOptions{
 				Enable: o.EnableLink,
 				BridgeCIDRs: v1alpha1.VxlanCIDRs{
 					IP:  "220.0.0.0/8",
@@ -228,7 +228,7 @@ func (o *CommandJoinOptions) runCluster() error {
 				NetworkType: v1alpha1.NetWorkTypeGateWay,
 				IPFamily:    v1alpha1.IPFamilyTypeIPV4,
 			},
-			ClusterTreeOptions: v1alpha1.ClusterTreeOptions{
+			ClusterTreeOptions: &v1alpha1.ClusterTreeOptions{
 				Enable: o.EnableTree,
 			},
 		},