github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-04 09:49:50 +00:00
Code Issues Projects Releases Wiki Activity

Update e2e test with private mount propagation

Browse Source
This commit is contained in:
Jan Safranek 2018-04-11 15:50:11 +02:00
parent 01a44d22cf
commit a943fdda8a
1 changed files with 16 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
test/e2e/node/mount_propagation.go
View File

@ -28,7 +28,7 @@ import (
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
) )
func preparePod(name string, node *v1.Node, propagation v1.MountPropagationMode, hostDir string) *v1.Pod { func preparePod(name string, node *v1.Node, propagation *v1.MountPropagationMode, hostDir string) *v1.Pod {
const containerName = "cntr" const containerName = "cntr"
bTrue := true bTrue := true
var oneSecond int64 = 1 var oneSecond int64 = 1
@ -49,7 +49,7 @@ func preparePod(name string, node *v1.Node, propagation v1.MountPropagationMode,
{ {
Name: "host", Name: "host",
MountPath: "/mnt/test", MountPath: "/mnt/test",
MountPropagation: &propagation, MountPropagation: propagation,
}, },
}, },
SecurityContext: &v1.SecurityContext{ SecurityContext: &v1.SecurityContext{
@ -105,12 +105,19 @@ var _ = SIGDescribe("Mount propagation", func() {
}() }()
podClient := f.PodClient() podClient := f.PodClient()
master := podClient.CreateSync(preparePod("master", node, v1.MountPropagationBidirectional, hostDir)) bidirectional := v1.MountPropagationBidirectional
slave := podClient.CreateSync(preparePod("slave", node, v1.MountPropagationHostToContainer, hostDir)) master := podClient.CreateSync(preparePod("master", node, &bidirectional, hostDir))
hostToContainer := v1.MountPropagationHostToContainer
slave := podClient.CreateSync(preparePod("slave", node, &hostToContainer, hostDir))
none := v1.MountPropagationNone
private := podClient.CreateSync(preparePod("private", node, &none, hostDir))
defaultPropagation := podClient.CreateSync(preparePod("default", node, nil, hostDir))
// Check that the pods sees directories of each other. This just checks // Check that the pods sees directories of each other. This just checks
// that they have the same HostPath, not the mount propagation. // that they have the same HostPath, not the mount propagation.
podNames := []string{master.Name, slave.Name} podNames := []string{master.Name, slave.Name, private.Name, defaultPropagation.Name}
for _, podName := range podNames { for _, podName := range podNames {
for _, dirName := range podNames { for _, dirName := range podNames {
cmd := fmt.Sprintf("test -d /mnt/test/%s", dirName) cmd := fmt.Sprintf("test -d /mnt/test/%s", dirName)
@ -147,6 +154,10 @@ var _ = SIGDescribe("Mount propagation", func() {
"master": sets.NewString("master", "host"), "master": sets.NewString("master", "host"),
// Slave sees master's mount + itself. // Slave sees master's mount + itself.
"slave": sets.NewString("master", "slave", "host"), "slave": sets.NewString("master", "slave", "host"),
// Private sees only its own mount
"private": sets.NewString("private"),
// Default (=private) sees only its own mount
"default": sets.NewString("default"),
} }
dirNames := append(podNames, "host") dirNames := append(podNames, "host")
for podName, mounts := range expectedMounts { for podName, mounts := range expectedMounts {