@@ -41,30 +41,24 @@ import (
41
41
"k8s.io/client-go/kubernetes"
42
42
43
43
"github.com/containernetworking/cni/pkg/skel"
44
- "github.com/containernetworking/cni/pkg/types/current "
44
+ current "github.com/containernetworking/cni/pkg/types/100 "
45
45
46
46
"github.com/intel/userspace-cni-network-plugin/logging"
47
47
"github.com/intel/userspace-cni-network-plugin/pkg/configdata"
48
48
"github.com/intel/userspace-cni-network-plugin/pkg/types"
49
49
)
50
50
51
- //
52
51
// Constants
53
- //
54
52
const (
55
53
defaultBridge = "br0"
56
54
DefaultHostVhostuserBaseDir = "/var/lib/vhost_sockets/"
57
55
)
58
56
59
- //
60
57
// Types
61
- //
62
58
type CniOvs struct {
63
59
}
64
60
65
- //
66
61
// API Functions
67
- //
68
62
func (cniOvs CniOvs ) AddOnHost (conf * types.NetConf ,
69
63
args * skel.CmdArgs ,
70
64
kubeClient kubernetes.Interface ,
@@ -196,7 +190,11 @@ func (cniOvs CniOvs) DelFromHost(conf *types.NetConf, args *skel.CmdArgs, shared
196
190
func (cniOvs CniOvs ) DelFromContainer (conf * types.NetConf , args * skel.CmdArgs , sharedDir string , pod * v1.Pod ) error {
197
191
logging .Infof ("OVS DelFromContainer: ENTER - Container %s Iface %s" , args .ContainerID [:12 ], args .IfName )
198
192
199
- configdata .FileCleanup (sharedDir , "" )
193
+ var err = configdata .FileCleanup (sharedDir , "" )
194
+
195
+ if err != nil {
196
+ logging .Debugf ("DelFromContainer(ovs): %v" , err )
197
+ }
200
198
201
199
return nil
202
200
}
@@ -243,15 +241,15 @@ func createSharedDir(sharedDir, oldSharedDir string) error {
243
241
if os .IsNotExist (err ) {
244
242
err = os .MkdirAll (sharedDir , 0750 )
245
243
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 )
247
245
return err
248
246
}
249
247
250
248
if strings .Contains (sharedDir , DefaultHostVhostuserBaseDir ) {
251
249
logging .Debugf ("createSharedDir: Mount from %s to %s" , oldSharedDir , sharedDir )
252
250
err = unix .Mount (oldSharedDir , sharedDir , "" , unix .MS_BIND , "" )
253
251
if err != nil {
254
- logging .Errorf ("createSharedDir: Failed to bind mount: %s" , err )
252
+ _ = logging .Errorf ("createSharedDir: Failed to bind mount: %s" , err )
255
253
return err
256
254
}
257
255
}
@@ -296,15 +294,15 @@ func addLocalDeviceVhost(conf *types.NetConf, args *skel.CmdArgs, actualSharedDi
296
294
sharedDir := getShortSharedDir (actualSharedDir )
297
295
err = createSharedDir (sharedDir , actualSharedDir )
298
296
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 )
300
298
return err
301
299
}
302
300
303
301
group := conf .HostConf .VhostConf .Group
304
302
if group != "" {
305
303
err = setSharedDirGroup (sharedDir , group )
306
304
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 )
308
306
return err
309
307
}
310
308
}
@@ -341,7 +339,7 @@ func delLocalDeviceVhost(conf *types.NetConf, args *skel.CmdArgs, actualSharedDi
341
339
// ovs-vsctl --if-exists del-port
342
340
err := deleteVhostPort (data .Vhostname , conf .HostConf .BridgeConf .BridgeName )
343
341
if err != nil {
344
- logging .Errorf ("delLocalDeviceVhost: Failed to delete port: %v" , err )
342
+ _ = logging .Errorf ("delLocalDeviceVhost: Failed to delete port: %v" , err )
345
343
return err
346
344
}
347
345
@@ -350,17 +348,17 @@ func delLocalDeviceVhost(conf *types.NetConf, args *skel.CmdArgs, actualSharedDi
350
348
logging .Debugf ("delLocalDeviceVhost: Unmount shared directory: %v" , sharedDir )
351
349
_ , err = os .Stat (sharedDir )
352
350
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 )
354
352
return nil
355
353
}
356
354
err = unix .Unmount (sharedDir , 0 )
357
355
if err != nil {
358
- logging .Errorf ("Failed to unmount dir: %v" , err )
356
+ _ = logging .Errorf ("Failed to unmount dir: %v" , err )
359
357
return err
360
358
}
361
359
err = os .Remove (sharedDir )
362
360
if err != nil {
363
- logging .Errorf ("Failed to remove dir: %v" , err )
361
+ _ = logging .Errorf ("Failed to remove dir: %v" , err )
364
362
return err
365
363
}
366
364
} else {
@@ -379,7 +377,7 @@ func delLocalDeviceVhost(conf *types.NetConf, args *skel.CmdArgs, actualSharedDi
379
377
380
378
// Remove files with matching container ID and IfName
381
379
for _ , fileName := range filesForContainerID {
382
- if match , _ := regexp .MatchString (fileBaseName + "*" , fileName ); match == true {
380
+ if match , _ := regexp .MatchString (fileBaseName + "*" , fileName ); match {
383
381
logging .Debugf ("OVS DelFromContainer: %s matches file %s" , fileBaseName , fileName )
384
382
file := filepath .Join (sharedDir , fileName )
385
383
if err = os .Remove (file ); err != nil {
@@ -392,7 +390,7 @@ func delLocalDeviceVhost(conf *types.NetConf, args *skel.CmdArgs, actualSharedDi
392
390
393
391
// In case the Socketfile name was passed in:
394
392
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 {
396
394
file := filepath .Join (sharedDir , fileName )
397
395
if err = os .Remove (file ); err != nil {
398
396
return err
@@ -415,7 +413,7 @@ func delLocalDeviceVhost(conf *types.NetConf, args *skel.CmdArgs, actualSharedDi
415
413
func addLocalNetworkBridge (conf * types.NetConf , args * skel.CmdArgs , data * OvsSavedData ) error {
416
414
var err error
417
415
418
- if found := findBridge (conf .HostConf .BridgeConf .BridgeName ); found == false {
416
+ if found := findBridge (conf .HostConf .BridgeConf .BridgeName ); ! found {
419
417
logging .Debugf ("addLocalNetworkBridge(): Bridge %s not found, creating" , conf .HostConf .BridgeConf .BridgeName )
420
418
err = createBridge (conf .HostConf .BridgeConf .BridgeName )
421
419
@@ -438,7 +436,7 @@ func addLocalNetworkBridge(conf *types.NetConf, args *skel.CmdArgs, data *OvsSav
438
436
func delLocalNetworkBridge (conf * types.NetConf , args * skel.CmdArgs , data * OvsSavedData ) error {
439
437
var err error
440
438
441
- if containInterfaces := doesBridgeContainInterfaces (conf .HostConf .BridgeConf .BridgeName ); containInterfaces == false {
439
+ if containInterfaces := doesBridgeContainInterfaces (conf .HostConf .BridgeConf .BridgeName ); ! containInterfaces {
442
440
logging .Debugf ("delLocalNetworkBridge(): No interfaces found, deleting Bridge %s" , conf .HostConf .BridgeConf .BridgeName )
443
441
err = deleteBridge (conf .HostConf .BridgeConf .BridgeName )
444
442
} else {
0 commit comments