mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2024-12-24 20:47: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:26:32 +07:00
parent 93d594cc8a
commit ff3e6e629b
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -316,14 +316,14 @@ func (q *ResultsQueueIter) PopNext() *TxTask {
}
func (q *ResultsQueue) Drain(ctx context.Context) error {
q.Lock()
l := q.results.Len()
q.Unlock()
// if queue is empty, then need block to wait new results
if l > 0 {
q.drainNoBlock(nil)
return nil
}
//q.Lock()
//l := q.results.Len()
//q.Unlock()
//if queue is empty, then need block to wait new results
//if l > 0 {
// q.drainNoBlock(nil)
// return nil
//}
select {
case <-ctx.Done():