forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-26 06:36:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix ctx done check

Browse source
This commit is contained in:
Sina Mahmoodi 2025-05-01 16:36:17 +02:00
parent 91923a6bc4
commit 4792f0a3ba
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
core/txindexer.go
View file

@ -308,12 +308,15 @@ func (indexer *txIndexer) txIndexProgress(ctx context.Context) (TxIndexProgress,
ch := make(chan TxIndexProgress, 1)
select {
case indexer.progress <- ch:
return <-ch, nil
case <-indexer.closed:
return TxIndexProgress{}, errors.New("indexer is closed")
select {
case prog := <-ch:
return prog, nil
case <-ctx.Done():
return TxIndexProgress{}, ctx.Err()
}
case <-indexer.closed:
return TxIndexProgress{}, errors.New("indexer is closed")
}
}
// close shutdown the indexer. Safe to be called for multiple times.