aboutsummaryrefslogtreecommitdiffstats
path: root/cmd/ovn4nfvk8s-cni/app/helper_linux.go
diff options
context:
space:
mode:
Diffstat (limited to 'cmd/ovn4nfvk8s-cni/app/helper_linux.go')
-rw-r--r--cmd/ovn4nfvk8s-cni/app/helper_linux.go38
1 files changed, 19 insertions, 19 deletions
diff --git a/cmd/ovn4nfvk8s-cni/app/helper_linux.go b/cmd/ovn4nfvk8s-cni/app/helper_linux.go
index fc4fd94..676901e 100644
--- a/cmd/ovn4nfvk8s-cni/app/helper_linux.go
+++ b/cmd/ovn4nfvk8s-cni/app/helper_linux.go
@@ -144,29 +144,29 @@ var ConfigureInterface = func(args *skel.CmdArgs, namespace, podName, macAddress
}
func setupRoute(netns ns.NetNS, dst, gw, dev string) error {
- // Add Route to the namespace
- err := netns.Do(func(_ ns.NetNS) error {
- dstAddr, dstAddrNet, _ := net.ParseCIDR(dst)
- ipNet := net.IPNet{IP: dstAddr, Mask: dstAddrNet.Mask}
- link, err := netlink.LinkByName(dev)
- err = ip.AddRoute(&ipNet, net.ParseIP(gw), link)
- if err != nil {
- logrus.Errorf("ip.AddRoute failed %v dst %v gw %v", err, dst, gw)
- }
- return err
- })
- return err
+ // Add Route to the namespace
+ err := netns.Do(func(_ ns.NetNS) error {
+ dstAddr, dstAddrNet, _ := net.ParseCIDR(dst)
+ ipNet := net.IPNet{IP: dstAddr, Mask: dstAddrNet.Mask}
+ link, err := netlink.LinkByName(dev)
+ err = ip.AddRoute(&ipNet, net.ParseIP(gw), link)
+ if err != nil {
+ logrus.Errorf("ip.AddRoute failed %v dst %v gw %v", err, dst, gw)
+ }
+ return err
+ })
+ return err
}
// ConfigureRoute sets up the container routes
var ConfigureRoute = func(args *skel.CmdArgs, dst, gw, dev string) error {
- netns, err := ns.GetNS(args.Netns)
- if err != nil {
- return fmt.Errorf("failed to open netns %q: %v", args.Netns, err)
- }
- defer netns.Close()
- err = setupRoute(netns, dst, gw, dev)
- return err
+ netns, err := ns.GetNS(args.Netns)
+ if err != nil {
+ return fmt.Errorf("failed to open netns %q: %v", args.Netns, err)
+ }
+ defer netns.Close()
+ err = setupRoute(netns, dst, gw, dev)
+ return err
}
// PlatformSpecificCleanup deletes the OVS port