mirror of https://github.com/docker/cli.git
Merge pull request #5044 from vvoland/wait-cancel-noerror
[26.1 backport] waitExitOrRemoved: Handle context cancellation
This commit is contained in:
commit
1e6db5d24b
|
@ -2,6 +2,7 @@ package container
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
"errors"
|
||||||
"strconv"
|
"strconv"
|
||||||
|
|
||||||
"github.com/docker/docker/api/types"
|
"github.com/docker/docker/api/types"
|
||||||
|
@ -36,6 +37,8 @@ func waitExitOrRemoved(ctx context.Context, apiClient client.APIClient, containe
|
||||||
statusC := make(chan int)
|
statusC := make(chan int)
|
||||||
go func() {
|
go func() {
|
||||||
select {
|
select {
|
||||||
|
case <-ctx.Done():
|
||||||
|
return
|
||||||
case result := <-resultC:
|
case result := <-resultC:
|
||||||
if result.Error != nil {
|
if result.Error != nil {
|
||||||
logrus.Errorf("Error waiting for container: %v", result.Error.Message)
|
logrus.Errorf("Error waiting for container: %v", result.Error.Message)
|
||||||
|
@ -44,6 +47,9 @@ func waitExitOrRemoved(ctx context.Context, apiClient client.APIClient, containe
|
||||||
statusC <- int(result.StatusCode)
|
statusC <- int(result.StatusCode)
|
||||||
}
|
}
|
||||||
case err := <-errC:
|
case err := <-errC:
|
||||||
|
if errors.Is(err, context.Canceled) {
|
||||||
|
return
|
||||||
|
}
|
||||||
logrus.Errorf("error waiting for container: %v", err)
|
logrus.Errorf("error waiting for container: %v", err)
|
||||||
statusC <- 125
|
statusC <- 125
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue