mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2025-01-20 17:31:11 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

add state check assert routine

Browse Source
This commit is contained in:
alex.sharov 2021-08-28 11:03:26 +07:00
parent 73ad34716f
commit 84be2290a6
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
txpool/pool.go
View File

@ -548,6 +548,7 @@ func (sc *SendersCache) flush(tx kv.RwTx, byNonce *ByNonce, sendersWithoutTransa
return evicted, err
}
defer c.Close()
justDeleted := []uint64{}
for k, v, err := c.First(); k != nil; k, v, err = c.Next() {
if err != nil {
return evicted, err
@ -580,6 +581,7 @@ func (sc *SendersCache) flush(tx kv.RwTx, byNonce *ByNonce, sendersWithoutTransa
return evicted, err
}
evicted++
justDeleted = append(justDeleted, senderID)
}
if err := c.DeleteCurrent(); err != nil {
return evicted, err
@ -600,6 +602,7 @@ func (sc *SendersCache) flush(tx kv.RwTx, byNonce *ByNonce, sendersWithoutTransa
fmt.Printf("now: %d\n", sc.senderID)
fmt.Printf("not foundd: %d,%x,%x,%x\n", binary.BigEndian.Uint64(v[:8]), k, v, vv)
fmt.Printf("aa: %x,%x,%x\n", k, v, vv)
fmt.Printf("justDeleted: %d\n", justDeleted)
panic("no-no")
}
return nil