From 367337bf9e603986e327c43d3bd785b9f9de7803 Mon Sep 17 00:00:00 2001 From: Giovanni Harting <539@idlegandalf.com> Date: Sun, 19 Dec 2021 16:58:43 +0100 Subject: [PATCH] removed batch-limits --- main.go | 16 ---------------- utils.go | 3 --- 2 files changed, 19 deletions(-) diff --git a/main.go b/main.go index bf4cd07..0f6c7ba 100644 --- a/main.go +++ b/main.go @@ -367,17 +367,6 @@ func (b *BuildManager) parseWorker() { } b.parseWG.Done() - - b.queuedLock.RLock() - if b.queued[pkg.March] >= conf.Build.Batch { - b.queuedLock.RUnlock() - continue - } - b.queuedLock.RUnlock() - b.queuedLock.Lock() - b.queued[pkg.March]++ - b.queuedLock.Unlock() - b.build[pkg.March] <- pkg } } @@ -663,11 +652,6 @@ func (b *BuildManager) syncWorker() { check(err) b.alpmMutex.Unlock() - // clear batch limits - b.queuedLock.Lock() - b.queued = map[string]int{} - b.queuedLock.Unlock() - pkgBuilds, err := Glob(filepath.Join(conf.Basedir.Work, upstreamDir, "/**/PKGBUILD")) check(err) diff --git a/utils.go b/utils.go index dd73d9b..04e74d4 100644 --- a/utils.go +++ b/utils.go @@ -73,8 +73,6 @@ type BuildManager struct { buildProcesses []*os.Process buildProcMutex sync.RWMutex alpmMutex sync.RWMutex - queued map[string]int - queuedLock sync.RWMutex } type Conf struct { @@ -92,7 +90,6 @@ type Conf struct { Worker int Makej int Checks bool - Batch int } Logging struct { Level string