diff --git a/serversession.go b/serversession.go index 94bebe39..d4b2ec17 100644 --- a/serversession.go +++ b/serversession.go @@ -939,7 +939,7 @@ func (ss *ServerSession) handleRequest(sc *ServerConn, req *base.Request) (*base ss.s.udpRTCPListener.addClient(ss.author.ip(), track.udpRTCPPort, ss, trackID, true) // open the firewall by sending packets to the counterpart - ss.WritePacketRTP(trackID, + ss.writePacketRTP(trackID, []byte{0x80, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00}) ss.WritePacketRTCP(trackID, []byte{0x80, 0xc9, 0x00, 0x01, 0x00, 0x00, 0x00, 0x00}) @@ -1070,8 +1070,7 @@ func (ss *ServerSession) handleRequest(sc *ServerConn, req *base.Request) (*base }, liberrors.ErrServerUnhandledRequest{Req: req} } -// WritePacketRTP writes a RTP packet to the session. -func (ss *ServerSession) WritePacketRTP(trackID int, payload []byte) { +func (ss *ServerSession) writePacketRTP(trackID int, payload []byte) { if _, ok := ss.setuppedTracks[trackID]; !ok { return } diff --git a/serverstream.go b/serverstream.go index 98f9f17e..5ead1b4a 100644 --- a/serverstream.go +++ b/serverstream.go @@ -242,7 +242,7 @@ func (st *ServerStream) WritePacketRTP(trackID int, payload []byte) { // send unicast for r := range st.readersUnicast { - r.WritePacketRTP(trackID, payload) + r.writePacketRTP(trackID, payload) } // send multicast