host-device plugin: result is valid JSON

test:
- feed valid config JSON to plugin
- execute plugin inside the namespace with the test device
This commit is contained in:
Gabriel Rosenhouse
2017-09-12 21:01:58 -07:00
parent 25ca6ccb52
commit c238c93b5e
2 changed files with 17 additions and 6 deletions

View File

@ -25,6 +25,7 @@ import (
"strings" "strings"
"github.com/containernetworking/cni/pkg/skel" "github.com/containernetworking/cni/pkg/skel"
"github.com/containernetworking/cni/pkg/types/current"
"github.com/containernetworking/cni/pkg/version" "github.com/containernetworking/cni/pkg/version"
"github.com/containernetworking/plugins/pkg/ns" "github.com/containernetworking/plugins/pkg/ns"
"github.com/vishvananda/netlink" "github.com/vishvananda/netlink"
@ -64,6 +65,7 @@ func cmdAdd(args *skel.CmdArgs) error {
return fmt.Errorf("failed to open netns %q: %v", args.Netns, err) return fmt.Errorf("failed to open netns %q: %v", args.Netns, err)
} }
defer containerNs.Close() defer containerNs.Close()
defer (&current.Result{}).Print()
return addLink(cfg.Device, cfg.HWAddr, cfg.KernelPath, containerNs) return addLink(cfg.Device, cfg.HWAddr, cfg.KernelPath, containerNs)
} }
@ -77,6 +79,7 @@ func cmdDel(args *skel.CmdArgs) error {
return fmt.Errorf("failed to open netns %q: %v", args.Netns, err) return fmt.Errorf("failed to open netns %q: %v", args.Netns, err)
} }
defer containerNs.Close() defer containerNs.Close()
defer fmt.Println(`{}`)
return removeLink(cfg.Device, cfg.HWAddr, cfg.KernelPath, containerNs) return removeLink(cfg.Device, cfg.HWAddr, cfg.KernelPath, containerNs)
} }

View File

@ -15,6 +15,9 @@
package main package main
import ( import (
"fmt"
"math/rand"
"github.com/containernetworking/cni/pkg/skel" "github.com/containernetworking/cni/pkg/skel"
"github.com/containernetworking/plugins/pkg/ns" "github.com/containernetworking/plugins/pkg/ns"
"github.com/containernetworking/plugins/pkg/testutils" "github.com/containernetworking/plugins/pkg/testutils"
@ -23,15 +26,16 @@ import (
"github.com/vishvananda/netlink" "github.com/vishvananda/netlink"
) )
var ifname = "dummy0"
var _ = Describe("base functionality", func() { var _ = Describe("base functionality", func() {
var originalNS ns.NetNS var originalNS ns.NetNS
var ifname string
BeforeEach(func() { BeforeEach(func() {
var err error var err error
originalNS, err = ns.NewNS() originalNS, err = ns.NewNS()
Expect(err).NotTo(HaveOccurred()) Expect(err).NotTo(HaveOccurred())
ifname = fmt.Sprintf("dummy-%x", rand.Int31())
}) })
AfterEach(func() { AfterEach(func() {
@ -61,19 +65,23 @@ var _ = Describe("base functionality", func() {
targetNS, err := ns.NewNS() targetNS, err := ns.NewNS()
Expect(err).NotTo(HaveOccurred()) Expect(err).NotTo(HaveOccurred())
conf := `{ conf := fmt.Sprintf(`{
"cniVersion": "0.3.0", "cniVersion": "0.3.0",
"name": "cni-plugin-host-device-test", "name": "cni-plugin-host-device-test",
"type": "host-device", "type": "host-device",
"device": ifname "device": %q
}` }`, ifname)
args := &skel.CmdArgs{ args := &skel.CmdArgs{
ContainerID: "dummy", ContainerID: "dummy",
Netns: targetNS.Path(), Netns: targetNS.Path(),
IfName: ifname, IfName: ifname,
StdinData: []byte(conf), StdinData: []byte(conf),
} }
_, _, err = testutils.CmdAddWithResult(targetNS.Path(), ifname, []byte(conf), func() error { return cmdAdd(args) }) err = originalNS.Do(func(ns.NetNS) error {
defer GinkgoRecover()
_, _, err := testutils.CmdAddWithResult(targetNS.Path(), ifname, []byte(conf), func() error { return cmdAdd(args) })
return err
})
Expect(err).NotTo(HaveOccurred()) Expect(err).NotTo(HaveOccurred())
// assert that dummy0 is now in the target namespace // assert that dummy0 is now in the target namespace