()
| 61 | } |
| 62 | |
| 63 | func (h *taskHandle) watchWaitCh() { |
| 64 | select { |
| 65 | case r := <-h.waitCh: |
| 66 | h.stateLock.Lock() |
| 67 | h.exitResult = r |
| 68 | h.cancelFunc() |
| 69 | h.stateLock.Unlock() |
| 70 | case <-h.ctx.Done(): |
| 71 | } |
| 72 | } |
| 73 | |
| 74 | func (h *taskHandle) TaskStatus() (*drivers.TaskStatus, error) { |
| 75 | h.stateLock.RLock() |