mirrors/seaweedfs
1
0
Fork 0
mirror of https://github.com/chrislusf/seaweedfs synced 2024-07-03 23:56:41 +02:00
Code Issues Projects Releases Wiki Activity

fix volume vacuum test unit

Browse source
This commit is contained in:
zhangsong 2020-05-07 19:58:06 +08:00
parent 73087f59b1
commit b161baa3f0
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
weed/storage/volume_vacuum_test.go
View file

@ -129,7 +129,7 @@ func TestCompaction(t *testing.T) {
} }
func doSomeWritesDeletes(i int, v *Volume, t *testing.T, infos []*needleInfo) { func doSomeWritesDeletes(i int, v *Volume, t *testing.T, infos []*needleInfo) {
n := newRandomNeedle(uint64(i)) n := newRandomNeedle(uint64(i))
_, size, _, err := v.writeNeedle(n, false) _, size, _, err := v.writeNeedle2(n, false)
if err != nil { if err != nil {
t.Fatalf("write file %d: %v", i, err) t.Fatalf("write file %d: %v", i, err)
} }
@ -141,7 +141,7 @@ func doSomeWritesDeletes(i int, v *Volume, t *testing.T, infos []*needleInfo) {
if rand.Float64() < 0.03 { if rand.Float64() < 0.03 {
toBeDeleted := rand.Intn(i) + 1 toBeDeleted := rand.Intn(i) + 1
oldNeedle := newEmptyNeedle(uint64(toBeDeleted)) oldNeedle := newEmptyNeedle(uint64(toBeDeleted))
v.deleteNeedle(oldNeedle) v.deleteNeedle2(oldNeedle)
// println("deleted file", toBeDeleted) // println("deleted file", toBeDeleted)
infos[toBeDeleted-1] = &needleInfo{ infos[toBeDeleted-1] = &needleInfo{
size: 0, size: 0,