From: Matt Joiner <anacrolix@gmail.com>
Date: Wed, 16 Jul 2014 07:10:49 +0000 (+1000)
Subject: Squash various unhandled DHT messages
X-Git-Tag: v1.0.0~1664
X-Git-Url: http://www.git.stargrave.org/?a=commitdiff_plain;h=7d587b832e5fd5b6c8e561a8bf319cab2c8055d1;p=btrtrc.git

Squash various unhandled DHT messages
---

diff --git a/dht/dht.go b/dht/dht.go
index cd8f9e35..6024bab3 100644
--- a/dht/dht.go
+++ b/dht/dht.go
@@ -3,6 +3,7 @@ package dht
 import (
 	"bitbucket.org/anacrolix/go.torrent/tracker"
 	"bitbucket.org/anacrolix/go.torrent/util"
+	"bytes"
 	"crypto"
 	_ "crypto/sha1"
 	"encoding/binary"
@@ -140,7 +141,10 @@ func (s *Server) Serve() error {
 		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()
@@ -230,7 +234,10 @@ func (s *Server) handleQuery(source *net.UDPAddr, m Msg) {
 			"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