|
|
|
package wal
|
|
|
|
|
|
|
|
import (
|
|
|
|
"bytes"
|
|
|
|
"io"
|
|
|
|
"os"
|
|
|
|
"testing"
|
|
|
|
)
|
|
|
|
|
|
|
|
func Test_CompactingScanner_Scan(t *testing.T) {
|
|
|
|
b, err := os.ReadFile("testdata/wal-reader/ok/wal")
|
|
|
|
if err != nil {
|
|
|
|
t.Fatal(err)
|
|
|
|
}
|
|
|
|
|
|
|
|
s, err := NewCompactingScanner(bytes.NewReader(b), true)
|
|
|
|
if err != nil {
|
|
|
|
t.Fatal(err)
|
|
|
|
}
|
|
|
|
|
|
|
|
for i, expF := range []struct {
|
|
|
|
pgno uint32
|
|
|
|
commit uint32
|
|
|
|
dataLowIdx int
|
|
|
|
dataHighIdx int
|
|
|
|
}{
|
|
|
|
{1, 0, 56, 4152},
|
|
|
|
//{2, 2, 4176, 8272}, skipped by the Compactor.
|
|
|
|
{2, 2, 8296, 12392},
|
|
|
|
} {
|
|
|
|
f, err := s.Next()
|
|
|
|
if err != nil {
|
|
|
|
t.Fatal(err)
|
|
|
|
}
|
|
|
|
if f.Pgno != expF.pgno {
|
|
|
|
t.Fatalf("expected pgno %d, got %d", expF.pgno, f.Pgno)
|
|
|
|
}
|
|
|
|
if f.Commit != expF.commit {
|
|
|
|
t.Fatalf("expected commit %d, got %d", expF.commit, f.Commit)
|
|
|
|
}
|
|
|
|
if len(f.Data) != 4096 {
|
|
|
|
t.Fatalf("expected data length 4096, got %d", len(f.Data))
|
|
|
|
}
|
|
|
|
if !bytes.Equal(f.Data, b[expF.dataLowIdx:expF.dataHighIdx]) {
|
|
|
|
t.Fatalf("page data mismatch on test %d", i)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
_, err = s.Next()
|
|
|
|
if err != io.EOF {
|
|
|
|
t.Fatalf("expected EOF, got %v", err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func Test_CompactingScanner_Scan_Commit0(t *testing.T) {
|
|
|
|
b, err := os.ReadFile("testdata/compacting-scanner/commit-0/wal")
|
|
|
|
if err != nil {
|
|
|
|
t.Fatal(err)
|
|
|
|
}
|
|
|
|
|
|
|
|
s, err := NewCompactingScanner(bytes.NewReader(b), false)
|
|
|
|
if err != nil {
|
|
|
|
t.Fatal(err)
|
|
|
|
}
|
|
|
|
|
|
|
|
for _, expF := range []struct {
|
|
|
|
pgno uint32
|
|
|
|
commit uint32
|
|
|
|
}{
|
|
|
|
// {1,0}, skipped by the Compactor.
|
|
|
|
// {2,2}, skipped by the Compactor.
|
|
|
|
{1, 0},
|
|
|
|
{2, 0},
|
|
|
|
{3, 0},
|
|
|
|
{4, 0},
|
|
|
|
{5, 0},
|
|
|
|
// {6,6}, skipped by the Compactor.
|
|
|
|
{6, 6},
|
|
|
|
} {
|
|
|
|
f, err := s.Next()
|
|
|
|
if err != nil {
|
|
|
|
t.Fatal(err)
|
|
|
|
}
|
|
|
|
if f.Pgno != expF.pgno {
|
|
|
|
t.Fatalf("expected pgno %d, got %d", expF.pgno, f.Pgno)
|
|
|
|
}
|
|
|
|
if f.Commit != expF.commit {
|
|
|
|
t.Fatalf("expected commit %d, got %d", expF.commit, f.Commit)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
_, err = s.Next()
|
|
|
|
if err != io.EOF {
|
|
|
|
t.Fatalf("expected EOF, got %v", err)
|
|
|
|
}
|
|
|
|
}
|