abortWorkerProcess terminates & aborts untidily, most probably breakdown of comms or internal error
(ctx *customAdapterWorkerContext)
| 237 | |
| 238 | // abortWorkerProcess terminates & aborts untidily, most probably breakdown of comms or internal error |
| 239 | func (a *customAdapter) abortWorkerProcess(ctx *customAdapterWorkerContext) { |
| 240 | a.Trace("xfer: Aborting worker process: %d", ctx.workerNum) |
| 241 | ctx.stdin.Close() |
| 242 | ctx.stdout.Close() |
| 243 | ctx.cmd.Process.Kill() |
| 244 | } |
| 245 | func (a *customAdapter) WorkerEnding(workerNum int, ctx interface{}) { |
| 246 | customCtx, ok := ctx.(*customAdapterWorkerContext) |
| 247 | if !ok { |
no test coverage detected