mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-07-26 14:46:42 +00:00
core/filtermaps: fixed tempRange
This commit is contained in:
parent
1fd2b97bc1
commit
8c4ec6a270
2 changed files with 2 additions and 1 deletions
|
|
@ -659,7 +659,7 @@ func (f *FilterMaps) mapRowIndex(mapIndex, rowIndex uint32) uint64 {
|
||||||
// called from outside the indexerLoop goroutine.
|
// called from outside the indexerLoop goroutine.
|
||||||
func (f *FilterMaps) getBlockLvPointer(blockNumber uint64) (uint64, error) {
|
func (f *FilterMaps) getBlockLvPointer(blockNumber uint64) (uint64, error) {
|
||||||
if blockNumber >= f.indexedRange.blocks.AfterLast() && f.indexedRange.headIndexed {
|
if blockNumber >= f.indexedRange.blocks.AfterLast() && f.indexedRange.headIndexed {
|
||||||
return f.indexedRange.headDelimiter, nil
|
return f.indexedRange.headDelimiter + 1, nil
|
||||||
}
|
}
|
||||||
if lvPointer, ok := f.lvPointerCache.Get(blockNumber); ok {
|
if lvPointer, ok := f.lvPointerCache.Get(blockNumber); ok {
|
||||||
return lvPointer, nil
|
return lvPointer, nil
|
||||||
|
|
|
||||||
|
|
@ -536,6 +536,7 @@ func (r *mapRenderer) getTempRange() (filterMapsRange, error) {
|
||||||
} else {
|
} else {
|
||||||
tempRange.blocks.SetAfterLast(0)
|
tempRange.blocks.SetAfterLast(0)
|
||||||
}
|
}
|
||||||
|
tempRange.headIndexed = false
|
||||||
tempRange.headDelimiter = 0
|
tempRange.headDelimiter = 0
|
||||||
}
|
}
|
||||||
return tempRange, nil
|
return tempRange, nil
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue