diff --git a/p2p/discover/v5_udp.go b/p2p/discover/v5_udp.go index 905baae4ce..6d5e19c224 100644 --- a/p2p/discover/v5_udp.go +++ b/p2p/discover/v5_udp.go @@ -93,7 +93,6 @@ type UDPv5 struct { // channels into dispatch packetInCh chan ReadPacket - readNextCh chan struct{} callCh chan *callV5 callDoneCh chan *callV5 respTimeoutCh chan *callTimeout @@ -190,7 +189,6 @@ func newUDPv5(conn UDPConn, ln *enode.LocalNode, cfg Config) (*UDPv5, error) { respTimeout: cfg.V5RespTimeout, // channels into dispatch packetInCh: make(chan ReadPacket, 1024), - readNextCh: make(chan struct{}, 1), callCh: make(chan *callV5), callDoneCh: make(chan *callV5), sendCh: make(chan sendRequest), @@ -629,7 +627,6 @@ func (t *UDPv5) dispatch() { t.handlePacket(p.Data, p.Addr) case <-t.closeCtx.Done(): - close(t.readNextCh) close(t.writeCh) for id, queue := range t.callQueue { for _, c := range queue {