From 98e63a62a2439311d5fa5122be5959d295c5d4d0 Mon Sep 17 00:00:00 2001 From: q191201771 <191201771@qq.com> Date: Mon, 1 Feb 2021 10:55:01 +0800 Subject: [PATCH] =?UTF-8?q?[fix]=20=E8=8E=B7=E5=8F=96group=E4=B8=AD?= =?UTF-8?q?=E6=92=AD=E6=94=BE=E8=80=85=E6=95=B0=E9=87=8F=E6=97=B6=E9=94=81?= =?UTF-8?q?=E6=B2=A1=E6=9C=89=E9=87=8A=E6=94=BE=EF=BC=8C=E5=AF=BC=E8=87=B4?= =?UTF-8?q?=E5=90=8E=E7=BB=AD=E6=97=A0=E6=B3=95=E8=BD=AC=E5=8F=91=E6=95=B0?= =?UTF-8?q?=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pkg/logic/group.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/logic/group.go b/pkg/logic/group.go index 6d438b7..12608db 100644 --- a/pkg/logic/group.go +++ b/pkg/logic/group.go @@ -535,10 +535,10 @@ func (group *Group) OnAVPacket(pkt base.AVPacket) { func (group *Group) StringifyDebugStats() string { group.mutex.Lock() subLen := len(group.rtmpSubSessionSet) + len(group.httpflvSubSessionSet) + len(group.httptsSubSessionSet) + len(group.rtspSubSessionSet) + group.mutex.Unlock() if subLen > 10 { return fmt.Sprintf("[%s] not log out all stats. subLen=%d", group.UniqueKey, subLen) } - group.mutex.Unlock() b, _ := json.Marshal(group.GetStat()) return string(b) }