Method Enqueue

internal/taskmanager/manager.go:97–135

(task *Task)

}

func (tm *TaskManager) Enqueue(task *Task) {
	if task == nil {
		return
	}

	var startTask *Task

	tm.mu.Lock()
	if task.ID == "" {
		task.ID = uuid.New().String()
	}

	// Keep task manager state isolated from caller-owned memory to avoid
	// cross-goroutine races when callers inspect their original task pointer.
	internalTask := cloneTask(task)
	internalTask.Status = StatusQueued
	internalTask.CreatedAt = time.Now()

	key := taskKey(internalTask.TargetNode, internalTask.TargetVMID)

	// Check if there is an active task for this VM on this node
	if _, active := tm.activeTasks[key]; !active && len(tm.activeTasks) < tm.maxRunning {
		// No active task, start immediately
		tm.activeTasks[key] = internalTask
		startTask = internalTask
	} else {
		// Active task exists, append to queue
		tm.queue[key] = append(tm.queue[key], internalTask)
	}
	tm.mu.Unlock()

	if startTask != nil {
		go tm.runTask(startTask)
	}

	if tm.updateNotify != nil {
		go tm.updateNotify()
	}
}

func (tm *TaskManager) runTask(task *Task) {
	// Update status to running