mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2025-01-07 19:41:19 +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-27 16:24:09 +07:00
parent e7572f6082
commit 5f20d8ba28
1 changed files with 18 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
txpool/pool.go
View File

@ -1131,6 +1131,24 @@ func (p *TxPool) fromDB(ctx context.Context, tx kv.RwTx, coreTx kv.Tx) error {
return err
}
if ASSERT {
tx.ForEach(kv.PooledTransaction, nil, func(k, v []byte) error {
vv, err := tx.GetOne(kv.PooledSenderIDToAdress, v[:8])
if err != nil {
return err
}
if len(vv) == 0 {
tx.ForEach(kv.PooledSenderIDToAdress, nil, func(k, v []byte) error {
fmt.Printf("found:%x,%x\n", k, v)
return nil
})
fmt.Printf("aa: %x,%x,%x\n", k, v, vv)
panic("no-no")
}
return nil
})
}
txs := TxSlots{}
parseCtx := NewTxParseContext()
parseCtx.WithSender(false)
@ -1189,10 +1207,6 @@ func (p *TxPool) fromDB(ctx context.Context, tx kv.RwTx, coreTx kv.Tx) error {
return err
}
if len(cacheMisses) > 0 {
p.senders.printDebug("miss")
for i, j := range cacheMisses {
fmt.Printf("miss: %d,%x\n", i, j)
}
if err := p.senders.loadFromCore(coreTx, cacheMisses); err != nil {
return err
}