]> Sergey Matveev's repositories - btrtrc.git/commitdiff
dht.Server.Announce now takes [20]byte
authorMatt Joiner <anacrolix@gmail.com>
Tue, 7 Feb 2017 04:01:02 +0000 (15:01 +1100)
committerMatt Joiner <anacrolix@gmail.com>
Tue, 7 Feb 2017 04:01:02 +0000 (15:01 +1100)
cmd/dht-get-peers/main.go
torrent.go

index 1c0a277663cec57d832b53c2661a17a1bbf1d3f1..d72c34e58d74cf9dd7d0167b0c9b4ab71588c591 100644 (file)
@@ -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)
                }
index beff7d212c22f6b2248dc0d5102f5526264a33cf..929e0bc6454d1956f2529614d4c17211ac74a3dc 100644 (file)
@@ -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
        }