From 9969144c894fc3629e4a5182228bd5befb1dc236 Mon Sep 17 00:00:00 2001
From: q191201771 <191201771@qq.com>
Date: Sun, 3 Apr 2022 13:10:23 +0800
Subject: [PATCH] patch

---
 pkg/remux/rtmp2rtsp.go | 16 ++--------------
 1 file changed, 2 insertions(+), 14 deletions(-)

diff --git a/pkg/remux/rtmp2rtsp.go b/pkg/remux/rtmp2rtsp.go
index fb7c4fb..8178371 100644
--- a/pkg/remux/rtmp2rtsp.go
+++ b/pkg/remux/rtmp2rtsp.go
@@ -70,12 +70,12 @@ func (r *Rtmp2RtspRemuxer) FeedRtmpMsg(msg base.RtmpMsg) {
 	case base.RtmpTypeIdMetadata:
 		return
 	case base.RtmpTypeIdAudio:
-		if len(msg.Payload) <= 5 {
+		if len(msg.Payload) <= 2 {
 			Log.Warnf("rtmp msg too short, ignore. header=%+v, payload=%s", msg.Header, hex.Dump(msg.Payload))
 			return
 		}
 	case base.RtmpTypeIdVideo:
-		if len(msg.Payload) <= 2 {
+		if len(msg.Payload) <= 5 {
 			Log.Warnf("rtmp msg too short, ignore. header=%+v, payload=%s", msg.Header, hex.Dump(msg.Payload))
 			return
 		}
@@ -104,10 +104,6 @@ func (r *Rtmp2RtspRemuxer) FeedRtmpMsg(msg base.RtmpMsg) {
 		}
 
 		if msg.IsAacSeqHeader() {
-			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
-			}
 			r.asc = msg.Clone().Payload[2:]
 			r.doAnalyze()
 			return
@@ -178,10 +174,6 @@ func (r *Rtmp2RtspRemuxer) remux(msg base.RtmpMsg) {
 	var rtppkts []rtprtcp.RtpPacket
 	switch msg.Header.MsgTypeId {
 	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()
 		if packer != nil {
 			rtppkts = packer.Pack(base.AvPacket{
@@ -191,10 +183,6 @@ func (r *Rtmp2RtspRemuxer) remux(msg base.RtmpMsg) {
 			})
 		}
 	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()
 		if packer != nil {
 			rtppkts = r.getVideoPacker().Pack(base.AvPacket{