client_test.go | 2 +- dht.go | 10 +++++----- diff --git a/client_test.go b/client_test.go index e8f652ebae736f31fc006dc3c864d9b42c7f0b92..84a99f469fb8beb361abd6d827719f08f5a397af 100644 --- a/client_test.go +++ b/client_test.go @@ -322,7 +322,7 @@ defer cl.Close() 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) diff --git a/dht.go b/dht.go index 8b0e84714c0939456ec3edbbd07073a8b7da678c..464090f992eb9a8e230dbe3facee8a51246fad3c 100644 --- a/dht.go +++ b/dht.go @@ -29,11 +29,11 @@ Close() 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() } @@ -45,13 +45,13 @@ func (me anacrolixDhtAnnounceWrapper) Peers() <-chan dht.PeersValues { 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{}