kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-01 16:05:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fix goroutine leakage (#15180)

Browse Source 
* Fix goroutine leakage

* cl: add cl entry

Co-authored-by: Seth Hoenig <shoenig@duck.com>
This commit is contained in:
stswidwinski
2022-11-17 10:47:11 -05:00
committed by GitHub
parent 732adae999
commit d16a2c9467
2 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
.changelog/15180.txt Normal file
View File

@@ -0,0 +1,3 @@
```release-note:bug
drivers: Fixed a bug where one goroutine was leaked per task
```

3
plugins/drivers/client.go
View File

@@ -187,7 +187,8 @@ func (d *driverPluginClient) handleWaitTask(ctx context.Context, id string, ch c
} }
// Join the passed context and the shutdown context // 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) resp, err := d.client.WaitTask(joinedCtx, req)
if err != nil { if err != nil {