fix underlay networking on node reboot

cmd/daemon/cniserver.go

@@ -28,6 +28,10 @@ func CmdMain() {
 
 	klog.Infof(versions.String())
 	daemon.InitMetrics()
+	if err := daemon.InitOVSBridges(); err != nil {
+		klog.Fatalf("failed to initialize OVS bridges: %v", err)
+	}
+
 	config, err := daemon.ParseFlags()
 	if err != nil {
 		klog.Fatalf("parse config failed %v", err)

pkg/daemon/init.go

@@ -7,13 +7,53 @@ import (
 	"strings"
 	"time"
 
+	"github.com/vishvananda/netlink"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/klog"
 
 	"github.com/kubeovn/kube-ovn/pkg/ovs"
 	"github.com/kubeovn/kube-ovn/pkg/util"
 )
 
+// InitOVSBridges initializes OVS bridges
+func InitOVSBridges() error {
+	bridges, err := ovs.Bridges()
+	if err != nil {
+		return err
+	}
+
+	for _, brName := range bridges {
+		bridge, err := netlink.LinkByName(brName)
+		if err != nil {
+			return fmt.Errorf("failed to get bridge by name %s: %v", brName, err)
+		}
+		if err = netlink.LinkSetUp(bridge); err != nil {
+			return fmt.Errorf("failed to set OVS bridge %s up: %v", brName, err)
+		}
+
+		output, err := ovs.Exec("list-ports", brName)
+		if err != nil {
+			return fmt.Errorf("failed to list ports of OVS birdge %s, %v: %q", brName, err, output)
+		}
+
+		if output != "" {
+			for _, port := range strings.Split(output, "\n") {
+				ok, err := ovs.ValidatePortVendor(port)
+				if err != nil {
+					return fmt.Errorf("failed to check vendor of port %s: %v", port, err)
+				}
+				if ok {
+					if _, err = configProviderNic(port, brName); err != nil {
+						return err
+					}
+				}
+			}
+		}
+	}
+
+	return nil
+}
+
 // InitNodeGateway init ovn0
 func InitNodeGateway(config *Configuration) error {
 	var portName, ip, cidr, macAddr, gw, ipAddr string

pkg/ovs/ovs-vsctl.go

@@ -94,6 +94,11 @@ func ovsClear(table, record string, columns ...string) error {
 	return err
 }
 
+// Bridges returns bridges created by Kube-OVN
+func Bridges() ([]string, error) {
+	return ovsFind("bridge", "name", fmt.Sprintf("external-ids:vendor=%s", util.CniTypeName))
+}
+
 // ClearPodBandwidth remove qos related to this pod. Only used when remove pod.
 func ClearPodBandwidth(podName, podNamespace string) error {
 	qosList, err := ovsFind("qos", "_uuid", fmt.Sprintf(`external-ids:iface-id="%s.%s"`, podName, podNamespace))