forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

core/bloombits : add quit channel select

Browse source
This commit is contained in:
ucwong 2020-04-09 11:01:27 +00:00
parent 3ed5d5500f
commit 9865f518da
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
core/bloombits/matcher.go
View file

@ -586,6 +586,8 @@ func (s *MatcherSession) AllocateSections(bit uint, count int) []uint64 {
// bit index to be injected into the processing pipeline.
func (s *MatcherSession) DeliverSections(bit uint, sections []uint64, bitsets [][]byte) {
select {
case <-s.quit:
return
case s.matcher.deliveries <- &Retrieval{Bit: bit, Sections: sections, Bitsets: bitsets}:
}
}