mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-01-19 02:48:24 +00:00
49 lines
1 KiB
Go
49 lines
1 KiB
Go
package filer
|
|
|
|
import (
|
|
"github.com/seaweedfs/seaweedfs/weed/pb/filer_pb"
|
|
"testing"
|
|
)
|
|
|
|
func Test_removeGarbageChunks(t *testing.T) {
|
|
section := NewFileChunkSection(0)
|
|
section.addChunk(&filer_pb.FileChunk{
|
|
FileId: "0",
|
|
Offset: 0,
|
|
Size: 1,
|
|
ModifiedTsNs: 0,
|
|
})
|
|
section.addChunk(&filer_pb.FileChunk{
|
|
FileId: "1",
|
|
Offset: 1,
|
|
Size: 1,
|
|
ModifiedTsNs: 1,
|
|
})
|
|
section.addChunk(&filer_pb.FileChunk{
|
|
FileId: "2",
|
|
Offset: 2,
|
|
Size: 1,
|
|
ModifiedTsNs: 2,
|
|
})
|
|
section.addChunk(&filer_pb.FileChunk{
|
|
FileId: "3",
|
|
Offset: 3,
|
|
Size: 1,
|
|
ModifiedTsNs: 3,
|
|
})
|
|
section.addChunk(&filer_pb.FileChunk{
|
|
FileId: "4",
|
|
Offset: 4,
|
|
Size: 1,
|
|
ModifiedTsNs: 4,
|
|
})
|
|
garbageFileIds := make(map[string]struct{})
|
|
garbageFileIds["0"] = struct{}{}
|
|
garbageFileIds["2"] = struct{}{}
|
|
garbageFileIds["4"] = struct{}{}
|
|
removeGarbageChunks(section, garbageFileIds)
|
|
if len(section.chunks) != 2 {
|
|
t.Errorf("remove chunk 2 failed")
|
|
}
|
|
}
|