mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2025-01-09 04:21: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-27 16:34:33 +07:00
parent e6a39ce9fc
commit 3ab6b5074c
1 changed files with 12 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
txpool/pool.go
View File

@ -1120,19 +1120,6 @@ func (p *TxPool) discardLocked(mt *metaTx) {
func (p *TxPool) fromDB(ctx context.Context, tx kv.RwTx, coreTx kv.Tx) error { func (p *TxPool) fromDB(ctx context.Context, tx kv.RwTx, coreTx kv.Tx) error {
p.lock.Lock() p.lock.Lock()
defer p.lock.Unlock() defer p.lock.Unlock()
if err := p.senders.fromDB(ctx, tx, coreTx); err != nil {
return err
}
if err := tx.ForEach(kv.RecentLocalTransaction, nil, func(k, v []byte) error {
hashID := [32]byte{}
copy(hashID[:], v)
p.localsHistory.Add(hashID, struct{}{})
return nil
}); err != nil {
return err
}
if ASSERT { if ASSERT {
tx.ForEach(kv.PooledTransaction, nil, func(k, v []byte) error { tx.ForEach(kv.PooledTransaction, nil, func(k, v []byte) error {
vv, err := tx.GetOne(kv.PooledSenderIDToAdress, v[:8]) vv, err := tx.GetOne(kv.PooledSenderIDToAdress, v[:8])
@ -1152,6 +1139,18 @@ func (p *TxPool) fromDB(ctx context.Context, tx kv.RwTx, coreTx kv.Tx) error {
return nil return nil
}) })
} }
if err := p.senders.fromDB(ctx, tx, coreTx); err != nil {
return err
}
if err := tx.ForEach(kv.RecentLocalTransaction, nil, func(k, v []byte) error {
hashID := [32]byte{}
copy(hashID[:], v)
p.localsHistory.Add(hashID, struct{}{})
return nil
}); err != nil {
return err
}
txs := TxSlots{} txs := TxSlots{}
parseCtx := NewTxParseContext() parseCtx := NewTxParseContext()