From b868a6b9e2cf372cbaec8e84cfd4682401b1ea46 Mon Sep 17 00:00:00 2001 From: Matt Joiner Date: Tue, 7 Feb 2017 15:01:02 +1100 Subject: [PATCH] dht.Server.Announce now takes [20]byte --- cmd/dht-get-peers/main.go | 7 ++++--- torrent.go | 2 +- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/cmd/dht-get-peers/main.go b/cmd/dht-get-peers/main.go index 1c0a2776..d72c34e5 100644 --- a/cmd/dht-get-peers/main.go +++ b/cmd/dht-get-peers/main.go @@ -9,10 +9,9 @@ import ( "os" "os/signal" - _ "github.com/anacrolix/envpprof" - "github.com/anacrolix/dht" "github.com/anacrolix/dht/krpc" + _ "github.com/anacrolix/envpprof" ) var ( @@ -128,7 +127,9 @@ func main() { seen := make(map[string]struct{}) getPeers: for { - ps, err := s.Announce(*infoHash, 0, false) + var ih [20]byte + copy(ih[:], *infoHash) + ps, err := s.Announce(ih, 0, false) if err != nil { log.Fatal(err) } diff --git a/torrent.go b/torrent.go index beff7d21..929e0bc6 100644 --- a/torrent.go +++ b/torrent.go @@ -1223,7 +1223,7 @@ func (t *Torrent) consumeDHTAnnounce(pvs <-chan dht.PeersValues) { func (t *Torrent) announceDHT(impliedPort bool) (err error) { cl := t.cl - ps, err := cl.dHT.Announce(string(t.infoHash[:]), cl.incomingPeerPort(), impliedPort) + ps, err := cl.dHT.Announce(t.infoHash, cl.incomingPeerPort(), impliedPort) if err != nil { return } -- 2.48.1