Function CreateTask

pkg/sentry/fsimpl/testutil/kernel.go:129–168

CreateTask creates a new bare bones task for tests.

(ctx context.Context, name string, tc *kernel.ThreadGroup, mntns *vfs.MountNamespace, root, cwd vfs.VirtualDentry)

// CreateTask creates a new bare bones task for tests.
func CreateTask(ctx context.Context, name string, tc *kernel.ThreadGroup, mntns *vfs.MountNamespace, root, cwd vfs.VirtualDentry) (*kernel.Task, error) {
	k := kernel.KernelFromContext(ctx)
	if k == nil {
		return nil, fmt.Errorf("cannot find kernel from context")
	}

	exe, err := newFakeExecutable(ctx, k.VFS(), auth.CredentialsFromContext(ctx), root)
	if err != nil {
		return nil, err
	}
	m, err := mm.NewMemoryManager(k, k.MemoryFile())
	if err != nil {
		return nil, err
	}
	m.SetExecutable(ctx, exe)

	creds := auth.CredentialsFromContext(ctx)
	config := &kernel.TaskConfig{
		Kernel:           k,
		ThreadGroup:      tc,
		TaskImage:        &kernel.TaskImage{Name: name, MemoryManager: m},
		Credentials:      auth.CredentialsFromContext(ctx),
		NetworkNamespace: k.RootNetworkNamespace(),
		AllowedCPUMask:   sched.NewFullCPUSet(k.ApplicationCores()),
		UTSNamespace:     kernel.UTSNamespaceFromContext(ctx),
		IPCNamespace:     kernel.IPCNamespaceFromContext(ctx),
		MountNamespace:   mntns,
		FSContext:        kernel.NewFSContext(root, cwd, 0022),
		FDTable:          k.NewFDTable(),
		UserCounters:     k.GetUserCounters(creds.RealKUID),
	}
	config.NetworkNamespace.IncRef()
	config.Credentials.UserNamespace.IncRef()
	t, err := k.TaskSet().NewTask(ctx, config)
	if err != nil {
		config.ThreadGroup.Release(ctx)
		return nil, err
	}
	return t, nil
}

func newFakeExecutable(ctx context.Context, vfsObj *vfs.VirtualFilesystem, creds *auth.Credentials, root vfs.VirtualDentry) (*vfs.FileDescription, error) {
	const name = "executable"