RubenKelevra/ALHP.GO
1
0
Fork 0
forked from ALHP/ALHP.GO
Code Issues Pull Requests Projects Releases Wiki Activity

do not purge packages that are just skipped

Browse Source
This commit is contained in:
Giovanni Harting
2022-05-21 20:30:34 +02:00
parent bb16bdcb61
commit 47552c88d8
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
main.go
View File

@@ -218,6 +218,7 @@ func (b *BuildManager) repoWorker(repo string) {
for { for {
select { select {
case pkgL := <-b.repoAdd[repo]: case pkgL := <-b.repoAdd[repo]:
b.repoWG.Add(1)
toAdd := make([]string, 0) toAdd := make([]string, 0)
for _, pkg := range pkgL { for _, pkg := range pkgL {
toAdd = append(toAdd, pkg.PkgFiles...) toAdd = append(toAdd, pkg.PkgFiles...)
@@ -263,6 +264,7 @@ func (b *BuildManager) repoWorker(repo string) {
if err != nil { if err != nil {
log.Warningf("Error updating lastupdate: %v", err) log.Warningf("Error updating lastupdate: %v", err)
} }
b.repoWG.Done()
case pkgL := <-b.repoPurge[repo]: case pkgL := <-b.repoPurge[repo]:
for _, pkg := range pkgL { for _, pkg := range pkgL {
if _, err := os.Stat(filepath.Join(conf.Basedir.Repo, pkg.FullRepo, "os", conf.Arch, pkg.FullRepo) + ".db.tar.xz"); err != nil { if _, err := os.Stat(filepath.Join(conf.Basedir.Repo, pkg.FullRepo, "os", conf.Arch, pkg.FullRepo) + ".db.tar.xz"); err != nil {
@@ -419,7 +421,6 @@ func (b *BuildManager) syncWorker(ctx context.Context) error {
} }
if !eligible { if !eligible {
log.Debugf("skipped package %s (%v)", pkg.Pkgbase, err) log.Debugf("skipped package %s (%v)", pkg.Pkgbase, err)
b.repoPurge[pkg.FullRepo] <- []*ProtoPackage{pkg}
continue continue
} }