From 417166704a0b2417cd947a86300c66d70e98ee30 Mon Sep 17 00:00:00 2001 From: "M. J. Fromberger" Date: Tue, 18 Jan 2022 12:01:04 -0800 Subject: [PATCH] pex: do not send nil envelopes to the reactor (#7622) --- internal/p2p/pex/reactor.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/internal/p2p/pex/reactor.go b/internal/p2p/pex/reactor.go index 87609cc85..2faa3130d 100644 --- a/internal/p2p/pex/reactor.go +++ b/internal/p2p/pex/reactor.go @@ -171,10 +171,14 @@ func (r *Reactor) processPexCh(ctx context.Context) { defer close(incoming) iter := r.pexCh.Receive(ctx) for iter.Next(ctx) { + env := iter.Envelope() + if env == nil { + break + } select { case <-ctx.Done(): return - case incoming <- iter.Envelope(): + case incoming <- env: } } }()