Skip to content

Commit

Permalink
core/rawdb: forgot batch commit
Browse files Browse the repository at this point in the history
  • Loading branch information
s1na committed Nov 10, 2021
1 parent 710b7d9 commit 16286fa
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion core/rawdb/freezer.go
Original file line number Diff line number Diff line change
Expand Up @@ -65,6 +65,7 @@ const (

// freezerTableSize defines the maximum size of freezer data files.
freezerTableSize = 2 * 1000 * 1000 * 1000
//freezerTableSize = 2 * 1024 * 1024
)

// freezer is an memory mapped append-only database to store immutable chain data
Expand Down Expand Up @@ -633,7 +634,7 @@ func (f *freezer) TransformTable(kind string, fn TransformerFn) error {
return err
}
if idx.filenum > filenum {
log.Info("Reached new file with updated receipts", "fn", fn, "i", i)
log.Info("Reached new file with updated receipts", "fn", filenum, "i", i)
break
}
blob, err := table.Retrieve(i)
Expand Down Expand Up @@ -665,6 +666,10 @@ func (f *freezer) TransformTable(kind string, fn TransformerFn) error {
log.Info("Duplicated rest of index in new table", "i", i)
}

if err := batch.commit(); err != nil {
return err
}

if err := newTable.Close(); err != nil {
return err
}
Expand Down

0 comments on commit 16286fa

Please sign in to comment.