Skip to content

Commit 1458933

Browse files
committed
fix(freezer): tailId filenum offset were misplaced
1 parent 9371b2f commit 1458933

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

core/rawdb/freezer_table.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -232,8 +232,8 @@ func (t *freezerTable) repair() error {
232232
t.index.ReadAt(buffer, 0)
233233
firstIndex.unmarshalBinary(buffer)
234234

235-
t.tailId = firstIndex.offset
236-
t.itemOffset = firstIndex.filenum
235+
t.tailId = firstIndex.filenum
236+
t.itemOffset = firstIndex.offset
237237

238238
t.index.ReadAt(buffer, offsetsSize-indexEntrySize)
239239
lastIndex.unmarshalBinary(buffer)

core/rawdb/freezer_table_test.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -552,8 +552,8 @@ func TestOffset(t *testing.T) {
552552
tailId := uint32(2) // First file is 2
553553
itemOffset := uint32(4) // We have removed four items
554554
zeroIndex := indexEntry{
555-
offset: tailId,
556-
filenum: itemOffset,
555+
filenum: tailId,
556+
offset: itemOffset,
557557
}
558558
buf := zeroIndex.marshallBinary()
559559
// Overwrite index zero
@@ -579,7 +579,7 @@ func TestOffset(t *testing.T) {
579579
// It should be fine to fetch 4,5,6
580580
if got, err := f.Retrieve(4); err != nil {
581581
t.Fatal(err)
582-
} else if exp := getChunk(20, 0xbb); !bytes.Equal(got, exp) {
582+
} else if exp := getChunk(16, 0xbb); !bytes.Equal(got, exp) {
583583
t.Fatalf("expected %x got %x", exp, got)
584584
}
585585
if got, err := f.Retrieve(5); err != nil {

0 commit comments

Comments
 (0)