rename rtsp* into server*

main.go

@@ -47,9 +47,9 @@ type program struct {
 	rtcpPort   int
 	publishKey string
 	mutex      sync.RWMutex
-	rtspl      *rtspTcpListener
+	rtspl      *serverTcpListener
-	rtpl       *rtspUdpListener
+	rtpl       *serverUdpListener
-	rtcpl      *rtspUdpListener
+	rtcpl      *serverUdpListener
 	clients    map[*client]struct{}
 	publishers map[string]*client
 }
@@ -92,17 +92,17 @@ func newProgram(protocolsStr string, rtspPort int, rtpPort int, rtcpPort int, pu
 
 	var err error
 
-	p.rtpl, err = newRtspUdpListener(p, rtpPort, _TRACK_FLOW_RTP)
+	p.rtpl, err = newServerUdpListener(p, rtpPort, _TRACK_FLOW_RTP)
 	if err != nil {
 		return nil, err
 	}
 
-	p.rtcpl, err = newRtspUdpListener(p, rtcpPort, _TRACK_FLOW_RTCP)
+	p.rtcpl, err = newServerUdpListener(p, rtcpPort, _TRACK_FLOW_RTCP)
 	if err != nil {
 		return nil, err
 	}
 
-	p.rtspl, err = newRtspTcpListener(p)
+	p.rtspl, err = newServerTcpListener(p)
 	if err != nil {
 		return nil, err
 	}

server_tcpl.go

@@ -5,12 +5,12 @@ import (
 	"net"
 )
 
-type rtspTcpListener struct {
+type serverTcpListener struct {
 	p    *program
 	netl *net.TCPListener
 }
 
-func newRtspTcpListener(p *program) (*rtspTcpListener, error) {
+func newServerTcpListener(p *program) (*serverTcpListener, error) {
 	netl, err := net.ListenTCP("tcp", &net.TCPAddr{
 		Port: p.rtspPort,
 	})
@@ -18,7 +18,7 @@ func newRtspTcpListener(p *program) (*rtspTcpListener, error) {
 		return nil, err
 	}
 
-	s := &rtspTcpListener{
+	s := &serverTcpListener{
 		p:    p,
 		netl: netl,
 	}
@@ -27,11 +27,11 @@ func newRtspTcpListener(p *program) (*rtspTcpListener, error) {
 	return s, nil
 }
 
-func (l *rtspTcpListener) log(format string, args ...interface{}) {
+func (l *serverTcpListener) log(format string, args ...interface{}) {
-	log.Printf("[RTSP TCP listener] "+format, args...)
+	log.Printf("[TCP listener] "+format, args...)
 }
 
-func (l *rtspTcpListener) run() {
+func (l *serverTcpListener) run() {
 	for {
 		nconn, err := l.netl.AcceptTCP()
 		if err != nil {

server_udpl.go

@@ -5,13 +5,13 @@ import (
 	"net"
 )
 
-type rtspUdpListener struct {
+type serverUdpListener struct {
 	p     *program
 	nconn *net.UDPConn
 	flow  trackFlow
 }
 
-func newRtspUdpListener(p *program, port int, flow trackFlow) (*rtspUdpListener, error) {
+func newServerUdpListener(p *program, port int, flow trackFlow) (*serverUdpListener, error) {
 	nconn, err := net.ListenUDP("udp", &net.UDPAddr{
 		Port: port,
 	})
@@ -19,7 +19,7 @@ func newRtspUdpListener(p *program, port int, flow trackFlow) (*rtspUdpListener,
 		return nil, err
 	}
 
-	l := &rtspUdpListener{
+	l := &serverUdpListener{
 		p:     p,
 		nconn: nconn,
 		flow:  flow,
@@ -29,17 +29,17 @@ func newRtspUdpListener(p *program, port int, flow trackFlow) (*rtspUdpListener,
 	return l, nil
 }
 
-func (l *rtspUdpListener) log(format string, args ...interface{}) {
+func (l *serverUdpListener) log(format string, args ...interface{}) {
 	var label string
 	if l.flow == _TRACK_FLOW_RTP {
 		label = "RTP"
 	} else {
 		label = "RTCP"
 	}
-	log.Printf("[RTSP UDP/"+label+" listener] "+format, args...)
+	log.Printf("[UDP/"+label+" listener] "+format, args...)
 }
 
-func (l *rtspUdpListener) run() {
+func (l *serverUdpListener) run() {
 	buf := make([]byte, 2048) // UDP MTU is 1400
 
 	for {