(vmid int)
| 340 | } |
| 341 | |
| 342 | func (tm *TaskManager) GetActiveTask(vmid int) *Task { |
| 343 | tm.mu.RLock() |
| 344 | defer tm.mu.RUnlock() |
| 345 | for _, task := range tm.activeTasks { |
| 346 | if task.TargetVMID == vmid { |
| 347 | return cloneTask(task) |
| 348 | } |
| 349 | } |
| 350 | return nil |
| 351 | } |
| 352 | |
| 353 | func (tm *TaskManager) GetActiveTaskForVM(node string, vmid int) *Task { |
| 354 | tm.mu.RLock() |
nothing calls this directly
no test coverage detected