Function buildLTXFixtureWithPages

vfs_test.go:987–1046

(tb testing.TB, txid ltx.TXID, pageSize uint32, pgnos []uint32, fill byte)

}

func buildLTXFixtureWithPages(tb testing.TB, txid ltx.TXID, pageSize uint32, pgnos []uint32, fill byte) *ltxFixture {
	tb.Helper()
	if len(pgnos) == 0 {
		tb.Fatalf("pgnos required")
	}
	if txid == 1 {
		if len(pgnos) == 0 || pgnos[0] != 1 {
			tb.Fatalf("snapshot fixture must start at page 1")
		}
	}

	var buf bytes.Buffer
	enc, err := ltx.NewEncoder(&buf)
	if err != nil {
		tb.Fatalf("new encoder: %v", err)
	}
	maxPg := uint32(0)
	for _, pg := range pgnos {
		if pg > maxPg {
			maxPg = pg
		}
	}
	if maxPg == 0 {
		maxPg = 1
	}
	hdr := ltx.Header{
		Version:   ltx.Version,
		PageSize:  pageSize,
		Commit:    maxPg,
		MinTXID:   txid,
		MaxTXID:   txid,
		Timestamp: time.Now().UnixMilli(),
		Flags:     ltx.HeaderFlagNoChecksum,
	}
	if err := enc.EncodeHeader(hdr); err != nil {
		tb.Fatalf("encode header: %v", err)
	}
	for _, pg := range pgnos {
		if pg == 0 {
			pg = 1
		}
		page := bytes.Repeat([]byte{fill}, int(pageSize))
		if err := enc.EncodePage(ltx.PageHeader{Pgno: pg}, page); err != nil {
			tb.Fatalf("encode page %d: %v", pg, err)
		}
	}
	if err := enc.Close(); err != nil {
		tb.Fatalf("close encoder: %v", err)
	}

	info := &ltx.FileInfo{
		Level:     0,
		MinTXID:   txid,
		MaxTXID:   txid,
		Size:      int64(buf.Len()),
		CreatedAt: time.Now().UTC(),
	}