|
|
@ -163,6 +163,10 @@ func (r *Rtmp2RtspRemuxer) remux(msg base.RtmpMsg) {
|
|
|
|
var rtppkts []rtprtcp.RtpPacket
|
|
|
|
var rtppkts []rtprtcp.RtpPacket
|
|
|
|
switch msg.Header.MsgTypeId {
|
|
|
|
switch msg.Header.MsgTypeId {
|
|
|
|
case base.RtmpTypeIdAudio:
|
|
|
|
case base.RtmpTypeIdAudio:
|
|
|
|
|
|
|
|
if len(msg.Payload)<3{
|
|
|
|
|
|
|
|
Log.Warnf("aac seq header payload too short. len=%d, payload=%s", len(msg.Payload), hex.Dump(msg.Payload))
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
packer = r.getAudioPacker()
|
|
|
|
packer = r.getAudioPacker()
|
|
|
|
if packer != nil {
|
|
|
|
if packer != nil {
|
|
|
|
rtppkts = packer.Pack(base.AvPacket{
|
|
|
|
rtppkts = packer.Pack(base.AvPacket{
|
|
|
@ -172,6 +176,10 @@ func (r *Rtmp2RtspRemuxer) remux(msg base.RtmpMsg) {
|
|
|
|
})
|
|
|
|
})
|
|
|
|
}
|
|
|
|
}
|
|
|
|
case base.RtmpTypeIdVideo:
|
|
|
|
case base.RtmpTypeIdVideo:
|
|
|
|
|
|
|
|
if len(msg.Payload)<6{
|
|
|
|
|
|
|
|
Log.Warnf("Video seq header payload too short. len=%d, payload=%s", len(msg.Payload), hex.Dump(msg.Payload))
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
packer = r.getVideoPacker()
|
|
|
|
packer = r.getVideoPacker()
|
|
|
|
if packer != nil {
|
|
|
|
if packer != nil {
|
|
|
|
rtppkts = r.getVideoPacker().Pack(base.AvPacket{
|
|
|
|
rtppkts = r.getVideoPacker().Pack(base.AvPacket{
|
|
|
|