From 23a0fddea35d80fdec5b244e079e15e8c51b3781 Mon Sep 17 00:00:00 2001
From: Giovanni Harting <539@idlegandalf.com>
Date: Mon, 29 Nov 2021 15:47:57 +0100
Subject: [PATCH] changed batch behaviour so all marchs get their queue filled

---
 main.go | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/main.go b/main.go
index 56410ae..2185e9c 100644
--- a/main.go
+++ b/main.go
@@ -648,14 +648,11 @@ func (b *BuildManager) syncWorker() {
 		pkgBuilds, err := Glob(filepath.Join(conf.Basedir.Upstream, "/**/PKGBUILD"))
 		check(err)
 
-		queued := 0
+		queued := map[string]int{}
 		for _, pkgbuild := range pkgBuilds {
 			if b.exit {
 				return
 			}
-			if queued >= conf.Build.Batch {
-				break
-			}
 
 			sPkgbuild := strings.Split(pkgbuild, "/")
 			repo := sPkgbuild[len(sPkgbuild)-2]
@@ -690,7 +687,11 @@ func (b *BuildManager) syncWorker() {
 					continue
 				}
 
-				queued++
+				if queued[march] >= conf.Build.Batch {
+					continue
+				}
+
+				queued[march]++
 				// send to parse
 				b.parseWG.Add(1)
 				b.parse <- &BuildPackage{