core/bloombits/matcher | add quit channel instead of kill channel

This commit is contained in:
ucwong 2020-04-22 01:25:55 +00:00
parent 9865f518da
commit c199a5134c

View file

@ -413,7 +413,8 @@ func (m *Matcher) distributor(dist chan *request, session *MatcherSession) {
return
}
shutdown = nil
case <-session.quit:
return
case req := <-dist:
// New retrieval request arrived to be distributed to some fetcher process
queue := requests[req.bit]