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-28 10:09:41 +07:00
parent 7b9d0d926d
commit 87ad608c30
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
txpool/pool.go
View File

@ -1663,7 +1663,7 @@ func (p *WorstQueue) Pop() interface{} {
// - all local pooled byHash to random peers periodically
// promote/demote transactions
// reorgs
func BroadcastLoop(ctx context.Context, db kv.RwDB, coreDB kv.RoDB, p *TxPool, senders *SendersCache, newTxs chan Hashes, send *Send, cfg Config) {
func BroadcastLoop(ctx context.Context, db kv.RwDB, coreDB kv.RoDB, p *TxPool, senders *SendersCache, newTxs chan Hashes, send *Send) {
//db.Update(ctx, func(tx kv.RwTx) error { return tx.ClearBucket(kv.PooledSender) })
if err := db.Update(ctx, func(tx kv.RwTx) error {
return coreDB.View(ctx, func(coreTx kv.Tx) error {
@ -1683,12 +1683,12 @@ func BroadcastLoop(ctx context.Context, db kv.RwDB, coreDB kv.RoDB, p *TxPool, s
}()
}
logEvery := time.NewTicker(cfg.logEvery)
logEvery := time.NewTicker(p.cfg.logEvery)
defer logEvery.Stop()
commitEvery := time.NewTicker(cfg.commitEvery)
commitEvery := time.NewTicker(p.cfg.commitEvery)
defer commitEvery.Stop()
syncToNewPeersEvery := time.NewTicker(cfg.syncToNewPeersEvery)
syncToNewPeersEvery := time.NewTicker(p.cfg.syncToNewPeersEvery)
defer syncToNewPeersEvery.Stop()
localTxHashes := make([]byte, 0, 128)