fix repeate set chassis (#3083)

* fix repeate set chassis

* fail fast

* fix go gmt

Author: zbb88888

pkg/controller/controller.go

@@ -782,6 +782,10 @@ func (c *Controller) Run(ctx context.Context) {
 		util.LogFatalAndExit(err, "failed to initialize ovn resources")
 	}
 
+	if err := c.initNodeChassis(); err != nil {
+		util.LogFatalAndExit(err, "failed to initialize node chassis")
+	}
+
 	// sync ip crd before initIPAM since ip crd will be used to restore vm and statefulset pod in initIPAM
 	if err := c.initSyncCrdIPs(); err != nil {
 		util.LogFatalAndExit(err, "failed to sync crd ips")
@@ -791,10 +795,6 @@ func (c *Controller) Run(ctx context.Context) {
 		util.LogFatalAndExit(err, "failed to initialize ipam")
 	}
 
-	if err := c.initNodeChassis(); err != nil {
-		util.LogFatalAndExit(err, "failed to initialize node chassis")
-	}
-
 	if err := c.initNodeRoutes(); err != nil {
 		util.LogFatalAndExit(err, "failed to initialize node routes")
 	}

pkg/controller/init.go

@@ -853,6 +853,14 @@ func (c *Controller) initNodeChassis() error {
 	for _, node := range nodes {
 		chassisName := node.Annotations[util.ChassisAnnotation]
 		if chassisName != "" {
+			existChasisId, err := c.ovnLegacyClient.GetChassis(node.Name)
+			if err != nil {
+				klog.Errorf("failed to get chassis id: %v", err)
+				return err
+			}
+			if existChasisId == chassisName {
+				continue
+			}
 			exist, err := c.ovnLegacyClient.ChassisExist(chassisName)
 			if err != nil {
 				klog.Errorf("failed to check chassis exist: %v", err)

pkg/speaker/subnet.go

@@ -96,7 +96,7 @@ func (c *Controller) syncSubnetRoutes() {
 		}
 	}
 
-	klog.V(5).Infof("expected announce ipv4 routes %v\n,ipv6 route %v", bgpExpected[kubeovnv1.ProtocolIPv4], bgpExpected[kubeovnv1.ProtocolIPv6])
+	klog.V(5).Infof("expected announce ipv4 routes: %v, ipv6 routes: %v", bgpExpected[kubeovnv1.ProtocolIPv4], bgpExpected[kubeovnv1.ProtocolIPv6])
 
 	fn := func(d *bgpapi.Destination) {
 		for _, path := range d.Paths {