live/filter: encode number

Signed-off-by: jsvisa <delweng@gmail.com>
This commit is contained in:
jsvisa 2024-09-27 10:59:25 +00:00
parent b002b3ff1f
commit 1d460503da
2 changed files with 4 additions and 4 deletions

View file

@ -83,8 +83,8 @@ func toTraceTable(name string) string {
return name + "_tracers" return name + "_tracers"
} }
// encodeBlockNumber encodes a block number as big endian uint64 // encodeNumber encodes a number as big endian uint64
func encodeBlockNumber(number uint64) []byte { func encodeNumber(number uint64) []byte {
enc := make([]byte, 8) enc := make([]byte, 8)
binary.BigEndian.PutUint64(enc, number) binary.BigEndian.PutUint64(enc, number)
return enc return enc
@ -105,7 +105,7 @@ func toKVKey(name string, number uint64, hash common.Hash) []byte {
panic("not supported yet") panic("not supported yet")
} }
// TODO: have some prefix? // TODO: have some prefix?
key := append(encodeBlockNumber(number), hash.Bytes()...) key := append(encodeNumber(number), hash.Bytes()...)
key = append(key, typo) key = append(key, typo)
return key return key

View file

@ -108,7 +108,7 @@ func (f *filter) moveBlockToFreezer(blknum uint64) error {
} }
func (f *filter) deleteKVDBEntriesWithPrefix(blknum uint64) error { func (f *filter) deleteKVDBEntriesWithPrefix(blknum uint64) error {
prefix := encodeBlockNumber(blknum) prefix := encodeNumber(blknum)
batch := f.kvdb.NewBatch() batch := f.kvdb.NewBatch()
it := f.kvdb.NewIterator(prefix, nil) it := f.kvdb.NewIterator(prefix, nil)
defer it.Release() defer it.Release()