mirror of
https://github.com/kata-containers/kata-containers.git
synced 2025-07-01 09:42:45 +00:00
tests: Fix units tests to check empty-dir volumes backed by host-dir
Test verify that k8s volumes that are mounted as tmpfs are considered as ephemeral. Signed-off-by: Archana Shinde <archana.m.shinde@intel.com>
This commit is contained in:
parent
47a6023382
commit
8e2a5eaa36
@ -16,6 +16,7 @@ import (
|
|||||||
"path"
|
"path"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
"strings"
|
"strings"
|
||||||
|
"syscall"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
vc "github.com/kata-containers/runtime/virtcontainers"
|
vc "github.com/kata-containers/runtime/virtcontainers"
|
||||||
@ -177,12 +178,30 @@ func findLastParam(key string, params []vc.Param) (string, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func TestSetEphemeralStorageType(t *testing.T) {
|
func TestSetEphemeralStorageType(t *testing.T) {
|
||||||
|
if os.Geteuid() != 0 {
|
||||||
|
t.Skip(testDisabledNeedRoot)
|
||||||
|
}
|
||||||
|
|
||||||
assert := assert.New(t)
|
assert := assert.New(t)
|
||||||
|
|
||||||
|
dir, err := ioutil.TempDir(testDir, "foo")
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
defer os.RemoveAll(dir)
|
||||||
|
|
||||||
|
ephePath := filepath.Join(dir, k8sEmptyDir, "tmp-volume")
|
||||||
|
err = os.MkdirAll(ephePath, testDirMode)
|
||||||
|
assert.Nil(err)
|
||||||
|
|
||||||
|
err = syscall.Mount("tmpfs", ephePath, "tmpfs", 0, "")
|
||||||
|
assert.Nil(err)
|
||||||
|
defer syscall.Unmount(ephePath, 0)
|
||||||
|
|
||||||
ociSpec := oci.CompatOCISpec{}
|
ociSpec := oci.CompatOCISpec{}
|
||||||
var ociMounts []specs.Mount
|
var ociMounts []specs.Mount
|
||||||
mount := specs.Mount{
|
mount := specs.Mount{
|
||||||
Source: "/var/lib/kubelet/pods/366c3a77-4869-11e8-b479-507b9ddd5ce4/volumes/kubernetes.io~empty-dir/cache-volume",
|
Source: ephePath,
|
||||||
}
|
}
|
||||||
|
|
||||||
ociMounts = append(ociMounts, mount)
|
ociMounts = append(ociMounts, mount)
|
||||||
|
@ -368,7 +368,24 @@ func TestGetFileContents(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func TestIsEphemeralStorage(t *testing.T) {
|
func TestIsEphemeralStorage(t *testing.T) {
|
||||||
sampleEphePath := "/var/lib/kubelet/pods/366c3a75-4869-11e8-b479-507b9ddd5ce4/volumes/kubernetes.io~empty-dir/cache-volume"
|
if os.Geteuid() != 0 {
|
||||||
|
t.Skip(testDisabledNeedRoot)
|
||||||
|
}
|
||||||
|
|
||||||
|
dir, err := ioutil.TempDir(testDir, "foo")
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
defer os.RemoveAll(dir)
|
||||||
|
|
||||||
|
sampleEphePath := filepath.Join(dir, k8sEmptyDir, "tmp-volume")
|
||||||
|
err = os.MkdirAll(sampleEphePath, testDirMode)
|
||||||
|
assert.Nil(t, err)
|
||||||
|
|
||||||
|
err = syscall.Mount("tmpfs", sampleEphePath, "tmpfs", 0, "")
|
||||||
|
assert.Nil(t, err)
|
||||||
|
defer syscall.Unmount(sampleEphePath, 0)
|
||||||
|
|
||||||
isEphe := IsEphemeralStorage(sampleEphePath)
|
isEphe := IsEphemeralStorage(sampleEphePath)
|
||||||
if !isEphe {
|
if !isEphe {
|
||||||
t.Fatalf("Unable to correctly determine volume type")
|
t.Fatalf("Unable to correctly determine volume type")
|
||||||
|
Loading…
Reference in New Issue
Block a user