persistence

This commit is contained in:
alex.sharov 2021-08-25 14:56:08 +07:00
parent 9e6631df29
commit 53cc635d5c

View File

@ -1437,7 +1437,7 @@ func (p *WorstQueue) Pop() interface{} {
// promote/demote transactions
// reorgs
func BroadcastLoop(ctx context.Context, db kv.RwDB, coreDB kv.RoDB, p *TxPool, senders *SendersCache, newTxs chan Hashes, send *Send, timings Timings) {
db.Update(ctx, func(tx kv.RwTx) error { return tx.ClearBucket(kv.PooledSender) })
//db.Update(ctx, func(tx kv.RwTx) error { return tx.ClearBucket(kv.PooledSender) })
if err := db.View(ctx, func(tx kv.Tx) error {
return coreDB.View(ctx, func(coreTx kv.Tx) error {
return p.fromDB(ctx, tx, coreTx, senders)