mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2024-12-31 16:21:21 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

e3: exec retry once (#6943)

Browse Source
This commit is contained in:
Alex Sharov 2023-02-24 12:57:17 +07:00 committed by GitHub
parent 58236d62bb
commit c534453654
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 15 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
eth/stagedsync/exec3.go
View File

@ -744,23 +744,30 @@ func blockWithSenders(db kv.RoDB, tx kv.Tx, blockReader services.BlockReader, bl
func processResultQueue(rws *exec22.TxTaskQueue, outputTxNum *atomic2.Uint64, rs *state.StateV3, agg *state2.AggregatorV3, applyTx kv.Tx, triggerCount, outputBlockNum, repeatCount *atomic2.Uint64, resultsSize *atomic2.Int64, onSuccess func(), applyWorker *exec3.Worker) error {
var txTask *exec22.TxTask
var i int
for rws.Len() > 0 && (*rws)[0].TxNum == outputTxNum.Load() {
txTask = heap.Pop(rws).(*exec22.TxTask)
resultsSize.Add(-txTask.ResultsSize)
if txTask.Error != nil || !rs.ReadsValid(txTask.ReadLists) {
repeatCount.Inc()
//send to re-exex
//rs.AddWork(txTask)
//repeatCount.Inc()
//continue
// immediately retry once
applyWorker.RunTxTask(txTask)
if txTask.Error != nil {
return txTask.Error
//log.Info("second fail", "blk", txTask.BlockNum, "txn", txTask.BlockNum)
//rs.AddWork(txTask)
//continue
if i == 0 {
// re-exec right here: conflict-free
applyWorker.RunTxTask(txTask)
if txTask.Error != nil {
return txTask.Error
//log.Info("second fail", "blk", txTask.BlockNum, "txn", txTask.BlockNum)
//rs.AddWork(txTask)
//continue
}
i++
} else {
rs.AddWork(txTask)
continue
}
}