(taskID, execID string)
| 312 | } |
| 313 | |
| 314 | func (m *taskManager) IsProxyOpen(taskID, execID string) (bool, error) { |
| 315 | m.mu.Lock() |
| 316 | defer m.mu.Unlock() |
| 317 | |
| 318 | proc, err := m.findProc(taskID, execID) |
| 319 | if err != nil { |
| 320 | return false, err |
| 321 | } |
| 322 | |
| 323 | return proc.proxy.IsOpen(), nil |
| 324 | } |
| 325 | |
| 326 | // findProc returns a vmProc if exists. The function itself doesn't lock the manager's mutex. |
| 327 | // The callers are responsible to lock/unlock since they may mutate the value. |