()
| 475 | } |
| 476 | |
| 477 | func (s *FileStore) getDirtyCacheKeys() []cacheKey { |
| 478 | s.Lock.Lock() |
| 479 | defer s.Lock.Unlock() |
| 480 | var dirtyCacheKeys []cacheKey |
| 481 | for key, entry := range s.Cache { |
| 482 | if entry.File != nil { |
| 483 | dirtyCacheKeys = append(dirtyCacheKeys, key) |
| 484 | } |
| 485 | } |
| 486 | return dirtyCacheKeys |
| 487 | } |
| 488 | |
| 489 | func (s *FileStore) setIsFlushing(flushing bool) { |
| 490 | s.Lock.Lock() |