add loop check for tunnel nic (#4736)

* add loop check for tunnel nic

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

* fix gofumpt err

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

---------

Signed-off-by: dolibali <[email protected]>
Co-authored-by: dolibali <[email protected]>

Author: dolibali

pkg/daemon/controller.go

@@ -596,6 +596,7 @@ func (c *Controller) Run(stopCh <-chan struct{}) {
 	klog.Info("Started workers")
 	go wait.Until(c.loopOvn0Check, 5*time.Second, stopCh)
 	go wait.Until(c.loopOvnExt0Check, 5*time.Second, stopCh)
+	go wait.Until(c.loopTunnelCheck, 5*time.Second, stopCh)
 	go wait.Until(c.runAddOrUpdateProviderNetworkWorker, time.Second, stopCh)
 	go wait.Until(c.runDeleteProviderNetworkWorker, time.Second, stopCh)
 	go wait.Until(c.runSubnetWorker, time.Second, stopCh)

pkg/daemon/ovs_linux.go

@@ -714,6 +714,36 @@ func (c *Controller) loopOvn0Check() {
 	}
 }
 
+// This method checks the status of the tunnel interface,
+// If the interface is found to be down, it attempts to bring it up
+func (c *Controller) loopTunnelCheck() {
+	tunnelType := c.config.NetworkType
+	var tunnelNic string
+	switch tunnelType {
+	case "vxlan":
+		tunnelNic = util.VxlanNic
+	case "geneve":
+		tunnelNic = util.GeneveNic
+	case "stt":
+		// TODO: tunnelNic = "stt tunnel nic name"
+		return
+	default:
+		return
+	}
+
+	link, err := netlink.LinkByName(tunnelNic)
+	if err != nil || link == nil {
+		return
+	}
+
+	if link.Attrs().OperState == netlink.OperDown {
+		klog.Errorf("nic: %s is down, attempting to bring it up", tunnelNic)
+		if err := netlink.LinkSetUp(link); err != nil {
+			klog.Errorf("fail to bring up nic: %s, %v", tunnelNic, err)
+		}
+	}
+}
+
 func (c *Controller) checkNodeGwNicInNs(nodeExtIP, ip, gw string, gwNS ns.NetNS) error {
 	exists, err := ovs.PortExists(util.NodeGwNic)
 	if err != nil {

pkg/daemon/ovs_windows.go

@@ -343,6 +343,10 @@ func (c *Controller) loopOvnExt0Check() {
 	// no need to check ovnext0 on Windows
 }
 
+func (c *Controller) loopTunnelCheck() {
+	// no need to check tunnel on Windows
+}
+
 func configureMirrorLink(portName string, mtu int) error {
 	adapter, err := util.GetNetAdapter(portName, false)
 	if err != nil {

pkg/util/const.go

@@ -133,6 +133,9 @@ const (
 	NodeLspPrefix     = "node-"
 	NodeAllowPriority = "3000"
 
+	VxlanNic  = "vxlan_sys_4789"
+	GeneveNic = "genev_sys_6081"
+
 	SecurityGroupHighestPriority = "2300"
 	SecurityGroupBasePriority    = "2005"
 	SecurityGroupAllowPriority   = "2004"