mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2025-01-06 02:52: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 17:06:34 +07:00
parent c0ad0c6745
commit 7f1a72b997
1 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
txpool/pool.go
View File

@ -1078,13 +1078,18 @@ func (p *TxPool) flush(tx kv.RwTx, senders *SendersCache) error {
binary.BigEndian.PutUint64(v, metaTx.Tx.senderID)
binary.BigEndian.PutUint64(v[8:], 0) // block num - timestamp
copy(v[8+8:], metaTx.Tx.rlp)
currentV, err := tx.GetOne(kv.PooledTransaction, []byte(txHash))
if err != nil {
return err
}
if currentV != nil && bytes.Equal(currentV, v) {
continue
if ASSERT {
if _, ok := p.senders.senderInfo[metaTx.Tx.senderID]; !ok {
info, err := p.senders.info(metaTx.Tx.senderID, tx)
if err != nil {
panic(err)
}
if info == nil {
panic("lost")
}
}
}
if err := tx.Put(kv.PooledTransaction, []byte(txHash), v); err != nil {
return err
}
@ -1715,7 +1720,7 @@ func BroadcastLoop(ctx context.Context, db kv.RwDB, coreDB kv.RoDB, p *TxPool, s
logEvery := time.NewTicker(timings.logEvery)
defer logEvery.Stop()
commitEvery := time.NewTicker(3 * time.Second)
commitEvery := time.NewTicker(1 * time.Second)
defer commitEvery.Stop()
syncToNewPeersEvery := time.NewTicker(timings.syncToNewPeersEvery)