diff --git a/dht/dht.go b/dht/dht.go index 737449e5..1bdb9ab5 100644 --- a/dht/dht.go +++ b/dht/dht.go @@ -572,6 +572,9 @@ func (s *Server) serve() error { logonce.Stderr.Printf("received dht packet exceeds buffer size") continue } + if s.ipBlocked(util.AddrIP(addr)) { + continue + } s.processPacket(b[:n], newDHTAddr(addr)) } }