server: unexport ServerSession.WritePacketRTP

This commit is contained in:
aler9
2021-12-04 22:30:21 +01:00
parent e98cb8b108
commit 4621d5f7be
2 changed files with 3 additions and 4 deletions

View File

@@ -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) ss.s.udpRTCPListener.addClient(ss.author.ip(), track.udpRTCPPort, ss, trackID, true)
// open the firewall by sending packets to the counterpart // 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}) []byte{0x80, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00})
ss.WritePacketRTCP(trackID, ss.WritePacketRTCP(trackID,
[]byte{0x80, 0xc9, 0x00, 0x01, 0x00, 0x00, 0x00, 0x00}) []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} }, 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 { if _, ok := ss.setuppedTracks[trackID]; !ok {
return return
} }

View File

@@ -242,7 +242,7 @@ func (st *ServerStream) WritePacketRTP(trackID int, payload []byte) {
// send unicast // send unicast
for r := range st.readersUnicast { for r := range st.readersUnicast {
r.WritePacketRTP(trackID, payload) r.writePacketRTP(trackID, payload)
} }
// send multicast // send multicast