From e007f9964ec7ac3eb49ad2842c9239b1c1a83304 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ond=C5=99ej=20Budai?= Date: Thu, 12 Nov 2020 11:45:24 +0100 Subject: [PATCH] fsjobqueue: extract channelSize constant --- internal/jobqueue/fsjobqueue/fsjobqueue.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/internal/jobqueue/fsjobqueue/fsjobqueue.go b/internal/jobqueue/fsjobqueue/fsjobqueue.go index c041e7b68..e2903a5d3 100644 --- a/internal/jobqueue/fsjobqueue/fsjobqueue.go +++ b/internal/jobqueue/fsjobqueue/fsjobqueue.go @@ -59,6 +59,10 @@ type job struct { Canceled bool `json:"canceled,omitempty"` } +// The size of channels used in fsJobQueue for queueing jobs. +// Note that each job type has its own queue. +const channelSize = 100 + // Create a new fsJobQueue object for `dir`. This object must have exclusive // access to `dir`. If `dir` contains jobs created from previous runs, they are // loaded and rescheduled to run if necessary. @@ -70,7 +74,7 @@ func New(dir string, acceptedJobTypes []string) (*fsJobQueue, error) { } for _, jt := range acceptedJobTypes { - q.pending[jt] = make(chan uuid.UUID, 100) + q.pending[jt] = make(chan uuid.UUID, channelSize) } // Look for jobs that are still pending and build the dependant map.