mirror/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-01-19 15:03:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

ensure section.chunks is always garbage free

Browse Source
This commit is contained in:
chrislu 2023-01-10 00:48:01 -08:00
parent 75bdd4a0d1
commit e650c8397d
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
weed/filer/filechunk_section.go
View File

@ -30,7 +30,9 @@ func (section *FileChunkSection) addChunk(chunk *filer_pb.FileChunk) error {
section.chunks = append(section.chunks, chunk) section.chunks = append(section.chunks, chunk)
if section.visibleIntervals != nil { if section.visibleIntervals == nil {
section.visibleIntervals = readResolvedChunks(section.chunks, int64(section.sectionIndex)*SectionSize, (int64(section.sectionIndex)+1)*SectionSize)
} else {
MergeIntoVisibles(section.visibleIntervals, start, stop, chunk) MergeIntoVisibles(section.visibleIntervals, start, stop, chunk)
garbageFileIds := FindGarbageChunks(section.visibleIntervals, start, stop) garbageFileIds := FindGarbageChunks(section.visibleIntervals, start, stop)
removeGarbageChunks(section, garbageFileIds) removeGarbageChunks(section, garbageFileIds)