forked from ALHP/ALHP.GO
move log housekeeping to separate function
This commit is contained in:
7
main.go
7
main.go
@@ -659,10 +659,15 @@ func (b *BuildManager) syncWorker() {
|
||||
}
|
||||
wg.Wait()
|
||||
|
||||
err := logHK()
|
||||
if err != nil {
|
||||
log.Warningf("log-housekeeping failed: %v", err)
|
||||
}
|
||||
|
||||
// fetch updates between sync runs
|
||||
b.alpmMutex.Lock()
|
||||
check(alpmHandle.Release())
|
||||
err := setupChroot()
|
||||
err = setupChroot()
|
||||
for err != nil {
|
||||
log.Warningf("Unable to upgrade chroot, trying again later.")
|
||||
time.Sleep(time.Minute)
|
||||
|
7
utils.go
7
utils.go
@@ -866,7 +866,7 @@ func housekeeping(repo string, wg *sync.WaitGroup) error {
|
||||
}
|
||||
|
||||
// check all dbpackages for existence
|
||||
dbpackages, err := db.DbPackage.Query().All(context.Background())
|
||||
dbpackages, err := db.DbPackage.Query().Where(dbpackage.RepositoryEQ(dbpackage.Repository(repo))).All(context.Background())
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
@@ -889,6 +889,10 @@ func housekeeping(repo string, wg *sync.WaitGroup) error {
|
||||
}
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func logHK() error {
|
||||
// check if package for log exists and if error can be fixed by rebuild
|
||||
logFiles, err := Glob(filepath.Join(conf.Basedir.Repo, logDir, "/**/*.log"))
|
||||
if err != nil {
|
||||
@@ -927,7 +931,6 @@ func housekeeping(repo string, wg *sync.WaitGroup) error {
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
|
Reference in New Issue
Block a user