balls

modules/net_recon.go

@@ -183,7 +183,9 @@ func (p ProtoPairList) Swap(i, j int)      { p[i], p[j] = p[j], p[i] }
 
 func (d *Discovery) Show() error {
 	d.Session.Targets.Lock()
+	d.Session.Queue.Lock()
 	defer d.Session.Targets.Unlock()
+	defer d.Session.Queue.Unlock()
 
 	iface := d.Session.Interface
 	gw := d.Session.Gateway

packets/queue.go

@@ -151,6 +151,14 @@ func (q *Queue) Send(raw []byte) error {
 	}
 }
 
+func (q *Queue) Lock() {
+	q.lock.Lock()
+}
+
+func (q *Queue) Unlock() {
+	q.lock.Unlock()
+}
+
 func (q *Queue) Stop() {
 	q.lock.Lock()
 	defer q.lock.Unlock()