ea

escape.go

package main

import (
	"log"
	"net"
	"os"
)

type worker struct {
	conn *net.UDPConn
	pkts chan []byte
}

func (w *worker) run() {
	for {
		buf := make([]byte, 1500)
		read, _, err := w.conn.ReadFromUDP(buf)
		if err != nil {
			log.Fatalf("could not ReadFromUDP: %s", err)
		}	 
		w.pkts <- buf[:read]
	}
}	

func listen(pkts chan []byte) os.Error {
	c, err := net.ListenUDP("udp4", &net.UDPAddr { net.IPv4zero, 5353 })
        if err != nil {
                return err
        }
	// BUG should be &worker
        w := worker{ c, pkts }
        go w.run()
	return nil
}

func main() {
	pkts := make(chan []byte, 16)
	if err := listen(pkts); err != nil {
		log.Fatal(err)
	}
	<- pkts // code will pause here
}