mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2025-01-08 12:01:20 +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 09:39:16 +07:00
parent d5677b131d
commit 13965918be
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

@ -554,6 +554,7 @@ func (sc *SendersCache) flush(tx kv.RwTx, byNonce *ByNonce, sendersWithoutTransa
} }
fmt.Printf("del:%d,%d,%d\n", binary.BigEndian.Uint64(k), sc.commitID, evicted) fmt.Printf("del:%d,%d,%d\n", binary.BigEndian.Uint64(k), sc.commitID, evicted)
if sc.commitID-binary.BigEndian.Uint64(k) < 5 { if sc.commitID-binary.BigEndian.Uint64(k) < 5 {
fmt.Printf("del break:%d,%d,%d\n", binary.BigEndian.Uint64(k), sc.commitID, evicted)
break break
} }
for i := 0; i < len(v); i += 8 { for i := 0; i < len(v); i += 8 {
@ -668,6 +669,7 @@ func (sc *SendersCache) flush(tx kv.RwTx, byNonce *ByNonce, sendersWithoutTransa
} }
//TODO: flush and evict //TODO: flush and evict
fmt.Printf("senders flush finish\n")
return nil return nil
} }
@ -1078,6 +1080,7 @@ func (p *TxPool) flush(tx kv.RwTx, senders *SendersCache) error {
} }
if err := senders.flush(tx, p.txNonce2Tx, sendersWithoutTransactions); err != nil { if err := senders.flush(tx, p.txNonce2Tx, sendersWithoutTransactions); err != nil {
panic(err)
return err return err
} }