skip peers using flux ports before adding to queue

This commit is contained in:
Conrado Gouvea 2022-06-13 12:27:13 -03:00
parent 309a0064b5
commit dc7e70dcec
1 changed files with 8 additions and 2 deletions

View File

@ -58,7 +58,10 @@ func (s *Seeder) onAddr(p *peer.Peer, msg *wire.MsgAddr) {
s.logger.Printf("Already knew about %s:%d", na.IP, na.Port)
continue
}
s.addrQueue <- na
_, denied := DeniedPorts[na.Port]
if !denied {
s.addrQueue <- na
}
}
}
@ -84,7 +87,10 @@ func (s *Seeder) onAddrV2(p *peer.Peer, msg *wire.MsgAddrV2) {
s.logger.Printf("Already knew about %s:%d", na.IP, na.Port)
continue
}
s.addrQueue <- &na.NetAddress
_, denied := DeniedPorts[na.Port]
if !denied {
s.addrQueue <- &na.NetAddress
}
}
}
}