From 4d3eb134a2e07da82b2130e6b2bbdf6a6a9051eb Mon Sep 17 00:00:00 2001 From: Jakob Borg Date: Sat, 19 Apr 2014 23:02:14 +0200 Subject: [PATCH] discosrv: Remove deprecated v1 support --- cmd/discosrv/main.go | 75 -------------------------------------------- 1 file changed, 75 deletions(-) diff --git a/cmd/discosrv/main.go b/cmd/discosrv/main.go index c53e4a892..9e751a88c 100644 --- a/cmd/discosrv/main.go +++ b/cmd/discosrv/main.go @@ -80,12 +80,6 @@ func main() { magic := binary.BigEndian.Uint32(buf) switch magic { - case discover.AnnouncementMagicV1: - handleAnnounceV1(addr, buf) - - case discover.QueryMagicV1: - handleQueryV1(conn, addr, buf) - case discover.AnnouncementMagicV2: handleAnnounceV2(addr, buf) @@ -123,75 +117,6 @@ func limit(addr *net.UDPAddr) bool { return false } -func handleAnnounceV1(addr *net.UDPAddr, buf []byte) { - var pkt discover.AnnounceV1 - err := pkt.UnmarshalXDR(buf) - if err != nil { - log.Println("AnnounceV1 Unmarshal:", err) - log.Println(hex.Dump(buf)) - return - } - if debug { - log.Printf("<- %v %#v", addr, pkt) - } - - ip := addr.IP.To4() - if ip == nil { - ip = addr.IP.To16() - } - node := Node{ - Addresses: []Address{{ - IP: ip, - Port: pkt.Port, - }}, - Updated: time.Now(), - } - - lock.Lock() - nodes[pkt.NodeID] = node - lock.Unlock() -} - -func handleQueryV1(conn *net.UDPConn, addr *net.UDPAddr, buf []byte) { - var pkt discover.QueryV1 - err := pkt.UnmarshalXDR(buf) - if err != nil { - log.Println("QueryV1 Unmarshal:", err) - log.Println(hex.Dump(buf)) - return - } - if debug { - log.Printf("<- %v %#v", addr, pkt) - } - - lock.Lock() - node, ok := nodes[pkt.NodeID] - queries++ - lock.Unlock() - - if ok && len(node.Addresses) > 0 { - pkt := discover.AnnounceV1{ - Magic: discover.AnnouncementMagicV1, - NodeID: pkt.NodeID, - Port: node.Addresses[0].Port, - IP: node.Addresses[0].IP, - } - if debug { - log.Printf("-> %v %#v", addr, pkt) - } - - tb := pkt.MarshalXDR() - _, _, err = conn.WriteMsgUDP(tb, nil, addr) - if err != nil { - log.Println("QueryV1 response write:", err) - } - - lock.Lock() - answered++ - lock.Unlock() - } -} - func handleAnnounceV2(addr *net.UDPAddr, buf []byte) { var pkt discover.AnnounceV2 err := pkt.UnmarshalXDR(buf)