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

changed batch behaviour so all marchs get their queue filled

Browse Source
This commit is contained in:
Giovanni Harting
2021-11-29 15:47:57 +01:00
parent 8e4c056e7e
commit 23a0fddea3
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
main.go
View File

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