代码拉取完成,页面将自动刷新
package gortsplib
import (
"github.com/bluenviron/gortsplib/v4/pkg/description"
)
type serverStreamMedia struct {
st *ServerStream
media *description.Media
trackID int
formats map[uint8]*serverStreamFormat
multicastWriter *serverMulticastWriter
}
func (sm *serverStreamMedia) initialize() {
sm.formats = make(map[uint8]*serverStreamFormat)
for _, forma := range sm.media.Formats {
sf := &serverStreamFormat{
sm: sm,
format: forma,
}
sf.initialize()
sm.formats[forma.PayloadType()] = sf
}
}
func (sm *serverStreamMedia) close() {
for _, tr := range sm.formats {
if tr.rtcpSender != nil {
tr.rtcpSender.Close()
}
}
if sm.multicastWriter != nil {
sm.multicastWriter.close()
}
}
func (sm *serverStreamMedia) writePacketRTCP(byts []byte) error {
// send unicast
for r := range sm.st.activeUnicastReaders {
sm, ok := r.setuppedMedias[sm.media]
if ok {
err := sm.writePacketRTCP(byts)
if err != nil {
r.onStreamWriteError(err)
}
}
}
// send multicast
if sm.multicastWriter != nil {
err := sm.multicastWriter.writePacketRTCP(byts)
if err != nil {
return err
}
}
return nil
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。