From 2f8a221a91e44bfccb2b31880a26697e7f8cb341 Mon Sep 17 00:00:00 2001 From: Aaron Smith Date: Fri, 20 Nov 2020 10:38:02 -0500 Subject: [PATCH] Additional cleanup format --- pkg/daemon/plugin.go | 5 ++- pkg/plugins/virtual/virtual_plugin.go | 8 ----- pkg/utils/utils_virtual.go | 51 +++++++++++++-------------- 3 files changed, 26 insertions(+), 38 deletions(-) diff --git a/pkg/daemon/plugin.go b/pkg/daemon/plugin.go index 182041863..9f490f757 100644 --- a/pkg/daemon/plugin.go +++ b/pkg/daemon/plugin.go @@ -22,9 +22,8 @@ type VendorPlugin interface { } var pluginMap = map[string]string{ - "8086": "intel_plugin", - "15b3": "mellanox_plugin", - "virtual": "virtual_plugin", + "8086": "intel_plugin", + "15b3": "mellanox_plugin", } const ( diff --git a/pkg/plugins/virtual/virtual_plugin.go b/pkg/plugins/virtual/virtual_plugin.go index a38109992..7cac658c6 100644 --- a/pkg/plugins/virtual/virtual_plugin.go +++ b/pkg/plugins/virtual/virtual_plugin.go @@ -50,13 +50,10 @@ func (p *VirtualPlugin) Spec() string { // OnNodeStateAdd Invoked when SriovNetworkNodeState CR is created, return if need dain and/or reboot node func (p *VirtualPlugin) OnNodeStateAdd(state *sriovnetworkv1.SriovNetworkNodeState) (needDrain bool, needReboot bool, err error) { glog.Info("virtual-plugin OnNodeStateAdd()") - needDrain = false needReboot = false err = nil p.DesireState = state - needDrain = needDrainNode(state.Spec.Interfaces, state.Status.Interfaces) - if p.LoadVfioDriver != loaded { if needVfioDriver(state) { p.LoadVfioDriver = loading @@ -134,8 +131,3 @@ func isCommandNotFound(err error) bool { } return false } - -func needDrainNode(desired sriovnetworkv1.Interfaces, current sriovnetworkv1.InterfaceExts) (needDrain bool) { - needDrain = false - return -} diff --git a/pkg/utils/utils_virtual.go b/pkg/utils/utils_virtual.go index 31279310c..8848ec2d6 100644 --- a/pkg/utils/utils_virtual.go +++ b/pkg/utils/utils_virtual.go @@ -143,35 +143,32 @@ func configSriovDeviceVirtual(iface *sriovnetworkv1.Interface, ifaceStatus *srio glog.Warningf("configSriovDeviceVirtual(): missing VFGroup") return errors.New("NumVfs != 1") } - vfAddrs := []string{iface.PciAddress} - glog.V(2).Infof("configSriovDeviceVirtual(): vfaddrs %v", vfAddrs) - for _, addr := range vfAddrs { - glog.V(2).Infof("configSriovDeviceVirtual(): addr %s", addr) - driver := "" - vfID := 0 - for _, group := range iface.VfGroups { - glog.V(2).Infof("configSriovDeviceVirtual(): group %v", group) - if sriovnetworkv1.IndexInRange(vfID, group.VfRange) { - glog.V(2).Infof("configSriovDeviceVirtual(): indexInRange %d", vfID) - if sriovnetworkv1.StringInArray(group.DeviceType, DpdkDrivers) { - glog.V(2).Infof("configSriovDeviceVirtual(): driver %s", group.DeviceType) - driver = group.DeviceType - } - break + addr := iface.PciAddress + glog.V(2).Infof("configSriovDeviceVirtual(): addr %s", addr) + driver := "" + vfID := 0 + for _, group := range iface.VfGroups { + glog.V(2).Infof("configSriovDeviceVirtual(): group %v", group) + if sriovnetworkv1.IndexInRange(vfID, group.VfRange) { + glog.V(2).Infof("configSriovDeviceVirtual(): indexInRange %d", vfID) + if sriovnetworkv1.StringInArray(group.DeviceType, DpdkDrivers) { + glog.V(2).Infof("configSriovDeviceVirtual(): driver %s", group.DeviceType) + driver = group.DeviceType } + break } - if driver == "" { - glog.V(2).Infof("configSriovDeviceVirtual(): bind default") - if err := BindDefaultDriver(addr); err != nil { - glog.Warningf("configSriovDeviceVirtual(): fail to bind default driver for device %s", addr) - return err - } - } else { - glog.V(2).Infof("configSriovDeviceVirtual(): bind driver %s", driver) - if err := BindDpdkDriver(addr, driver); err != nil { - glog.Warningf("configSriovDeviceVirtual(): fail to bind driver %s for device %s", driver, addr) - return err - } + } + if driver == "" { + glog.V(2).Infof("configSriovDeviceVirtual(): bind default") + if err := BindDefaultDriver(addr); err != nil { + glog.Warningf("configSriovDeviceVirtual(): fail to bind default driver for device %s", addr) + return err + } + } else { + glog.V(2).Infof("configSriovDeviceVirtual(): bind driver %s", driver) + if err := BindDpdkDriver(addr, driver); err != nil { + glog.Warningf("configSriovDeviceVirtual(): fail to bind driver %s for device %s", driver, addr) + return err } } }