tuning: increase test coverage to 1.0.0 and older spec versions
Signed-off-by: Dan Williams <dcbw@redhat.com>
This commit is contained in:
@ -21,7 +21,7 @@ import (
|
|||||||
|
|
||||||
"github.com/containernetworking/cni/pkg/skel"
|
"github.com/containernetworking/cni/pkg/skel"
|
||||||
"github.com/containernetworking/cni/pkg/types"
|
"github.com/containernetworking/cni/pkg/types"
|
||||||
current "github.com/containernetworking/cni/pkg/types/100"
|
"github.com/containernetworking/cni/pkg/types/100"
|
||||||
"github.com/containernetworking/plugins/pkg/ns"
|
"github.com/containernetworking/plugins/pkg/ns"
|
||||||
"github.com/containernetworking/plugins/pkg/testutils"
|
"github.com/containernetworking/plugins/pkg/testutils"
|
||||||
|
|
||||||
@ -75,7 +75,7 @@ func buildOneConfig(name, cniVersion string, orig *TuningConf, prevResult types.
|
|||||||
}
|
}
|
||||||
|
|
||||||
var _ = Describe("tuning plugin", func() {
|
var _ = Describe("tuning plugin", func() {
|
||||||
var originalNS ns.NetNS
|
var originalNS, targetNS ns.NetNS
|
||||||
const IFNAME string = "dummy0"
|
const IFNAME string = "dummy0"
|
||||||
var beforeConf configToRestore
|
var beforeConf configToRestore
|
||||||
|
|
||||||
@ -85,6 +85,9 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
originalNS, err = testutils.NewNS()
|
originalNS, err = testutils.NewNS()
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
|
targetNS, err = testutils.NewNS()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
err = originalNS.Do(func(ns.NetNS) error {
|
err = originalNS.Do(func(ns.NetNS) error {
|
||||||
defer GinkgoRecover()
|
defer GinkgoRecover()
|
||||||
|
|
||||||
@ -108,13 +111,21 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
|
|
||||||
AfterEach(func() {
|
AfterEach(func() {
|
||||||
Expect(originalNS.Close()).To(Succeed())
|
Expect(originalNS.Close()).To(Succeed())
|
||||||
|
Expect(testutils.UnmountNS(originalNS)).To(Succeed())
|
||||||
|
Expect(targetNS.Close()).To(Succeed())
|
||||||
|
Expect(testutils.UnmountNS(targetNS)).To(Succeed())
|
||||||
})
|
})
|
||||||
|
|
||||||
It("passes prevResult through unchanged", func() {
|
for _, ver := range []string{"0.3.0", "0.3.1", "0.4.0", "1.0.0"} {
|
||||||
conf := []byte(`{
|
// Redefine ver inside for scope so real value is picked up by each dynamically defined It()
|
||||||
|
// See Gingkgo's "Patterns for dynamically generating tests" documentation.
|
||||||
|
ver := ver
|
||||||
|
|
||||||
|
It(fmt.Sprintf("[%s] passes prevResult through unchanged", ver), func() {
|
||||||
|
conf := []byte(fmt.Sprintf(`{
|
||||||
"name": "test",
|
"name": "test",
|
||||||
"type": "tuning",
|
"type": "tuning",
|
||||||
"cniVersion": "0.3.1",
|
"cniVersion": "%s",
|
||||||
"sysctl": {
|
"sysctl": {
|
||||||
"net.ipv4.conf.all.log_martians": "1"
|
"net.ipv4.conf.all.log_martians": "1"
|
||||||
},
|
},
|
||||||
@ -131,22 +142,18 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
}
|
}
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
}`)
|
}`, ver))
|
||||||
|
|
||||||
targetNs, err := testutils.NewNS()
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
defer targetNs.Close()
|
|
||||||
|
|
||||||
args := &skel.CmdArgs{
|
args := &skel.CmdArgs{
|
||||||
ContainerID: "dummy",
|
ContainerID: "dummy",
|
||||||
Netns: targetNs.Path(),
|
Netns: targetNS.Path(),
|
||||||
IfName: IFNAME,
|
IfName: IFNAME,
|
||||||
StdinData: conf,
|
StdinData: conf,
|
||||||
}
|
}
|
||||||
|
|
||||||
beforeConf = configToRestore{}
|
beforeConf = configToRestore{}
|
||||||
|
|
||||||
err = originalNS.Do(func(ns.NetNS) error {
|
err := originalNS.Do(func(ns.NetNS) error {
|
||||||
defer GinkgoRecover()
|
defer GinkgoRecover()
|
||||||
|
|
||||||
r, _, err := testutils.CmdAddWithArgs(args, func() error {
|
r, _, err := testutils.CmdAddWithArgs(args, func() error {
|
||||||
@ -154,7 +161,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
})
|
})
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
result, err := current.GetResult(r)
|
result, err := types100.GetResult(r)
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
Expect(len(result.Interfaces)).To(Equal(1))
|
Expect(len(result.Interfaces)).To(Equal(1))
|
||||||
@ -173,11 +180,11 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
})
|
})
|
||||||
|
|
||||||
It("configures and deconfigures promiscuous mode with ADD/DEL", func() {
|
It(fmt.Sprintf("[%s] configures and deconfigures promiscuous mode with ADD/DEL", ver), func() {
|
||||||
conf := []byte(`{
|
conf := []byte(fmt.Sprintf(`{
|
||||||
"name": "test",
|
"name": "test",
|
||||||
"type": "iplink",
|
"type": "iplink",
|
||||||
"cniVersion": "0.3.1",
|
"cniVersion": "%s",
|
||||||
"promisc": true,
|
"promisc": true,
|
||||||
"prevResult": {
|
"prevResult": {
|
||||||
"interfaces": [
|
"interfaces": [
|
||||||
@ -192,7 +199,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
}
|
}
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
}`)
|
}`, ver))
|
||||||
|
|
||||||
args := &skel.CmdArgs{
|
args := &skel.CmdArgs{
|
||||||
ContainerID: "dummy",
|
ContainerID: "dummy",
|
||||||
@ -209,7 +216,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
})
|
})
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
result, err := current.GetResult(r)
|
result, err := types100.GetResult(r)
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
Expect(len(result.Interfaces)).To(Equal(1))
|
Expect(len(result.Interfaces)).To(Equal(1))
|
||||||
@ -221,6 +228,22 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
Expect(link.Attrs().Promisc).To(Equal(1))
|
Expect(link.Attrs().Promisc).To(Equal(1))
|
||||||
|
|
||||||
|
if testutils.SpecVersionHasCHECK(ver) {
|
||||||
|
n := &TuningConf{}
|
||||||
|
err = json.Unmarshal([]byte(conf), &n)
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
|
_, confString, err := buildOneConfig("testConfig", ver, n, r)
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
|
args.StdinData = confString
|
||||||
|
|
||||||
|
err = testutils.CmdCheckWithArgs(args, func() error {
|
||||||
|
return cmdCheck(args)
|
||||||
|
})
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
}
|
||||||
|
|
||||||
err = testutils.CmdDel(originalNS.Path(),
|
err = testutils.CmdDel(originalNS.Path(),
|
||||||
args.ContainerID, "", func() error { return cmdDel(args) })
|
args.ContainerID, "", func() error { return cmdDel(args) })
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
@ -234,11 +257,11 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
})
|
})
|
||||||
|
|
||||||
It("configures and deconfigures promiscuous mode from args with ADD/DEL", func() {
|
It(fmt.Sprintf("[%s] configures and deconfigures promiscuous mode from args with ADD/DEL", ver), func() {
|
||||||
conf := []byte(`{
|
conf := []byte(fmt.Sprintf(`{
|
||||||
"name": "test",
|
"name": "test",
|
||||||
"type": "iplink",
|
"type": "iplink",
|
||||||
"cniVersion": "0.3.1",
|
"cniVersion": "%s",
|
||||||
"args": {
|
"args": {
|
||||||
"cni": {
|
"cni": {
|
||||||
"promisc": true
|
"promisc": true
|
||||||
@ -257,7 +280,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
}
|
}
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
}`)
|
}`, ver))
|
||||||
|
|
||||||
args := &skel.CmdArgs{
|
args := &skel.CmdArgs{
|
||||||
ContainerID: "dummy",
|
ContainerID: "dummy",
|
||||||
@ -274,7 +297,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
})
|
})
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
result, err := current.GetResult(r)
|
result, err := types100.GetResult(r)
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
Expect(len(result.Interfaces)).To(Equal(1))
|
Expect(len(result.Interfaces)).To(Equal(1))
|
||||||
@ -299,11 +322,11 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
})
|
})
|
||||||
|
|
||||||
It("configures and deconfigures mtu with ADD/DEL", func() {
|
It(fmt.Sprintf("[%s] configures and deconfigures mtu with ADD/DEL", ver), func() {
|
||||||
conf := []byte(`{
|
conf := []byte(fmt.Sprintf(`{
|
||||||
"name": "test",
|
"name": "test",
|
||||||
"type": "iplink",
|
"type": "iplink",
|
||||||
"cniVersion": "0.3.1",
|
"cniVersion": "%s",
|
||||||
"mtu": 1454,
|
"mtu": 1454,
|
||||||
"prevResult": {
|
"prevResult": {
|
||||||
"interfaces": [
|
"interfaces": [
|
||||||
@ -318,7 +341,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
}
|
}
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
}`)
|
}`, ver))
|
||||||
|
|
||||||
args := &skel.CmdArgs{
|
args := &skel.CmdArgs{
|
||||||
ContainerID: "dummy",
|
ContainerID: "dummy",
|
||||||
@ -335,7 +358,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
})
|
})
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
result, err := current.GetResult(r)
|
result, err := types100.GetResult(r)
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
Expect(len(result.Interfaces)).To(Equal(1))
|
Expect(len(result.Interfaces)).To(Equal(1))
|
||||||
@ -347,6 +370,22 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
Expect(link.Attrs().MTU).To(Equal(1454))
|
Expect(link.Attrs().MTU).To(Equal(1454))
|
||||||
|
|
||||||
|
if testutils.SpecVersionHasCHECK(ver) {
|
||||||
|
n := &TuningConf{}
|
||||||
|
err = json.Unmarshal([]byte(conf), &n)
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
|
_, confString, err := buildOneConfig("testConfig", ver, n, r)
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
|
args.StdinData = confString
|
||||||
|
|
||||||
|
err = testutils.CmdCheckWithArgs(args, func() error {
|
||||||
|
return cmdCheck(args)
|
||||||
|
})
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
}
|
||||||
|
|
||||||
err = testutils.CmdDel(originalNS.Path(),
|
err = testutils.CmdDel(originalNS.Path(),
|
||||||
args.ContainerID, "", func() error { return cmdDel(args) })
|
args.ContainerID, "", func() error { return cmdDel(args) })
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
@ -360,11 +399,11 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
})
|
})
|
||||||
|
|
||||||
It("configures and deconfigures mtu from args with ADD/DEL", func() {
|
It(fmt.Sprintf("[%s] configures and deconfigures mtu from args with ADD/DEL", ver), func() {
|
||||||
conf := []byte(`{
|
conf := []byte(fmt.Sprintf(`{
|
||||||
"name": "test",
|
"name": "test",
|
||||||
"type": "iplink",
|
"type": "iplink",
|
||||||
"cniVersion": "0.3.1",
|
"cniVersion": "%s",
|
||||||
"args": {
|
"args": {
|
||||||
"cni": {
|
"cni": {
|
||||||
"mtu": 1454
|
"mtu": 1454
|
||||||
@ -383,7 +422,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
}
|
}
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
}`)
|
}`, ver))
|
||||||
|
|
||||||
args := &skel.CmdArgs{
|
args := &skel.CmdArgs{
|
||||||
ContainerID: "dummy",
|
ContainerID: "dummy",
|
||||||
@ -400,7 +439,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
})
|
})
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
result, err := current.GetResult(r)
|
result, err := types100.GetResult(r)
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
Expect(len(result.Interfaces)).To(Equal(1))
|
Expect(len(result.Interfaces)).To(Equal(1))
|
||||||
@ -425,11 +464,11 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
})
|
})
|
||||||
|
|
||||||
It("configures and deconfigures mac address (from conf file) with ADD/DEL", func() {
|
It(fmt.Sprintf("[%s] configures and deconfigures mac address (from conf file) with ADD/DEL", ver), func() {
|
||||||
conf := []byte(`{
|
conf := []byte(fmt.Sprintf(`{
|
||||||
"name": "test",
|
"name": "test",
|
||||||
"type": "iplink",
|
"type": "iplink",
|
||||||
"cniVersion": "0.3.1",
|
"cniVersion": "%s",
|
||||||
"mac": "c2:11:22:33:44:55",
|
"mac": "c2:11:22:33:44:55",
|
||||||
"prevResult": {
|
"prevResult": {
|
||||||
"interfaces": [
|
"interfaces": [
|
||||||
@ -444,7 +483,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
}
|
}
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
}`)
|
}`, ver))
|
||||||
|
|
||||||
args := &skel.CmdArgs{
|
args := &skel.CmdArgs{
|
||||||
ContainerID: "dummy",
|
ContainerID: "dummy",
|
||||||
@ -461,7 +500,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
})
|
})
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
result, err := current.GetResult(r)
|
result, err := types100.GetResult(r)
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
Expect(len(result.Interfaces)).To(Equal(1))
|
Expect(len(result.Interfaces)).To(Equal(1))
|
||||||
@ -475,6 +514,22 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
Expect(link.Attrs().HardwareAddr).To(Equal(hw))
|
Expect(link.Attrs().HardwareAddr).To(Equal(hw))
|
||||||
|
|
||||||
|
if testutils.SpecVersionHasCHECK(ver) {
|
||||||
|
n := &TuningConf{}
|
||||||
|
err = json.Unmarshal([]byte(conf), &n)
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
|
_, confString, err := buildOneConfig("testConfig", ver, n, r)
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
|
args.StdinData = confString
|
||||||
|
|
||||||
|
err = testutils.CmdCheckWithArgs(args, func() error {
|
||||||
|
return cmdCheck(args)
|
||||||
|
})
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
}
|
||||||
|
|
||||||
err = testutils.CmdDel(originalNS.Path(),
|
err = testutils.CmdDel(originalNS.Path(),
|
||||||
args.ContainerID, "", func() error { return cmdDel(args) })
|
args.ContainerID, "", func() error { return cmdDel(args) })
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
@ -488,11 +543,11 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
})
|
})
|
||||||
|
|
||||||
It("configures and deconfigures mac address (from args) with ADD/DEL", func() {
|
It(fmt.Sprintf("[%s] configures and deconfigures mac address (from args) with ADD/DEL", ver), func() {
|
||||||
conf := []byte(`{
|
conf := []byte(fmt.Sprintf(`{
|
||||||
"name": "test",
|
"name": "test",
|
||||||
"type": "iplink",
|
"type": "iplink",
|
||||||
"cniVersion": "0.3.1",
|
"cniVersion": "%s",
|
||||||
"args": {
|
"args": {
|
||||||
"cni": {
|
"cni": {
|
||||||
"mac": "c2:11:22:33:44:55"
|
"mac": "c2:11:22:33:44:55"
|
||||||
@ -511,7 +566,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
}
|
}
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
}`)
|
}`, ver))
|
||||||
|
|
||||||
args := &skel.CmdArgs{
|
args := &skel.CmdArgs{
|
||||||
ContainerID: "dummy",
|
ContainerID: "dummy",
|
||||||
@ -528,7 +583,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
})
|
})
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
result, err := current.GetResult(r)
|
result, err := types100.GetResult(r)
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
Expect(len(result.Interfaces)).To(Equal(1))
|
Expect(len(result.Interfaces)).To(Equal(1))
|
||||||
@ -555,11 +610,11 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
})
|
})
|
||||||
|
|
||||||
It("configures and deconfigures mac address (from CNI_ARGS) with ADD/DEL", func() {
|
It(fmt.Sprintf("[%s] configures and deconfigures mac address (from CNI_ARGS) with ADD/DEL", ver), func() {
|
||||||
conf := []byte(`{
|
conf := []byte(fmt.Sprintf(`{
|
||||||
"name": "test",
|
"name": "test",
|
||||||
"type": "iplink",
|
"type": "iplink",
|
||||||
"cniVersion": "0.3.1",
|
"cniVersion": "%s",
|
||||||
"prevResult": {
|
"prevResult": {
|
||||||
"interfaces": [
|
"interfaces": [
|
||||||
{"name": "dummy0", "sandbox":"netns"}
|
{"name": "dummy0", "sandbox":"netns"}
|
||||||
@ -573,7 +628,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
}
|
}
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
}`)
|
}`, ver))
|
||||||
|
|
||||||
args := &skel.CmdArgs{
|
args := &skel.CmdArgs{
|
||||||
ContainerID: "dummy",
|
ContainerID: "dummy",
|
||||||
@ -591,301 +646,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
})
|
})
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
result, err := current.GetResult(r)
|
result, err := types100.GetResult(r)
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
Expect(len(result.Interfaces)).To(Equal(1))
|
|
||||||
Expect(result.Interfaces[0].Name).To(Equal(IFNAME))
|
|
||||||
Expect(len(result.IPs)).To(Equal(1))
|
|
||||||
Expect(result.IPs[0].Address.String()).To(Equal("10.0.0.2/24"))
|
|
||||||
|
|
||||||
link, err := netlink.LinkByName(IFNAME)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
hw, err := net.ParseMAC("c2:11:22:33:44:66")
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
fmt.Printf("%v, %v\n", link.Attrs().HardwareAddr, hw)
|
|
||||||
Expect(link.Attrs().HardwareAddr).To(Equal(hw))
|
|
||||||
|
|
||||||
err = testutils.CmdDel(originalNS.Path(),
|
|
||||||
args.ContainerID, "", func() error { return cmdDel(args) })
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
link, err = netlink.LinkByName(IFNAME)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
Expect(link.Attrs().HardwareAddr.String()).To(Equal(beforeConf.Mac))
|
|
||||||
|
|
||||||
return nil
|
|
||||||
})
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
})
|
|
||||||
|
|
||||||
It("configures and deconfigures promiscuous mode with CNI 0.4.0 ADD/DEL", func() {
|
|
||||||
conf := []byte(`{
|
|
||||||
"name": "test",
|
|
||||||
"type": "iplink",
|
|
||||||
"cniVersion": "0.4.0",
|
|
||||||
"promisc": true,
|
|
||||||
"prevResult": {
|
|
||||||
"interfaces": [
|
|
||||||
{"name": "dummy0", "sandbox":"netns"}
|
|
||||||
],
|
|
||||||
"ips": [
|
|
||||||
{
|
|
||||||
"version": "4",
|
|
||||||
"address": "10.0.0.2/24",
|
|
||||||
"gateway": "10.0.0.1",
|
|
||||||
"interface": 0
|
|
||||||
}
|
|
||||||
]
|
|
||||||
}
|
|
||||||
}`)
|
|
||||||
|
|
||||||
args := &skel.CmdArgs{
|
|
||||||
ContainerID: "dummy",
|
|
||||||
Netns: originalNS.Path(),
|
|
||||||
IfName: IFNAME,
|
|
||||||
StdinData: conf,
|
|
||||||
}
|
|
||||||
|
|
||||||
err := originalNS.Do(func(ns.NetNS) error {
|
|
||||||
defer GinkgoRecover()
|
|
||||||
|
|
||||||
r, _, err := testutils.CmdAddWithArgs(args, func() error {
|
|
||||||
return cmdAdd(args)
|
|
||||||
})
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
result, err := current.GetResult(r)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
Expect(len(result.Interfaces)).To(Equal(1))
|
|
||||||
Expect(result.Interfaces[0].Name).To(Equal(IFNAME))
|
|
||||||
Expect(len(result.IPs)).To(Equal(1))
|
|
||||||
Expect(result.IPs[0].Address.String()).To(Equal("10.0.0.2/24"))
|
|
||||||
|
|
||||||
link, err := netlink.LinkByName(IFNAME)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
Expect(link.Attrs().Promisc).To(Equal(1))
|
|
||||||
|
|
||||||
n := &TuningConf{}
|
|
||||||
err = json.Unmarshal([]byte(conf), &n)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
cniVersion := "0.4.0"
|
|
||||||
_, confString, err := buildOneConfig("testConfig", cniVersion, n, r)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
args.StdinData = confString
|
|
||||||
|
|
||||||
err = testutils.CmdCheckWithArgs(args, func() error {
|
|
||||||
return cmdCheck(args)
|
|
||||||
})
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
err = testutils.CmdDel(originalNS.Path(),
|
|
||||||
args.ContainerID, "", func() error { return cmdDel(args) })
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
link, err = netlink.LinkByName(IFNAME)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
Expect(link.Attrs().Promisc != 0).To(Equal(*beforeConf.Promisc))
|
|
||||||
|
|
||||||
return nil
|
|
||||||
})
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
})
|
|
||||||
|
|
||||||
It("configures and deconfigures mtu with CNI 0.4.0 ADD/DEL", func() {
|
|
||||||
conf := []byte(`{
|
|
||||||
"name": "test",
|
|
||||||
"type": "iplink",
|
|
||||||
"cniVersion": "0.4.0",
|
|
||||||
"mtu": 1454,
|
|
||||||
"prevResult": {
|
|
||||||
"interfaces": [
|
|
||||||
{"name": "dummy0", "sandbox":"netns"}
|
|
||||||
],
|
|
||||||
"ips": [
|
|
||||||
{
|
|
||||||
"version": "4",
|
|
||||||
"address": "10.0.0.2/24",
|
|
||||||
"gateway": "10.0.0.1",
|
|
||||||
"interface": 0
|
|
||||||
}
|
|
||||||
]
|
|
||||||
}
|
|
||||||
}`)
|
|
||||||
|
|
||||||
args := &skel.CmdArgs{
|
|
||||||
ContainerID: "dummy",
|
|
||||||
Netns: originalNS.Path(),
|
|
||||||
IfName: IFNAME,
|
|
||||||
StdinData: conf,
|
|
||||||
}
|
|
||||||
|
|
||||||
err := originalNS.Do(func(ns.NetNS) error {
|
|
||||||
defer GinkgoRecover()
|
|
||||||
|
|
||||||
r, _, err := testutils.CmdAddWithArgs(args, func() error {
|
|
||||||
return cmdAdd(args)
|
|
||||||
})
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
result, err := current.GetResult(r)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
Expect(len(result.Interfaces)).To(Equal(1))
|
|
||||||
Expect(result.Interfaces[0].Name).To(Equal(IFNAME))
|
|
||||||
Expect(len(result.IPs)).To(Equal(1))
|
|
||||||
Expect(result.IPs[0].Address.String()).To(Equal("10.0.0.2/24"))
|
|
||||||
|
|
||||||
link, err := netlink.LinkByName(IFNAME)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
Expect(link.Attrs().MTU).To(Equal(1454))
|
|
||||||
|
|
||||||
n := &TuningConf{}
|
|
||||||
err = json.Unmarshal([]byte(conf), &n)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
cniVersion := "0.4.0"
|
|
||||||
_, confString, err := buildOneConfig("testConfig", cniVersion, n, r)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
args.StdinData = confString
|
|
||||||
|
|
||||||
err = testutils.CmdCheckWithArgs(args, func() error {
|
|
||||||
return cmdCheck(args)
|
|
||||||
})
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
err = testutils.CmdDel(originalNS.Path(),
|
|
||||||
args.ContainerID, "", func() error { return cmdDel(args) })
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
link, err = netlink.LinkByName(IFNAME)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
Expect(link.Attrs().MTU).To(Equal(beforeConf.Mtu))
|
|
||||||
|
|
||||||
return nil
|
|
||||||
})
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
})
|
|
||||||
|
|
||||||
It("configures and deconfigures mac address (from conf file) with CNI v4.0 ADD/DEL", func() {
|
|
||||||
conf := []byte(`{
|
|
||||||
"name": "test",
|
|
||||||
"type": "iplink",
|
|
||||||
"cniVersion": "0.4.0",
|
|
||||||
"mac": "c2:11:22:33:44:55",
|
|
||||||
"prevResult": {
|
|
||||||
"interfaces": [
|
|
||||||
{"name": "dummy0", "sandbox":"netns"}
|
|
||||||
],
|
|
||||||
"ips": [
|
|
||||||
{
|
|
||||||
"version": "4",
|
|
||||||
"address": "10.0.0.2/24",
|
|
||||||
"gateway": "10.0.0.1",
|
|
||||||
"interface": 0
|
|
||||||
}
|
|
||||||
]
|
|
||||||
}
|
|
||||||
}`)
|
|
||||||
|
|
||||||
args := &skel.CmdArgs{
|
|
||||||
ContainerID: "dummy",
|
|
||||||
Netns: originalNS.Path(),
|
|
||||||
IfName: IFNAME,
|
|
||||||
StdinData: conf,
|
|
||||||
}
|
|
||||||
|
|
||||||
err := originalNS.Do(func(ns.NetNS) error {
|
|
||||||
defer GinkgoRecover()
|
|
||||||
|
|
||||||
r, _, err := testutils.CmdAddWithArgs(args, func() error {
|
|
||||||
return cmdAdd(args)
|
|
||||||
})
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
result, err := current.GetResult(r)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
Expect(len(result.Interfaces)).To(Equal(1))
|
|
||||||
Expect(result.Interfaces[0].Name).To(Equal(IFNAME))
|
|
||||||
Expect(len(result.IPs)).To(Equal(1))
|
|
||||||
Expect(result.IPs[0].Address.String()).To(Equal("10.0.0.2/24"))
|
|
||||||
|
|
||||||
link, err := netlink.LinkByName(IFNAME)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
hw, err := net.ParseMAC("c2:11:22:33:44:55")
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
Expect(link.Attrs().HardwareAddr).To(Equal(hw))
|
|
||||||
|
|
||||||
n := &TuningConf{}
|
|
||||||
err = json.Unmarshal([]byte(conf), &n)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
cniVersion := "0.4.0"
|
|
||||||
_, confString, err := buildOneConfig("testConfig", cniVersion, n, r)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
args.StdinData = confString
|
|
||||||
|
|
||||||
err = testutils.CmdCheckWithArgs(args, func() error {
|
|
||||||
return cmdCheck(args)
|
|
||||||
})
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
err = testutils.CmdDel(originalNS.Path(),
|
|
||||||
args.ContainerID, "", func() error { return cmdDel(args) })
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
link, err = netlink.LinkByName(IFNAME)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
Expect(link.Attrs().HardwareAddr.String()).To(Equal(beforeConf.Mac))
|
|
||||||
|
|
||||||
return nil
|
|
||||||
})
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
})
|
|
||||||
|
|
||||||
It("configures and deconfigures mac address (from CNI_ARGS) with CNI v4 ADD/DEL", func() {
|
|
||||||
conf := []byte(`{
|
|
||||||
"name": "test",
|
|
||||||
"type": "iplink",
|
|
||||||
"cniVersion": "0.4.0",
|
|
||||||
"prevResult": {
|
|
||||||
"interfaces": [
|
|
||||||
{"name": "dummy0", "sandbox":"netns"}
|
|
||||||
],
|
|
||||||
"ips": [
|
|
||||||
{
|
|
||||||
"version": "4",
|
|
||||||
"address": "10.0.0.2/24",
|
|
||||||
"gateway": "10.0.0.1",
|
|
||||||
"interface": 0
|
|
||||||
}
|
|
||||||
]
|
|
||||||
}
|
|
||||||
}`)
|
|
||||||
|
|
||||||
args := &skel.CmdArgs{
|
|
||||||
ContainerID: "dummy",
|
|
||||||
Netns: originalNS.Path(),
|
|
||||||
IfName: IFNAME,
|
|
||||||
StdinData: conf,
|
|
||||||
Args: "IgnoreUnknown=true;MAC=c2:11:22:33:44:66",
|
|
||||||
}
|
|
||||||
|
|
||||||
err := originalNS.Do(func(ns.NetNS) error {
|
|
||||||
defer GinkgoRecover()
|
|
||||||
|
|
||||||
r, _, err := testutils.CmdAddWithArgs(args, func() error {
|
|
||||||
return cmdAdd(args)
|
|
||||||
})
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
result, err := current.GetResult(r)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
Expect(len(result.Interfaces)).To(Equal(1))
|
Expect(len(result.Interfaces)).To(Equal(1))
|
||||||
@ -899,12 +660,12 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
Expect(link.Attrs().HardwareAddr).To(Equal(hw))
|
Expect(link.Attrs().HardwareAddr).To(Equal(hw))
|
||||||
|
|
||||||
|
if testutils.SpecVersionHasCHECK(ver) {
|
||||||
n := &TuningConf{}
|
n := &TuningConf{}
|
||||||
err = json.Unmarshal([]byte(conf), &n)
|
err = json.Unmarshal([]byte(conf), &n)
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
cniVersion := "0.4.0"
|
_, confString, err := buildOneConfig("testConfig", ver, n, r)
|
||||||
_, confString, err := buildOneConfig("testConfig", cniVersion, n, r)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
args.StdinData = confString
|
args.StdinData = confString
|
||||||
@ -913,6 +674,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
return cmdCheck(args)
|
return cmdCheck(args)
|
||||||
})
|
})
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
}
|
||||||
|
|
||||||
err = testutils.CmdDel(originalNS.Path(),
|
err = testutils.CmdDel(originalNS.Path(),
|
||||||
args.ContainerID, "", func() error { return cmdDel(args) })
|
args.ContainerID, "", func() error { return cmdDel(args) })
|
||||||
@ -927,11 +689,11 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
})
|
})
|
||||||
|
|
||||||
It("configures and deconfigures mac address (from RuntimeConfig) with ADD/DEL", func() {
|
It(fmt.Sprintf("[%s] configures and deconfigures mac address (from RuntimeConfig) with ADD/DEL", ver), func() {
|
||||||
conf := []byte(`{
|
conf := []byte(fmt.Sprintf(`{
|
||||||
"name": "test",
|
"name": "test",
|
||||||
"type": "iplink",
|
"type": "iplink",
|
||||||
"cniVersion": "0.3.1",
|
"cniVersion": "%s",
|
||||||
"capabilities": {"mac": true},
|
"capabilities": {"mac": true},
|
||||||
"RuntimeConfig": {
|
"RuntimeConfig": {
|
||||||
"mac": "c2:11:22:33:44:55"
|
"mac": "c2:11:22:33:44:55"
|
||||||
@ -949,7 +711,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
}
|
}
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
}`)
|
}`, ver))
|
||||||
|
|
||||||
args := &skel.CmdArgs{
|
args := &skel.CmdArgs{
|
||||||
ContainerID: "dummy",
|
ContainerID: "dummy",
|
||||||
@ -966,7 +728,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
})
|
})
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
result, err := current.GetResult(r)
|
result, err := types100.GetResult(r)
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
Expect(len(result.Interfaces)).To(Equal(1))
|
Expect(len(result.Interfaces)).To(Equal(1))
|
||||||
@ -993,11 +755,11 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
})
|
})
|
||||||
|
|
||||||
It("configures and deconfigures mac address, promisc mode and MTU (from conf file) with custom dataDir", func() {
|
It(fmt.Sprintf("[%s] configures and deconfigures mac address, promisc mode and MTU (from conf file) with custom dataDir", ver), func() {
|
||||||
conf := []byte(`{
|
conf := []byte(fmt.Sprintf(`{
|
||||||
"name": "test",
|
"name": "test",
|
||||||
"type": "iplink",
|
"type": "iplink",
|
||||||
"cniVersion": "0.4.0",
|
"cniVersion": "%s",
|
||||||
"mac": "c2:11:22:33:44:77",
|
"mac": "c2:11:22:33:44:77",
|
||||||
"promisc": true,
|
"promisc": true,
|
||||||
"mtu": 4000,
|
"mtu": 4000,
|
||||||
@ -1015,7 +777,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
}
|
}
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
}`)
|
}`, ver))
|
||||||
|
|
||||||
args := &skel.CmdArgs{
|
args := &skel.CmdArgs{
|
||||||
ContainerID: "dummy",
|
ContainerID: "dummy",
|
||||||
@ -1032,7 +794,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
})
|
})
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
result, err := current.GetResult(r)
|
result, err := types100.GetResult(r)
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
Expect(len(result.Interfaces)).To(Equal(1))
|
Expect(len(result.Interfaces)).To(Equal(1))
|
||||||
@ -1050,12 +812,12 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
|
|
||||||
Expect("/tmp/tuning-test/dummy_dummy0.json").Should(BeAnExistingFile())
|
Expect("/tmp/tuning-test/dummy_dummy0.json").Should(BeAnExistingFile())
|
||||||
|
|
||||||
|
if testutils.SpecVersionHasCHECK(ver) {
|
||||||
n := &TuningConf{}
|
n := &TuningConf{}
|
||||||
err = json.Unmarshal([]byte(conf), &n)
|
err = json.Unmarshal([]byte(conf), &n)
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
cniVersion := "0.4.0"
|
_, confString, err := buildOneConfig("testConfig", ver, n, r)
|
||||||
_, confString, err := buildOneConfig("testConfig", cniVersion, n, r)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
args.StdinData = confString
|
args.StdinData = confString
|
||||||
@ -1064,6 +826,7 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
return cmdCheck(args)
|
return cmdCheck(args)
|
||||||
})
|
})
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
}
|
||||||
|
|
||||||
err = testutils.CmdDel(originalNS.Path(),
|
err = testutils.CmdDel(originalNS.Path(),
|
||||||
args.ContainerID, "", func() error { return cmdDel(args) })
|
args.ContainerID, "", func() error { return cmdDel(args) })
|
||||||
@ -1079,5 +842,5 @@ var _ = Describe("tuning plugin", func() {
|
|||||||
})
|
})
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
})
|
})
|
||||||
|
}
|
||||||
})
|
})
|
||||||
|
Reference in New Issue
Block a user