()
| 311 | } |
| 312 | |
| 313 | func (h *taskHandle) Destroy() { |
| 314 | if h.shutdown { |
| 315 | return |
| 316 | } |
| 317 | h.stateLock.Lock() |
| 318 | h.shutdown = true |
| 319 | h.stateLock.Unlock() |
| 320 | |
| 321 | common.WriteWaitCh(h.waitCh, &drivers.ExitResult{ |
| 322 | ExitCode: 0, |
| 323 | Signal: 0, |
| 324 | OOMKilled: false, |
| 325 | Err: nil, |
| 326 | }) |
| 327 | |
| 328 | if h.runner != nil { |
| 329 | err := h.runner.Shutdown() |
| 330 | if err != nil { |
| 331 | h.logger.Error("error in h.runner.Shutdown", "err", err) |
| 332 | } |
| 333 | } |
| 334 | } |
| 335 | |
| 336 | func (h *taskHandle) GetExitResult() *drivers.ExitResult { |
| 337 | h.stateLock.Lock() |
no test coverage detected