From: Tom Clegg <tom@curii.com>
Date: Wed, 13 Apr 2022 18:13:26 +0000 (-0400)
Subject: 18947: Close trackers before existing dispatch goroutine.
X-Git-Tag: 2.5.0~210^2~2
X-Git-Url: https://git.arvados.org/arvados.git/commitdiff_plain/b95fa95f78e46523ad21e5d9f5cc1f7b50d5a04a?ds=sidebyside

18947: Close trackers before existing dispatch goroutine.

Arvados-DCO-1.1-Signed-off-by: Tom Clegg <tom@curii.com>
---

diff --git a/sdk/go/dispatch/dispatch.go b/sdk/go/dispatch/dispatch.go
index a0a61f2b6d..d34ea68d7a 100644
--- a/sdk/go/dispatch/dispatch.go
+++ b/sdk/go/dispatch/dispatch.go
@@ -98,6 +98,11 @@ func (d *Dispatcher) Run(ctx context.Context) error {
 		case <-poll.C:
 			break
 		case <-ctx.Done():
+			d.mtx.Lock()
+			defer d.mtx.Unlock()
+			for _, tracker := range d.trackers {
+				tracker.close()
+			}
 			return ctx.Err()
 		}