From 812cfd8a55c50c908bb8f622f49ea210a1aa91c9 Mon Sep 17 00:00:00 2001
From: q191201771 <191201771@qq.com>
Date: Sat, 21 Aug 2021 16:58:04 +0800
Subject: [PATCH] =?UTF-8?q?[chore]=20=E5=A2=9E=E5=BC=BA=E5=81=A5=E5=A3=AE?=
 =?UTF-8?q?=E6=80=A7=EF=BC=9Apackage=20rtmp:=20=E5=AF=B9=E7=AB=AF=E5=8D=8F?=
 =?UTF-8?q?=E8=AE=AE=E9=94=99=E8=AF=AF=E6=97=B6=EF=BC=8C=E4=B8=BB=E5=8A=A8?=
 =?UTF-8?q?=E5=85=B3=E9=97=AD=E5=AF=B9=E7=AB=AF=E8=BF=9E=E6=8E=A5=E8=80=8C?=
 =?UTF-8?q?=E4=B8=8D=E6=98=AF=E4=B8=BB=E5=8A=A8panic?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pkg/rtmp/chunk_composer.go | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/pkg/rtmp/chunk_composer.go b/pkg/rtmp/chunk_composer.go
index ee21f93..14c9dde 100644
--- a/pkg/rtmp/chunk_composer.go
+++ b/pkg/rtmp/chunk_composer.go
@@ -13,10 +13,9 @@ package rtmp
 // 读取chunk，并组织chunk，生成message返回给上层
 
 import (
-	"io"
-	"log"
-
 	"github.com/q191201771/lal/pkg/base"
+	"github.com/q191201771/naza/pkg/nazalog"
+	"io"
 
 	"github.com/q191201771/naza/pkg/bele"
 )
@@ -246,7 +245,8 @@ func (c *ChunkComposer) RunLoop(reader io.Reader, cb OnCompleteMessage) error {
 			}
 		}
 		if stream.msg.len() > stream.header.MsgLen {
-			log.Panicf("stream msg len should not greater than len field in header. stream.msg.len=%d, len.in.header=%d", stream.msg.len(), stream.header.MsgLen)
+			nazalog.Warnf("stream msg len should not greater than len field in header. stream.msg.len=%d, header=%+v", stream.msg.len(), stream.header)
+			return ErrRtmp
 		}
 	}
 }