Method findProc

internal/vm/task.go:328–343

findProc returns a vmProc if exists. The function itself doesn't lock the manager's mutex. The callers are responsible to lock/unlock since they may mutate the value.

(taskID, execID string)

// findProc returns a vmProc if exists. The function itself doesn't lock the manager's mutex.
// The callers are responsible to lock/unlock since they may mutate the value.
func (m *taskManager) findProc(taskID, execID string) (*vmProc, error) {
	_, ok := m.tasks[taskID]
	if !ok {
		return nil, fmt.Errorf("cannot find exec %q from non-existent task %q", execID, taskID)
	}

	proc, ok := m.tasks[taskID][execID]
	if !ok {
		return nil, fmt.Errorf("cannot find non-existent exec %q from task %q", execID, taskID)
	}

	if proc.proxy == nil {
		return nil, fmt.Errorf("exec %q and task %q are present, but no proxy", taskID, execID)
	}
	return proc, nil
}

func (m *taskManager) AttachIO(_ context.Context, taskID, execID string, proxy IOProxy) error {
	m.mu.Lock()