forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-26 06:36:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

remove readNextCh

Browse source
This commit is contained in:
thinkAfCod 2025-05-14 15:39:59 +08:00 committed by Chen Kai
parent 8d05d5da6d
commit c603f255c8
1 changed files with 0 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
p2p/discover/v5_udp.go
View file

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