Function runTest

pkg/sentry/kernel/pipe/pipe_test.go:29–47

(t *testing.T, sizeBytes int64, tester func(ctx context.Context, r, w *vfs.FileDescription))

)

func runTest(t *testing.T, sizeBytes int64, tester func(ctx context.Context, r, w *vfs.FileDescription)) {
	ctx := contexttest.Context(t)
	vfsObj := &vfs.VirtualFilesystem{}
	if err := vfsObj.Init(ctx); err != nil {
		t.Fatalf("VFS init: %v", err)
	}
	vd := vfsObj.NewAnonVirtualDentry("pipe")
	defer vd.DecRef(ctx)

	vp := NewVFSPipe(false /* isNamed */, sizeBytes)
	r, w, err := vp.ReaderWriterPair(ctx, vd.Mount(), vd.Dentry(), 0)
	if err != nil {
		t.Fatalf("ReaderWriterPair failed: %v", err)
	}
	defer r.DecRef(ctx)
	defer w.DecRef(ctx)

	tester(ctx, r, w)
}

func TestPipeRW(t *testing.T) {
	runTest(t, 65536, func(ctx context.Context, r *vfs.FileDescription, w *vfs.FileDescription) {