diff --git a/main.go b/main.go index dbf3d21b..cc477b40 100644 --- a/main.go +++ b/main.go @@ -60,8 +60,8 @@ type program struct { rtspl *serverTcpListener rtpl *serverUdpListener rtcpl *serverUdpListener - clients map[*client]struct{} - publishers map[string]*client + clients map[*serverClient]struct{} + publishers map[string]*serverClient } func newProgram() (*program, error) { @@ -159,8 +159,8 @@ func newProgram() (*program, error) { publishPass: publishPass, preScript: preScript, postScript: postScript, - clients: make(map[*client]struct{}), - publishers: make(map[string]*client), + clients: make(map[*serverClient]struct{}), + publishers: make(map[string]*serverClient), } var err error diff --git a/server-client.go b/server-client.go index 02da75be..f5fae149 100644 --- a/server-client.go +++ b/server-client.go @@ -105,7 +105,7 @@ const ( _CLIENT_STATE_RECORD ) -type client struct { +type serverClient struct { p *program conn *gortsplib.ConnServer state clientState @@ -119,8 +119,8 @@ type client struct { chanWrite chan *gortsplib.InterleavedFrame } -func newClient(p *program, nconn net.Conn) *client { - c := &client{ +func newServerClient(p *program, nconn net.Conn) *serverClient { + c := &serverClient{ p: p, conn: gortsplib.NewConnServer(nconn), state: _CLIENT_STATE_STARTING, @@ -134,7 +134,7 @@ func newClient(p *program, nconn net.Conn) *client { return c } -func (c *client) close() error { +func (c *serverClient) close() error { // already deleted if _, ok := c.p.clients[c]; !ok { return nil @@ -160,12 +160,12 @@ func (c *client) close() error { return nil } -func (c *client) log(format string, args ...interface{}) { +func (c *serverClient) log(format string, args ...interface{}) { format = "[RTSP client " + c.conn.NetConn().RemoteAddr().String() + "] " + format log.Printf(format, args...) } -func (c *client) run() { +func (c *serverClient) run() { defer func() { if c.p.postScript != "" { postScript := exec.Command(c.p.postScript) @@ -213,12 +213,12 @@ func (c *client) run() { } } -func (c *client) writeResDeadline(res *gortsplib.Response) { +func (c *serverClient) writeResDeadline(res *gortsplib.Response) { c.conn.NetConn().SetWriteDeadline(time.Now().Add(_WRITE_TIMEOUT)) c.conn.WriteResponse(res) } -func (c *client) writeResError(req *gortsplib.Request, err error) { +func (c *serverClient) writeResError(req *gortsplib.Request, err error) { c.log("ERR: %s", err) if cseq, ok := req.Header["CSeq"]; ok && len(cseq) == 1 { @@ -237,7 +237,7 @@ func (c *client) writeResError(req *gortsplib.Request, err error) { } } -func (c *client) handleRequest(req *gortsplib.Request) bool { +func (c *serverClient) handleRequest(req *gortsplib.Request) bool { c.log(req.Method) cseq, ok := req.Header["CSeq"] diff --git a/server-tcpl.go b/server-tcpl.go index 4aeedd13..8588e577 100644 --- a/server-tcpl.go +++ b/server-tcpl.go @@ -38,7 +38,7 @@ func (l *serverTcpListener) run() { break } - rsc := newClient(l.p, nconn) + rsc := newServerClient(l.p, nconn) go rsc.run() } }