Fix goroutine leakage (#15180)
* Fix goroutine leakage * cl: add cl entry Co-authored-by: Seth Hoenig <shoenig@duck.com>
This commit is contained in:
parent
74f1fe437e
commit
75f80e2fdd
|
@ -0,0 +1,3 @@
|
|||
```release-note:bug
|
||||
drivers: Fixed a bug where one goroutine was leaked per task
|
||||
```
|
|
@ -187,7 +187,8 @@ func (d *driverPluginClient) handleWaitTask(ctx context.Context, id string, ch c
|
|||
}
|
||||
|
||||
// Join the passed context and the shutdown context
|
||||
joinedCtx, _ := joincontext.Join(ctx, d.doneCtx)
|
||||
joinedCtx, joinedCtxCancel := joincontext.Join(ctx, d.doneCtx)
|
||||
defer joinedCtxCancel()
|
||||
|
||||
resp, err := d.client.WaitTask(joinedCtx, req)
|
||||
if err != nil {
|
||||
|
|
Loading…
Reference in New Issue