X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/ff8c3cfde1e73c1c0adccb670040e98d82120e99..772fc9527716fea221ae88ea3200db94f754afde:/lib/dispatchcloud/test/queue.go diff --git a/lib/dispatchcloud/test/queue.go b/lib/dispatchcloud/test/queue.go index fda04d52b3..ceca8c63f1 100644 --- a/lib/dispatchcloud/test/queue.go +++ b/lib/dispatchcloud/test/queue.go @@ -95,6 +95,7 @@ func (q *Queue) Unsubscribe(ch <-chan struct{}) { delete(q.subscribers, ch) } +// caller must have lock. func (q *Queue) notify() { for _, ch := range q.subscribers { select {