CleanChunksByNeed will cleanup chunks after the FS passes a specific chunk
(offset int64)
| 75 | |
| 76 | // CleanChunksByNeed will cleanup chunks after the FS passes a specific chunk |
| 77 | func (m *Memory) CleanChunksByNeed(offset int64) { |
| 78 | for key := range m.db.Items() { |
| 79 | sepIdx := strings.LastIndex(key, "-") |
| 80 | keyOffset, err := strconv.ParseInt(key[sepIdx+1:], 10, 64) |
| 81 | if err != nil { |
| 82 | fs.Errorf("cache", "couldn't parse offset entry %v", key) |
| 83 | continue |
| 84 | } |
| 85 | |
| 86 | if keyOffset < offset { |
| 87 | m.db.Delete(key) |
| 88 | } |
| 89 | } |
| 90 | } |
| 91 | |
| 92 | // CleanChunksBySize will cleanup chunks after the total size passes a certain point |
| 93 | func (m *Memory) CleanChunksBySize(maxSize int64) { |
no test coverage detected