in lib/store/cleanup.go [132:155]
func (m *cleanupManager) scan(
op base.FileOp, tti time.Duration, ttl time.Duration) (usage int64, err error) {
names, err := op.ListNames()
if err != nil {
return 0, fmt.Errorf("list names: %s", err)
}
for _, name := range names {
info, err := op.GetFileStat(name)
if err != nil {
log.With("name", name).Errorf("Error getting file stat: %s", err)
continue
}
if ready, err := m.readyForDeletion(op, name, info, tti, ttl); err != nil {
log.With("name", name).Errorf("Error checking if file expired: %s", err)
} else if ready {
if err := op.DeleteFile(name); err != nil && err != base.ErrFilePersisted {
log.With("name", name).Errorf("Error deleting expired file: %s", err)
}
}
usage += info.Size()
}
return usage, nil
}