From 6f374e396529a11a6af5920c5cce135bf906a60e Mon Sep 17 00:00:00 2001 From: aler9 <46489434+aler9@users.noreply.github.com> Date: Sun, 12 Dec 2021 23:06:44 +0100 Subject: [PATCH] server: re-export ServerSession.WritePacketRTP() (#90) --- serversession.go | 5 +++-- serverstream.go | 2 +- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/serversession.go b/serversession.go index 38625789..e2f97805 100644 --- a/serversession.go +++ b/serversession.go @@ -999,7 +999,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}) @@ -1200,7 +1200,8 @@ func (ss *ServerSession) runWriter() { } } -func (ss *ServerSession) writePacketRTP(trackID int, payload []byte) { +// WritePacketRTP writes a RTP packet to the session. +func (ss *ServerSession) WritePacketRTP(trackID int, payload []byte) { if _, ok := ss.setuppedTracks[trackID]; !ok { return } diff --git a/serverstream.go b/serverstream.go index 8d2624c3..6a391b7e 100644 --- a/serverstream.go +++ b/serverstream.go @@ -318,7 +318,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