peer_store "github.com/anacrolix/dht/v2/peer-store"
)
+// DHT server interface for use by a Torrent or Client. It's reasonable for this to make assumptions
+// for torrent-use that might not be the default behaviour for the DHT server.
type DhtServer interface {
Stats() interface{}
ID() [20]byte
Addr() net.Addr
AddNode(ni krpc.NodeInfo) error
+ // This is called asynchronously when receiving PORT messages.
Ping(addr *net.UDPAddr)
Announce(hash [20]byte, port int, impliedPort bool) (DhtAnnounce, error)
WriteStatus(io.Writer)
}
func (me AnacrolixDhtServerWrapper) Ping(addr *net.UDPAddr) {
- me.Server.Ping(addr)
+ me.Server.PingQueryInput(addr, dht.QueryInput{
+ RateLimiting: dht.QueryRateLimiting{NoWaitFirst: true},
+ })
}
var _ DhtServer = AnacrolixDhtServerWrapper{}