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 15:39:10 +07:00
parent 71366cb4ab
commit 3a2d407832
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
txpool/pool.go
View File

@ -943,7 +943,9 @@ func (p *TxPool) AddNewGoodPeer(peerID PeerID) { p.recentlyConnectedPeers.AddPee
func (p *TxPool) Started() bool { return p.protocolBaseFee.Load() > 0 }
func (p *TxPool) OnNewTxs(ctx context.Context, coreDB kv.RoDB, newTxs TxSlots, senders *SendersCache) error {
//t := time.Now()
p.lock.Lock()
defer p.lock.Unlock()
tx, err := p.db.BeginRo(context.Background())
if err != nil {
return err
@ -966,8 +968,6 @@ func (p *TxPool) OnNewTxs(ctx context.Context, coreDB kv.RoDB, newTxs TxSlots, s
if protocolBaseFee == 0 || pendingBaseFee == 0 {
return fmt.Errorf("non-zero base fee: %d,%d", protocolBaseFee, pendingBaseFee)
}
p.lock.Lock()
defer p.lock.Unlock()
if err := onNewTxs(tx, senders, newTxs, protocolBaseFee, pendingBaseFee, p.pending, p.baseFee, p.queued, p.txNonce2Tx, p.byHash, p.discardLocked); err != nil {
return err
}