Mercurial > gemma
diff pkg/imports/queue.go @ 5584:7ed9e32706d0 surveysperbottleneckid
Merged delault
author | Sascha Wilde <wilde@sha-bang.de> |
---|---|
date | Fri, 01 Apr 2022 16:47:53 +0200 |
parents | aaa9e658cabd |
children | 1222b777f51f |
line wrap: on
line diff
--- a/pkg/imports/queue.go Mon Feb 14 12:06:48 2022 +0100 +++ b/pkg/imports/queue.go Fri Apr 01 16:47:53 2022 +0200 @@ -731,6 +731,16 @@ return iqueue.decideImport(ctx, id, accepted, reviewer) } +func (q *importQueue) All(fn func(JobKind, JobCreator)) { + q.creatorsMu.Lock() + defer q.creatorsMu.Unlock() + for k, v := range q.creators { + fn(k, v) + } +} + +func All(fn func(JobKind, JobCreator)) { iqueue.All(fn) } + type logFeedback int64 func (lf logFeedback) log(kind, format string, args ...interface{}) {