remove pkg/testutil/loopback_linux.go and use continuity/testutil/loopback
Signed-off-by: Akihiro Suda <suda.akihiro@lab.ntt.co.jp>
This commit is contained in:
138
mount/lookup_linux_test.go
Normal file
138
mount/lookup_linux_test.go
Normal file
@@ -0,0 +1,138 @@
|
||||
// +build linux
|
||||
|
||||
/*
|
||||
Copyright The containerd Authors.
|
||||
|
||||
Licensed under the Apache License, Version 2.0 (the "License");
|
||||
you may not use this file except in compliance with the License.
|
||||
You may obtain a copy of the License at
|
||||
|
||||
http://www.apache.org/licenses/LICENSE-2.0
|
||||
|
||||
Unless required by applicable law or agreed to in writing, software
|
||||
distributed under the License is distributed on an "AS IS" BASIS,
|
||||
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
See the License for the specific language governing permissions and
|
||||
limitations under the License.
|
||||
*/
|
||||
|
||||
package mount
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"io/ioutil"
|
||||
"os"
|
||||
"os/exec"
|
||||
"path/filepath"
|
||||
"strings"
|
||||
"testing"
|
||||
|
||||
// containerd/pkg/testutil has circular dependency on this mount pkg.
|
||||
// so we use continuity/testutil instead.
|
||||
"github.com/containerd/continuity/testutil"
|
||||
"github.com/containerd/continuity/testutil/loopback"
|
||||
"gotest.tools/assert"
|
||||
)
|
||||
|
||||
func checkLookup(t *testing.T, fsType, mntPoint, dir string) {
|
||||
t.Helper()
|
||||
info, err := Lookup(dir)
|
||||
assert.NilError(t, err)
|
||||
assert.Equal(t, fsType, info.FSType)
|
||||
assert.Equal(t, mntPoint, info.Mountpoint)
|
||||
}
|
||||
|
||||
func testLookup(t *testing.T, fsType string) {
|
||||
testutil.RequiresRoot(t)
|
||||
mnt, err := ioutil.TempDir("", "containerd-mountinfo-test-lookup")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll(mnt)
|
||||
|
||||
deviceName, cleanupDevice, err := loopback.New(100 << 20) // 100 MB
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
if out, err := exec.Command("mkfs", "-t", fsType, deviceName).CombinedOutput(); err != nil {
|
||||
// not fatal
|
||||
cleanupDevice()
|
||||
t.Skipf("could not mkfs (%s) %s: %v (out: %q)", fsType, deviceName, err, string(out))
|
||||
}
|
||||
if out, err := exec.Command("mount", deviceName, mnt).CombinedOutput(); err != nil {
|
||||
// not fatal
|
||||
cleanupDevice()
|
||||
t.Skipf("could not mount %s: %v (out: %q)", deviceName, err, string(out))
|
||||
}
|
||||
defer func() {
|
||||
testutil.Unmount(t, mnt)
|
||||
cleanupDevice()
|
||||
}()
|
||||
assert.Check(t, strings.HasPrefix(deviceName, "/dev/loop"))
|
||||
checkLookup(t, fsType, mnt, mnt)
|
||||
|
||||
newMnt, err := ioutil.TempDir("", "containerd-mountinfo-test-newMnt")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
defer os.RemoveAll(newMnt)
|
||||
|
||||
if out, err := exec.Command("mount", "--bind", mnt, newMnt).CombinedOutput(); err != nil {
|
||||
t.Fatalf("could not mount %s to %s: %v (out: %q)", mnt, newMnt, err, string(out))
|
||||
}
|
||||
defer func() {
|
||||
testutil.Unmount(t, newMnt)
|
||||
}()
|
||||
checkLookup(t, fsType, newMnt, newMnt)
|
||||
|
||||
subDir := filepath.Join(newMnt, "subDir")
|
||||
err = os.MkdirAll(subDir, 0700)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
checkLookup(t, fsType, newMnt, subDir)
|
||||
}
|
||||
|
||||
func TestLookupWithExt4(t *testing.T) {
|
||||
testLookup(t, "ext4")
|
||||
}
|
||||
|
||||
func TestLookupWithXFS(t *testing.T) {
|
||||
testLookup(t, "xfs")
|
||||
}
|
||||
|
||||
func TestLookupWithOverlay(t *testing.T) {
|
||||
lower, err := ioutil.TempDir("", "containerd-mountinfo-test-lower")
|
||||
assert.NilError(t, err)
|
||||
defer os.RemoveAll(lower)
|
||||
|
||||
upper, err := ioutil.TempDir("", "containerd-mountinfo-test-upper")
|
||||
assert.NilError(t, err)
|
||||
defer os.RemoveAll(upper)
|
||||
|
||||
work, err := ioutil.TempDir("", "containerd-mountinfo-test-work")
|
||||
assert.NilError(t, err)
|
||||
defer os.RemoveAll(work)
|
||||
|
||||
overlay, err := ioutil.TempDir("", "containerd-mountinfo-test-overlay")
|
||||
assert.NilError(t, err)
|
||||
defer os.RemoveAll(overlay)
|
||||
|
||||
if out, err := exec.Command("mount", "-t", "overlay", "overlay", "-o", fmt.Sprintf("lowerdir=%s,upperdir=%s,workdir=%s",
|
||||
lower, upper, work), overlay).CombinedOutput(); err != nil {
|
||||
// not fatal
|
||||
t.Skipf("could not mount overlay: %v (out: %q)", err, string(out))
|
||||
}
|
||||
defer testutil.Unmount(t, overlay)
|
||||
|
||||
testdir := filepath.Join(overlay, "testdir")
|
||||
err = os.Mkdir(testdir, 0777)
|
||||
assert.NilError(t, err)
|
||||
|
||||
testfile := filepath.Join(overlay, "testfile")
|
||||
_, err = os.Create(testfile)
|
||||
assert.NilError(t, err)
|
||||
|
||||
checkLookup(t, "overlay", overlay, testdir)
|
||||
checkLookup(t, "overlay", overlay, testfile)
|
||||
}
|
Reference in New Issue
Block a user