Function TestMountAtRuntime

integration/client/mount_manager_linux_test.go:66–189

(t *testing.T)

}

func TestMountAtRuntime(t *testing.T) {
	client, err := newClient(t, address)
	if err != nil {
		t.Fatal(err)
	}
	defer client.Close()

	var (
		ctx, cancel = testContext(t)
		id1         = fmt.Sprintf("%s-1", t.Name())
		id2         = fmt.Sprintf("%s-2", t.Name())
		testDev     = createImgFile(t, "test-dev.img")
		workDir     = filepath.Join(t.TempDir(), "work")
	)
	defer cancel()

	require.NoError(t, os.MkdirAll(workDir, 0755))

	ctx, done, err := client.WithLease(ctx)
	require.NoError(t, err)
	defer done(ctx)

	img, err := client.GetImage(ctx, testImage)
	require.NoError(t, err)

	snapshotter := client.SnapshotService(defaults.DefaultSnapshotter)
	diffIDs, err := img.RootFS(ctx)
	require.NoError(t, err)

	mnt, err := snapshotter.View(ctx, id1, identity.ChainID(diffIDs).String())
	require.NoError(t, err)
	if len(mnt) > 1 {
		t.Skipf("Test can only be run with single mount")
	}
	m := append(mnt, mount.Mount{
		Type:    "xfs",
		Source:  testDev,
		Options: []string{"loop"},
	}, mount.Mount{
		Type:    "format/overlay",
		Source:  "overlay",
		Options: []string{"lowerdir={{ mount 0 }}", "upperdir={{ mount 1 }}/root1", "workdir={{ mount 1 }}/work", "index=off"},
	})

	container1, err := client.NewContainer(ctx, id1, containerd.WithNewSpec(withImage(img, "sh", "-c", `echo -n 'Test mount at runtime'> /etc/test-name.txt`)))
	require.NoError(t, err)
	defer func() { assert.NoError(t, container1.Delete(ctx)) }()

	task, err := container1.NewTask(ctx, empty(), containerd.WithRootFS(m))
	require.NoError(t, err)
	defer func() {
		if task != nil {
			task.Delete(ctx)
		}
	}()

	info, err := client.MountManager().Info(ctx, id1)
	require.NoError(t, err)