github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-24 20:24:09 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #78825 from pswica/logs-wg

Browse Source 
Adding defer wg.Done() Statement To logs.go
This commit is contained in:
Kubernetes Prow Robot 2019-06-14 20:46:49 -07:00 committed by GitHub
commit 14b6dce953
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/kubectl/cmd/logs/logs.go
View File

@ -324,6 +324,7 @@ func (o LogsOptions) parallelConsumeRequest(requests []rest.ResponseWrapper) err
wg.Add(len(requests)) wg.Add(len(requests))
for _, request := range requests { for _, request := range requests {
go func(request rest.ResponseWrapper) { go func(request rest.ResponseWrapper) {
defer wg.Done()
if err := o.ConsumeRequestFn(request, writer); err != nil { if err := o.ConsumeRequestFn(request, writer); err != nil {
if !o.IgnoreLogErrors { if !o.IgnoreLogErrors {
writer.CloseWithError(err) writer.CloseWithError(err)
@ -335,7 +336,6 @@ func (o LogsOptions) parallelConsumeRequest(requests []rest.ResponseWrapper) err
fmt.Fprintf(writer, "error: %v\n", err) fmt.Fprintf(writer, "error: %v\n", err)
} }
wg.Done()
}(request) }(request)
} }