setComplete is an internal function to set the job to completed. This does not send the completedJob.
(c *proto.CompletedJob)
| 290 | |
| 291 | // setComplete is an internal function to set the job to completed. This does not send the completedJob. |
| 292 | func (r *Runner) setComplete(c *proto.CompletedJob) { |
| 293 | r.mutex.Lock() |
| 294 | defer r.mutex.Unlock() |
| 295 | if r.completedJob == nil { |
| 296 | r.completedJob = c |
| 297 | r.cond.Signal() |
| 298 | } |
| 299 | } |
| 300 | |
| 301 | // setFail is an internal function to set the job to failed. This does not send the failedJob. |
| 302 | func (r *Runner) setFail(f *proto.FailedJob) { |
no test coverage detected