From 47552c88d8f748130a3f4c743b542ca6c0e0b7f8 Mon Sep 17 00:00:00 2001 From: Giovanni Harting <539@idlegandalf.com> Date: Sat, 21 May 2022 20:30:34 +0200 Subject: [PATCH] do not purge packages that are just skipped --- main.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/main.go b/main.go index 562a75f..4cc6529 100644 --- a/main.go +++ b/main.go @@ -218,6 +218,7 @@ func (b *BuildManager) repoWorker(repo string) { for { select { case pkgL := <-b.repoAdd[repo]: + b.repoWG.Add(1) toAdd := make([]string, 0) for _, pkg := range pkgL { toAdd = append(toAdd, pkg.PkgFiles...) @@ -263,6 +264,7 @@ func (b *BuildManager) repoWorker(repo string) { if err != nil { log.Warningf("Error updating lastupdate: %v", err) } + b.repoWG.Done() case pkgL := <-b.repoPurge[repo]: 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 { @@ -419,7 +421,6 @@ func (b *BuildManager) syncWorker(ctx context.Context) error { } if !eligible { log.Debugf("skipped package %s (%v)", pkg.Pkgbase, err) - b.repoPurge[pkg.FullRepo] <- []*ProtoPackage{pkg} continue }