CgroupParent: runner.expectCgroupParent,
CgroupRoot: runner.cgroupRoot,
PollPeriod: runner.statInterval,
+ TempDir: runner.parentTemp,
}
runner.statReporter.Start()
return nil
}
containerdGone := make(chan error)
- defer func() {
- close(containerdGone)
- }()
+ defer close(containerdGone)
if runner.checkContainerd > 0 {
go func() {
ticker := time.NewTicker(time.Duration(runner.checkContainerd))
return
}
case <-containerdGone:
- break
+ // Channel closed, quit goroutine
+ return
}
}
}()