package main import ( "net" "time" "github.com/aler9/gortsplib" ) type udpAddrBufPair struct { addr *net.UDPAddr buf []byte } type serverUdp struct { p *program conn *net.UDPConn streamType gortsplib.StreamType readBuf *multiBuffer writeChan chan *udpAddrBufPair done chan struct{} } func newServerUdp(p *program, port int, streamType gortsplib.StreamType) (*serverUdp, error) { conn, err := net.ListenUDP("udp", &net.UDPAddr{ Port: port, }) if err != nil { return nil, err } l := &serverUdp{ p: p, conn: conn, streamType: streamType, readBuf: newMultiBuffer(3, clientUdpReadBufferSize), writeChan: make(chan *udpAddrBufPair), done: make(chan struct{}), } l.log("opened on :%d", port) return l, nil } func (l *serverUdp) log(format string, args ...interface{}) { var label string if l.streamType == gortsplib.StreamTypeRtp { label = "RTP" } else { label = "RTCP" } l.p.log("[UDP/"+label+" listener] "+format, args...) } func (l *serverUdp) run() { writeDone := make(chan struct{}) go func() { defer close(writeDone) for w := range l.writeChan { l.conn.SetWriteDeadline(time.Now().Add(l.p.conf.WriteTimeout)) l.conn.WriteTo(w.buf, w.addr) } }() for { buf := l.readBuf.next() n, addr, err := l.conn.ReadFromUDP(buf) if err != nil { break } l.p.clientFrameUdp <- clientFrameUdpReq{ addr, l.streamType, buf[:n], } } close(l.writeChan) <-writeDone close(l.done) } func (l *serverUdp) close() { l.conn.Close() <-l.done } func (l *serverUdp) write(pair *udpAddrBufPair) { l.writeChan <- pair }