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

save

Browse Source
This commit is contained in:
alex.sharov 2023-04-19 12:32:31 +07:00
parent b8d974028d
commit f7bbbb765f
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cmd/state/exec22/txtask.go
View File

@ -326,6 +326,11 @@ func (q *ResultsQueue) Drain(ctx context.Context) error {
// q.drainNoBlock(nil) // q.drainNoBlock(nil)
// return nil // return nil
//} //}
q.Lock()
for _, t := range *(q.results) {
log.Warn("[dbg] before drain resultqueue", "txnum", t.TxNum)
}
q.Unlock()
select { select {
case <-ctx.Done(): case <-ctx.Done():

2
eth/stagedsync/exec3.go
View File

@ -229,8 +229,6 @@ func ExecV3(ctx context.Context,
var lastBlockNum uint64 var lastBlockNum uint64
for outputTxNum.Load() <= maxTxNum { for outputTxNum.Load() <= maxTxNum {
log.Warn("[dbg] before drain", "outputTxNum.Load()", outputTxNum.Load(), "maxTxNum", maxTxNum, "rws.ResultChLen()", rws.ResultChLen(), "rws.Len", rws.Len())
if err := rws.Drain(ctx); err != nil { if err := rws.Drain(ctx); err != nil {
return err return err
} }