numServers := 0
cl.eachDhtServer(func(s DhtServer) {
t.Log(s)
- assert.Equal(t, ipl, s.(anacrolixDhtServerWrapper).Server.IPBlocklist())
+ assert.Equal(t, ipl, s.(AnacrolixDhtServerWrapper).Server.IPBlocklist())
numServers++
})
assert.EqualValues(t, 2, numServers)
Peers() <-chan dht.PeersValues
}
-type anacrolixDhtServerWrapper struct {
+type AnacrolixDhtServerWrapper struct {
*dht.Server
}
-func (me anacrolixDhtServerWrapper) Stats() interface{} {
+func (me AnacrolixDhtServerWrapper) Stats() interface{} {
return me.Server.Stats()
}
return me.Announce.Peers
}
-func (me anacrolixDhtServerWrapper) Announce(hash [20]byte, port int, impliedPort bool) (DhtAnnounce, error) {
+func (me AnacrolixDhtServerWrapper) Announce(hash [20]byte, port int, impliedPort bool) (DhtAnnounce, error) {
ann, err := me.Server.Announce(hash, port, impliedPort)
return anacrolixDhtAnnounceWrapper{ann}, err
}
-func (me anacrolixDhtServerWrapper) Ping(addr *net.UDPAddr) {
+func (me AnacrolixDhtServerWrapper) Ping(addr *net.UDPAddr) {
me.Server.Ping(addr)
}
-var _ DhtServer = anacrolixDhtServerWrapper{}
+var _ DhtServer = AnacrolixDhtServerWrapper{}