Skip to content
This repository was archived by the owner on Apr 8, 2025. It is now read-only.

Commit fefc9b5

Browse files
johnoloughlinjohnoloughlin
committed
api updates
updates flagged by golangci-lint Signed-off-by: John O'Loughlin <[email protected]>
1 parent 4e5d240 commit fefc9b5

24 files changed

+177
-219
lines changed

Diff for: ‎cniovs/cniovs.go

+17-19
Original file line numberDiff line numberDiff line change
@@ -48,23 +48,17 @@ import (
4848
"github.com/intel/userspace-cni-network-plugin/pkg/types"
4949
)
5050

51-
//
5251
// Constants
53-
//
5452
const (
5553
defaultBridge = "br0"
5654
DefaultHostVhostuserBaseDir = "/var/lib/vhost_sockets/"
5755
)
5856

59-
//
6057
// Types
61-
//
6258
type CniOvs struct {
6359
}
6460

65-
//
6661
// API Functions
67-
//
6862
func (cniOvs CniOvs) AddOnHost(conf *types.NetConf,
6963
args *skel.CmdArgs,
7064
kubeClient kubernetes.Interface,
@@ -196,7 +190,11 @@ func (cniOvs CniOvs) DelFromHost(conf *types.NetConf, args *skel.CmdArgs, shared
196190
func (cniOvs CniOvs) DelFromContainer(conf *types.NetConf, args *skel.CmdArgs, sharedDir string, pod *v1.Pod) error {
197191
logging.Infof("OVS DelFromContainer: ENTER - Container %s Iface %s", args.ContainerID[:12], args.IfName)
198192

199-
configdata.FileCleanup(sharedDir, "")
193+
var err = configdata.FileCleanup(sharedDir, "")
194+
195+
if err != nil {
196+
logging.Debugf("DelFromContainer(ovs): %v", err)
197+
}
200198

201199
return nil
202200
}
@@ -243,15 +241,15 @@ func createSharedDir(sharedDir, oldSharedDir string) error {
243241
if os.IsNotExist(err) {
244242
err = os.MkdirAll(sharedDir, 0750)
245243
if err != nil {
246-
logging.Errorf("createSharedDir: Failed to create dir (%s): %v", sharedDir, err)
244+
_ = logging.Errorf("createSharedDir: Failed to create dir (%s): %v", sharedDir, err)
247245
return err
248246
}
249247

250248
if strings.Contains(sharedDir, DefaultHostVhostuserBaseDir) {
251249
logging.Debugf("createSharedDir: Mount from %s to %s", oldSharedDir, sharedDir)
252250
err = unix.Mount(oldSharedDir, sharedDir, "", unix.MS_BIND, "")
253251
if err != nil {
254-
logging.Errorf("createSharedDir: Failed to bind mount: %s", err)
252+
_ = logging.Errorf("createSharedDir: Failed to bind mount: %s", err)
255253
return err
256254
}
257255
}
@@ -296,15 +294,15 @@ func addLocalDeviceVhost(conf *types.NetConf, args *skel.CmdArgs, actualSharedDi
296294
sharedDir := getShortSharedDir(actualSharedDir)
297295
err = createSharedDir(sharedDir, actualSharedDir)
298296
if err != nil {
299-
logging.Errorf("addLocalDeviceVhost: Failed to create shared dir: %v", err)
297+
_ = logging.Errorf("addLocalDeviceVhost: Failed to create shared dir: %v", err)
300298
return err
301299
}
302300

303301
group := conf.HostConf.VhostConf.Group
304302
if group != "" {
305303
err = setSharedDirGroup(sharedDir, group)
306304
if err != nil {
307-
logging.Errorf("addLocalDeviceVhost: Failed to set shared dir group: %v", err)
305+
_ = logging.Errorf("addLocalDeviceVhost: Failed to set shared dir group: %v", err)
308306
return err
309307
}
310308
}
@@ -341,7 +339,7 @@ func delLocalDeviceVhost(conf *types.NetConf, args *skel.CmdArgs, actualSharedDi
341339
// ovs-vsctl --if-exists del-port
342340
err := deleteVhostPort(data.Vhostname, conf.HostConf.BridgeConf.BridgeName)
343341
if err != nil {
344-
logging.Errorf("delLocalDeviceVhost: Failed to delete port: %v", err)
342+
_ = logging.Errorf("delLocalDeviceVhost: Failed to delete port: %v", err)
345343
return err
346344
}
347345

@@ -350,17 +348,17 @@ func delLocalDeviceVhost(conf *types.NetConf, args *skel.CmdArgs, actualSharedDi
350348
logging.Debugf("delLocalDeviceVhost: Unmount shared directory: %v", sharedDir)
351349
_, err = os.Stat(sharedDir)
352350
if os.IsNotExist(err) {
353-
logging.Errorf("delLocalDeviceVhost: shared directory %s does not exist to unmount", sharedDir)
351+
_ = logging.Errorf("delLocalDeviceVhost: shared directory %s does not exist to unmount", sharedDir)
354352
return nil
355353
}
356354
err = unix.Unmount(sharedDir, 0)
357355
if err != nil {
358-
logging.Errorf("Failed to unmount dir: %v", err)
356+
_ = logging.Errorf("Failed to unmount dir: %v", err)
359357
return err
360358
}
361359
err = os.Remove(sharedDir)
362360
if err != nil {
363-
logging.Errorf("Failed to remove dir: %v", err)
361+
_ = logging.Errorf("Failed to remove dir: %v", err)
364362
return err
365363
}
366364
} else {
@@ -379,7 +377,7 @@ func delLocalDeviceVhost(conf *types.NetConf, args *skel.CmdArgs, actualSharedDi
379377

380378
// Remove files with matching container ID and IfName
381379
for _, fileName := range filesForContainerID {
382-
if match, _ := regexp.MatchString(fileBaseName+"*", fileName); match == true {
380+
if match, _ := regexp.MatchString(fileBaseName+"*", fileName); match {
383381
logging.Debugf("OVS DelFromContainer: %s matches file %s", fileBaseName, fileName)
384382
file := filepath.Join(sharedDir, fileName)
385383
if err = os.Remove(file); err != nil {
@@ -392,7 +390,7 @@ func delLocalDeviceVhost(conf *types.NetConf, args *skel.CmdArgs, actualSharedDi
392390

393391
// In case the Socketfile name was passed in:
394392
if conf.HostConf.VhostConf.Socketfile != fileBaseName {
395-
if match, _ := regexp.MatchString(conf.HostConf.VhostConf.Socketfile+"*", fileName); match == true {
393+
if match, _ := regexp.MatchString(conf.HostConf.VhostConf.Socketfile+"*", fileName); match {
396394
file := filepath.Join(sharedDir, fileName)
397395
if err = os.Remove(file); err != nil {
398396
return err
@@ -415,7 +413,7 @@ func delLocalDeviceVhost(conf *types.NetConf, args *skel.CmdArgs, actualSharedDi
415413
func addLocalNetworkBridge(conf *types.NetConf, args *skel.CmdArgs, data *OvsSavedData) error {
416414
var err error
417415

418-
if found := findBridge(conf.HostConf.BridgeConf.BridgeName); found == false {
416+
if found := findBridge(conf.HostConf.BridgeConf.BridgeName); !found {
419417
logging.Debugf("addLocalNetworkBridge(): Bridge %s not found, creating", conf.HostConf.BridgeConf.BridgeName)
420418
err = createBridge(conf.HostConf.BridgeConf.BridgeName)
421419

@@ -438,7 +436,7 @@ func addLocalNetworkBridge(conf *types.NetConf, args *skel.CmdArgs, data *OvsSav
438436
func delLocalNetworkBridge(conf *types.NetConf, args *skel.CmdArgs, data *OvsSavedData) error {
439437
var err error
440438

441-
if containInterfaces := doesBridgeContainInterfaces(conf.HostConf.BridgeConf.BridgeName); containInterfaces == false {
439+
if containInterfaces := doesBridgeContainInterfaces(conf.HostConf.BridgeConf.BridgeName); !containInterfaces {
442440
logging.Debugf("delLocalNetworkBridge(): No interfaces found, deleting Bridge %s", conf.HostConf.BridgeConf.BridgeName)
443441
err = deleteBridge(conf.HostConf.BridgeConf.BridgeName)
444442
} else {

Diff for: ‎cniovs/cniovs_test.go

+16-17
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@ package cniovs
1717
import (
1818
"errors"
1919
"fmt"
20-
"io/ioutil"
2120
"os"
2221
"os/user"
2322
"path"
@@ -83,7 +82,7 @@ func TestAddOnHost(t *testing.T) {
8382
var result *current.Result
8483
args := testdata.GetTestArgs()
8584

86-
sharedDir, dirErr := ioutil.TempDir("/tmp", "test-cniovs-")
85+
sharedDir, dirErr := os.MkdirTemp("/tmp", "test-cniovs-")
8786
require.NoError(t, dirErr, "Can't create temporary directory")
8887
defer os.RemoveAll(sharedDir)
8988

@@ -113,7 +112,7 @@ func TestAddOnContainer(t *testing.T) {
113112
args := testdata.GetTestArgs()
114113
ovs := CniOvs{}
115114

116-
sharedDir, dirErr := ioutil.TempDir("/tmp", "test-cniovs-")
115+
sharedDir, dirErr := os.MkdirTemp("/tmp", "test-cniovs-")
117116
require.NoError(t, dirErr, "Can't create temporary directory")
118117
defer os.RemoveAll(sharedDir)
119118

@@ -131,7 +130,7 @@ func TestDelOnContainer(t *testing.T) {
131130
args := testdata.GetTestArgs()
132131
ovs := CniOvs{}
133132

134-
sharedDir, dirErr := ioutil.TempDir("/tmp", "test-cniovs-")
133+
sharedDir, dirErr := os.MkdirTemp("/tmp", "test-cniovs-")
135134
require.NoError(t, dirErr, "Can't create temporary directory")
136135
// just in case that DelFromContainer fails
137136
defer os.RemoveAll(sharedDir)
@@ -191,10 +190,10 @@ func TestDelFromHost(t *testing.T) {
191190
}
192191
path := path.Join(localDir, fileName)
193192

194-
require.NoError(t, ioutil.WriteFile(path, []byte(tc.savedData), 0644), "Can't create test file")
193+
require.NoError(t, os.WriteFile(path, []byte(tc.savedData), 0644), "Can't create test file")
195194
defer os.Remove(path)
196195

197-
sharedDir, dirErr := ioutil.TempDir("/tmp", "test-cniovs-")
196+
sharedDir, dirErr := os.MkdirTemp("/tmp", "test-cniovs-")
198197
require.NoError(t, dirErr, "Can't create temporary directory")
199198
defer os.RemoveAll(sharedDir)
200199

@@ -217,10 +216,10 @@ func TestGenerateRandomMacAddress(t *testing.T) {
217216
nr := 10
218217
t.Run(fmt.Sprintf("generate %v random MAC addresses", nr), func(t *testing.T) {
219218
macs := make(map[string]int)
219+
mac_regex := regexp.MustCompile("^[0-9a-fA-F]{2}(:([0-9a-fA-F]){2}){5}$")
220220
for i := 0; i < nr; i++ {
221221
mac := generateRandomMacAddress()
222-
ok, err := regexp.Match("^[0-9a-fA-F]{2}(:([0-9a-fA-F]){2}){5}$", []byte(mac))
223-
require.NoError(t, err, fmt.Sprintf("MAC is incorrect. MAC: %q", mac))
222+
ok := mac_regex.Match([]byte(mac))
224223
require.True(t, ok, fmt.Sprintf("MAC is incorrect. MAC: %q", mac))
225224
macs[mac]++
226225
}
@@ -315,7 +314,7 @@ func TestCreateSharedDir(t *testing.T) {
315314
}
316315
for _, tc := range testCases {
317316
t.Run(tc.name, func(t *testing.T) {
318-
sharedDir, dirErr := ioutil.TempDir("/tmp", "test-cniovs-")
317+
sharedDir, dirErr := os.MkdirTemp("/tmp", "test-cniovs-")
319318
sharedDirNoPath := strings.Split(sharedDir, "/")[2]
320319
require.NoError(t, dirErr, "Can't create temporary directory")
321320
tc.sharedDir = strings.Replace(tc.sharedDir, "#sharedDir#", sharedDir, -1)
@@ -368,7 +367,7 @@ func TestSetSharedDirGroup(t *testing.T) {
368367
}
369368
for _, tc := range testCases {
370369
t.Run(tc.name, func(t *testing.T) {
371-
sharedDir, dirErr := ioutil.TempDir("/tmp", "test-cniovs-")
370+
sharedDir, dirErr := os.MkdirTemp("/tmp", "test-cniovs-")
372371
require.NoError(t, dirErr, "Can't create temporary directory")
373372
tc.sharedDir = strings.Replace(tc.sharedDir, "#sharedDir#", sharedDir, -1)
374373
defer os.RemoveAll(sharedDir)
@@ -458,7 +457,7 @@ func TestAddLocalDeviceVhost(t *testing.T) {
458457
args := testdata.GetTestArgs()
459458
execCommand := &FakeExecCommand{Err: tc.fakeErr}
460459

461-
sharedDir, dirErr := ioutil.TempDir("/tmp", "test-cniovs-")
460+
sharedDir, dirErr := os.MkdirTemp("/tmp", "test-cniovs-")
462461
require.NoError(t, dirErr, "Can't create temporary directory")
463462
if !tc.createDir {
464463
require.NoError(t, os.RemoveAll(sharedDir))
@@ -483,7 +482,7 @@ func TestAddLocalDeviceVhost(t *testing.T) {
483482
defer os.RemoveAll(defaultOvSSocketDir)
484483
}
485484
path := path.Join(defaultOvSSocketDir, socketFile)
486-
require.NoError(t, ioutil.WriteFile(path, []byte(""), 0644), "Can't create test file")
485+
require.NoError(t, os.WriteFile(path, []byte(""), 0644), "Can't create test file")
487486
defer os.Remove(path)
488487

489488
}
@@ -515,9 +514,9 @@ func createSocket(t *testing.T, dir, socket string, isDir bool) (socketPath stri
515514
if isDir {
516515
// error case - create dir instead of file and create file inside it
517516
require.NoError(t, os.MkdirAll(socketPath, 0700), "Can't create test directory")
518-
require.NoError(t, ioutil.WriteFile(path.Join(socketPath, socket), []byte(""), 0644), "Can't create test file")
517+
require.NoError(t, os.WriteFile(path.Join(socketPath, socket), []byte(""), 0644), "Can't create test file")
519518
} else {
520-
require.NoError(t, ioutil.WriteFile(socketPath, []byte(""), 0644), "Can't create test file")
519+
require.NoError(t, os.WriteFile(socketPath, []byte(""), 0644), "Can't create test file")
521520
}
522521
return
523522
}
@@ -661,15 +660,15 @@ func TestDelLocalDeviceVhost(t *testing.T) {
661660
defer unix.Unmount(sharedDir, 0)
662661
} else {
663662
var dirErr error
664-
sharedDir, dirErr = ioutil.TempDir("/tmp", "test-cniovs-")
663+
sharedDir, dirErr = os.MkdirTemp("/tmp", "test-cniovs-")
665664
require.NoError(dirErr, "Can't create temporary directory")
666665
switch tc.brokenDir {
667666
case "proc":
668667
require.NoError(os.RemoveAll(sharedDir))
669668
sharedDir = "/proc/broken_shared_dir"
670669
case "file":
671670
require.NoError(os.RemoveAll(sharedDir))
672-
require.NoError(ioutil.WriteFile(sharedDir, []byte(""), 0644), "Can't create test file")
671+
require.NoError(os.WriteFile(sharedDir, []byte(""), 0644), "Can't create test file")
673672
defer os.Remove(sharedDir)
674673
}
675674
// cleanup if needed
@@ -690,7 +689,7 @@ func TestDelLocalDeviceVhost(t *testing.T) {
690689
// prepare noise files, which shall remain and avoid shared dir removal
691690
for i := 0; i < tc.noiseFiles; i++ {
692691
path := path.Join(sharedDir, fmt.Sprintf("noise-file-%v", i))
693-
require.NoError(ioutil.WriteFile(path, []byte(""), 0644), "Can't create test file")
692+
require.NoError(os.WriteFile(path, []byte(""), 0644), "Can't create test file")
694693
defer os.Remove(path)
695694
}
696695

Diff for: ‎cniovs/localdb.go

+2-3
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@ package cniovs
2222
import (
2323
"encoding/json"
2424
"fmt"
25-
"io/ioutil"
2625
"os"
2726
"path/filepath"
2827

@@ -76,7 +75,7 @@ func SaveConfig(conf *types.NetConf, args *skel.CmdArgs, data *OvsSavedData) err
7675

7776
path := filepath.Join(localDir, fileName)
7877

79-
return ioutil.WriteFile(path, dataBytes, 0644)
78+
return os.WriteFile(path, dataBytes, 0644)
8079
} else {
8180
return fmt.Errorf("ERROR: serializing delegate OVS saved data: %v", err)
8281
}
@@ -89,7 +88,7 @@ func LoadConfig(conf *types.NetConf, args *skel.CmdArgs, data *OvsSavedData) err
8988
path := filepath.Join(localDir, fileName)
9089

9190
if _, err := os.Stat(path); err == nil {
92-
if dataBytes, err := ioutil.ReadFile(path); err == nil {
91+
if dataBytes, err := os.ReadFile(path); err == nil {
9392
if err = json.Unmarshal(dataBytes, data); err != nil {
9493
return fmt.Errorf("ERROR: Failed to parse OVS saved data: %v", err)
9594
}

Diff for: ‎cniovs/localdb_test.go

+1-2
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@ package cniovs
1717
import (
1818
"errors"
1919
"fmt"
20-
"io/ioutil"
2120
"os"
2221
"path"
2322
"testing"
@@ -106,7 +105,7 @@ func TestLoadConfig(t *testing.T) {
106105
case "none":
107106
require.NoFileExists(t, path, "Saved configuration shall not exist")
108107
case "corrupted":
109-
require.NoError(t, ioutil.WriteFile(path, []byte("{"), 0644), "Can't create test file")
108+
require.NoError(t, os.WriteFile(path, []byte("{"), 0644), "Can't create test file")
110109
defer os.Remove(path)
111110
case "directory":
112111
require.NoError(t, os.Mkdir(path, 0700), "Can't create test dir")

Diff for: ‎cniovs/ovsctrl_test.go

+1-2
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@ package cniovs
1717
import (
1818
"errors"
1919
"fmt"
20-
"io/ioutil"
2120
"os"
2221
"path"
2322
"strings"
@@ -77,7 +76,7 @@ func TestCreateVhostPort(t *testing.T) {
7776
require := require.New(t)
7877
execCommand := &FakeExecCommand{Err: tc.fakeErr}
7978

80-
socketDir, dirErr := ioutil.TempDir("/tmp", "test-cniovs-")
79+
socketDir, dirErr := os.MkdirTemp("/tmp", "test-cniovs-")
8180
require.NoError(dirErr, "Can't create temporary directory")
8281
defer os.RemoveAll(socketDir)
8382

Diff for: ‎cnivpp/api/bridge/bridge.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ func DeleteBridge(ch api.Channel, bridgeDomain uint32) error {
7777

7878
// Determine if bridge domain exists
7979
exists, count := findBridge(ch, bridgeDomain)
80-
if exists == false || count != 0 {
80+
if !exists || count != 0 {
8181
return nil
8282
}
8383

Diff for: ‎cnivpp/api/memif/memif.go

+5-6
Original file line numberDiff line numberDiff line change
@@ -38,14 +38,14 @@ import (
3838

3939
const debugMemif = false
4040

41-
type MemifRole uint8
41+
type MemifRole uint32
4242

4343
const (
4444
RoleMaster MemifRole = 0
4545
RoleSlave MemifRole = 1
4646
)
4747

48-
type MemifMode uint8
48+
type MemifMode uint32
4949

5050
const (
5151
ModeEthernet MemifMode = 0
@@ -56,7 +56,6 @@ const (
5656
// Dump Strings
5757
var modeStr = [...]string{"eth", "ip ", "pnt"}
5858
var roleStr = [...]string{"master", "slave "}
59-
var stateStr = [...]string{"dn", "up"}
6059

6160
//
6261
// API Functions
@@ -108,7 +107,7 @@ func DeleteMemifInterface(ch api.Channel, swIfIndex interface_types.InterfaceInd
108107
// Determine if memif interface exists
109108
socketId, exist := findMemifInterface(ch, swIfIndex)
110109
if debugMemif {
111-
if exist == false {
110+
if !exist {
112111
logging.Verbosef("Error deleting memif interface: memif interface (swIfIndex=%d) Does NOT Exist", swIfIndex)
113112
} else {
114113
logging.Verbosef("Attempting to delete memif interface %d with SocketId %d", swIfIndex, socketId)
@@ -428,10 +427,10 @@ func findMemifSocket(ch api.Channel, socketFilename string) (found bool, socketI
428427
// If input SocketFilename has not been created, then loop
429428
// through the list of existing SocketIds and find an unused Id.
430429
//
431-
if found == false {
430+
if !found {
432431
socketId = 1
433432

434-
for done == false {
433+
for !done {
435434

436435
done = true
437436
for i := 0; i < count; i++ {

0 commit comments

Comments
 (0)