parent
7119ef8f29
commit
84cbee227a
|
@ -448,6 +448,10 @@ func (f *FileStore) Close() error {
|
||||||
f.mu.Lock()
|
f.mu.Lock()
|
||||||
defer f.mu.Unlock()
|
defer f.mu.Unlock()
|
||||||
|
|
||||||
|
for _, file := range f.files {
|
||||||
|
file.Close()
|
||||||
|
}
|
||||||
|
|
||||||
f.lastFileStats = nil
|
f.lastFileStats = nil
|
||||||
f.files = nil
|
f.files = nil
|
||||||
atomic.StoreInt64(&f.stats.FileCount, 0)
|
atomic.StoreInt64(&f.stats.FileCount, 0)
|
||||||
|
|
Loading…
Reference in New Issue