Merge pull request #29747 from xlgao-zju/break-the-for
exit collect when we get EOF Upstream-commit: 3c64061b6719e26a2a14d314d39f42e7df6ad9a4 Component: engine
This commit is contained in:
@@ -152,11 +152,13 @@ func collect(ctx context.Context, s *formatter.ContainerStats, cli client.APICli
|
||||
waitFirst.Done()
|
||||
}
|
||||
case err := <-u:
|
||||
s.SetError(err)
|
||||
if err == io.EOF {
|
||||
break
|
||||
}
|
||||
if err != nil {
|
||||
s.SetError(err)
|
||||
continue
|
||||
}
|
||||
s.SetError(nil)
|
||||
// if this is the first stat you get, release WaitGroup
|
||||
if !getFirst {
|
||||
getFirst = true
|
||||
|
||||
Reference in New Issue
Block a user