From c199a5134ca31ce0f91537c10ffeb4a6bca95e6f Mon Sep 17 00:00:00 2001 From: ucwong Date: Wed, 22 Apr 2020 01:25:55 +0000 Subject: [PATCH] core/bloombits/matcher | add quit channel instead of kill channel --- core/bloombits/matcher.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/core/bloombits/matcher.go b/core/bloombits/matcher.go index f96e5b71ac..a18d8ca89b 100644 --- a/core/bloombits/matcher.go +++ b/core/bloombits/matcher.go @@ -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]