2021-10-09 19:54:14 +08:00
|
|
|
package storage
|
|
|
|
|
|
|
|
import (
|
|
|
|
"fmt"
|
|
|
|
"testing"
|
|
|
|
"time"
|
2021-10-14 12:27:58 +08:00
|
|
|
|
2022-07-29 15:17:28 +08:00
|
|
|
"github.com/seaweedfs/seaweedfs/weed/storage/needle"
|
|
|
|
"github.com/seaweedfs/seaweedfs/weed/storage/super_block"
|
|
|
|
"github.com/seaweedfs/seaweedfs/weed/storage/types"
|
2021-10-09 19:54:14 +08:00
|
|
|
)
|
|
|
|
|
|
|
|
func TestSearchVolumesWithDeletedNeedles(t *testing.T) {
|
2022-02-14 10:38:13 +08:00
|
|
|
dir := t.TempDir()
|
2021-10-09 19:54:14 +08:00
|
|
|
|
2022-11-14 16:19:27 +08:00
|
|
|
v, err := NewVolume(dir, dir, "", 1, NeedleMapInMemory, &super_block.ReplicaPlacement{}, &needle.TTL{}, 0, 0, 0)
|
2021-10-09 19:54:14 +08:00
|
|
|
if err != nil {
|
|
|
|
t.Fatalf("volume creation: %v", err)
|
|
|
|
}
|
|
|
|
|
2021-10-12 13:00:41 +08:00
|
|
|
count := 20
|
2021-10-09 19:54:14 +08:00
|
|
|
|
2021-10-12 14:23:46 +08:00
|
|
|
for i := 1; i < count; i++ {
|
2021-10-09 19:54:14 +08:00
|
|
|
n := newRandomNeedle(uint64(i))
|
|
|
|
_, _, _, err := v.writeNeedle2(n, true, false)
|
|
|
|
if err != nil {
|
|
|
|
t.Fatalf("write needle %d: %v", i, err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2021-10-12 14:23:46 +08:00
|
|
|
for i := 1; i < 15; i++ {
|
2021-10-09 19:54:14 +08:00
|
|
|
n := newEmptyNeedle(uint64(i))
|
2021-10-12 13:00:41 +08:00
|
|
|
err := v.nm.Put(n.Id, types.Offset{}, types.TombstoneFileSize)
|
2021-10-09 19:54:14 +08:00
|
|
|
if err != nil {
|
|
|
|
t.Fatalf("delete needle %d: %v", i, err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
ts1 := time.Now().UnixNano()
|
|
|
|
|
2021-10-12 14:23:46 +08:00
|
|
|
for i := 15; i < count; i++ {
|
2021-10-09 19:54:14 +08:00
|
|
|
n := newEmptyNeedle(uint64(i))
|
|
|
|
_, err := v.doDeleteRequest(n)
|
|
|
|
if err != nil {
|
|
|
|
t.Fatalf("delete needle %d: %v", i, err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
offset, isLast, err := v.BinarySearchByAppendAtNs(uint64(ts1))
|
|
|
|
if err != nil {
|
|
|
|
t.Fatalf("lookup by ts: %v", err)
|
|
|
|
}
|
|
|
|
fmt.Printf("offset: %v, isLast: %v\n", offset.ToActualOffset(), isLast)
|
|
|
|
|
2021-10-12 14:23:46 +08:00
|
|
|
}
|