From 9ee424b912af7010515b09d4e1539d41858b71c8 Mon Sep 17 00:00:00 2001 From: Martin Geno Date: Thu, 26 Oct 2017 15:24:04 +0200 Subject: [PATCH] [BUGFIX] binding listen port --- respond/collector.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/respond/collector.go b/respond/collector.go index 982d002..1098abf 100644 --- a/respond/collector.go +++ b/respond/collector.go @@ -19,6 +19,7 @@ import ( type Collector struct { connections []*net.UDPConn // UDP sockets ifaceToConn map[string]*net.UDPConn // map from interface name to UDP socket + port int queue chan *Response // received responses db database.Connection @@ -33,6 +34,7 @@ func NewCollector(db database.Connection, nodes *runtime.Nodes, ifaces []string, coll := &Collector{ db: db, nodes: nodes, + port: port, queue: make(chan *Response, 400), stop: make(chan interface{}), ifaceToConn: make(map[string]*net.UDPConn), @@ -63,7 +65,7 @@ func (coll *Collector) listenUDP(iface string) { // Open socket conn, err := net.ListenUDP("udp", &net.UDPAddr{ IP: linkLocalAddr, - Port: port, + Port: coll.port, Zone: iface, }) if err != nil {