import (
"bitbucket.org/anacrolix/go.torrent/tracker"
"bitbucket.org/anacrolix/go.torrent/util"
+ "bytes"
"crypto"
_ "crypto/sha1"
"encoding/binary"
var d Msg
err = bencode.Unmarshal(b[:n], &d)
if err != nil {
- log.Printf("%s: received bad krpc message: %s: %q", s, err, b[:n])
+ // TODO: What are these messages?
+ if !bytes.HasPrefix(b[:], []byte("A\x00")) {
+ log.Printf("%s: received bad krpc message: %s: %q", s, err, b[:n])
+ }
continue
}
s.mu.Lock()
"nodes": string(nodesBytes),
})
case "announce_peer":
- log.Print(m)
+ // TODO(anacrolix): Implement this lolz.
+ // log.Print(m)
+ case "vote":
+ // TODO(anacrolix): Or reject, I don't think I want this.
default:
log.Printf("%s: not handling received query: q=%s", s, m["q"])
return