BertalanD/ALHP.GO
1
0
Fork 0
forked from ALHP/ALHP.GO
Code Pull Requests Activity

removed batch-limits

Browse Source
This commit is contained in:
Giovanni Harting
2021-12-19 16:58:43 +01:00
parent d453a705da
commit 367337bf9e
2 changed files with 0 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
main.go
View File

@@ -367,17 +367,6 @@ func (b *BuildManager) parseWorker() {
} }
b.parseWG.Done() 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 b.build[pkg.March] <- pkg
} }
} }
@@ -663,11 +652,6 @@ func (b *BuildManager) syncWorker() {
check(err) check(err)
b.alpmMutex.Unlock() 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")) pkgBuilds, err := Glob(filepath.Join(conf.Basedir.Work, upstreamDir, "/**/PKGBUILD"))
check(err) check(err)

3
utils.go
View File

@@ -73,8 +73,6 @@ type BuildManager struct {
buildProcesses []*os.Process buildProcesses []*os.Process
buildProcMutex sync.RWMutex buildProcMutex sync.RWMutex
alpmMutex sync.RWMutex alpmMutex sync.RWMutex
queued map[string]int
queuedLock sync.RWMutex
} }
type Conf struct { type Conf struct {
@@ -92,7 +90,6 @@ type Conf struct {
Worker int Worker int
Makej int Makej int
Checks bool Checks bool
Batch int
} }
Logging struct { Logging struct {
Level string Level string