oci: remove busy loop
Signed-off-by: Antonio Murdaca <runcom@redhat.com>
This commit is contained in:
parent
00444753e7
commit
9e6359b6f7
1 changed files with 19 additions and 5 deletions
16
oci/oci.go
16
oci/oci.go
|
@ -514,13 +514,26 @@ func (r *Runtime) StopContainer(c *Container, timeout int64) error {
|
|||
timeout = 10
|
||||
}
|
||||
done := make(chan struct{})
|
||||
// we could potentially re-use "done" channel to exit the loop on timeout
|
||||
// but we use another channel "chControl" so that we won't never incur in the
|
||||
// case the "done" channel is closed in the "default" select case and we also
|
||||
// reach the timeout in the select below. If that happens we could raise
|
||||
// a panic closing a closed channel so better be safe and use another new
|
||||
// channel just to control the loop.
|
||||
chControl := make(chan struct{})
|
||||
go func() {
|
||||
for {
|
||||
select {
|
||||
case <-chControl:
|
||||
return
|
||||
default:
|
||||
// Check if the process is still around
|
||||
err := unix.Kill(c.state.Pid, 0)
|
||||
if err == syscall.ESRCH {
|
||||
close(done)
|
||||
break
|
||||
return
|
||||
}
|
||||
time.Sleep(100 * time.Millisecond)
|
||||
}
|
||||
}
|
||||
}()
|
||||
|
@ -528,6 +541,7 @@ func (r *Runtime) StopContainer(c *Container, timeout int64) error {
|
|||
case <-done:
|
||||
return nil
|
||||
case <-time.After(time.Duration(timeout) * time.Second):
|
||||
close(chControl)
|
||||
err := unix.Kill(c.state.Pid, syscall.SIGKILL)
|
||||
if err != nil && err != syscall.ESRCH {
|
||||
return fmt.Errorf("failed to kill process: %v", err)
|
||||
|
|
Loading…
Reference in a new issue