SystemSh0cker/gocsaf
1
0
Fork 0
mirror of https://github.com/gocsaf/csaf.git synced 2025-12-22 11:55:40 +01:00
Code Issues Releases Activity Actions

Ensure that interims.csv is deleted as soon as the last entry is removed from it.

Browse source
This commit is contained in:
Sascha L. Teichmann 2022-08-02 22:12:56 +02:00
parent 00a0fb68d2
commit bdb24e72ab
1 changed files with 8 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

18
cmd/csaf_aggregator/interim.go
View file

@ -221,16 +221,14 @@ func (w *worker) interimWork(wg *sync.WaitGroup, jobs <-chan *interimJob) {
// a greater interims interval later. // a greater interims interval later.
notFinalized = append(notFinalized, olds...) notFinalized = append(notFinalized, olds...)
if len(notFinalized) > 0 { // We want to write in the transaction folder.
// We want to write in the transaction folder. dst, err := tx.Dst()
dst, err := tx.Dst() if err != nil {
if err != nil { return err
return err }
} ninterCSV := filepath.Join(dst, label, interimsCSV)
interCSV := filepath.Join(dst, label, interimsCSV) if err := writeInterims(ninterCSV, notFinalized); err != nil {
if err := writeInterims(interCSV, notFinalized); err != nil { return err
return err
}
} }
} }
return tx.commit() return tx.commit()