From 748e1ee09a280ff5db59808d32e3bc03458a7d3f Mon Sep 17 00:00:00 2001 From: joestarzxh Date: Thu, 1 Apr 2021 15:22:03 +0800 Subject: [PATCH] =?UTF-8?q?[fix]=E8=A7=A3=E5=86=B3rtsp=20sub=E6=97=A0?= =?UTF-8?q?=E5=93=8D=E5=BA=94=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pkg/logic/group.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/pkg/logic/group.go b/pkg/logic/group.go index 79bf3a4..43a8bcb 100644 --- a/pkg/logic/group.go +++ b/pkg/logic/group.go @@ -188,7 +188,7 @@ func (group *Group) Tick() { if _, writeAlive := session.IsAlive(); !writeAlive { nazalog.Warnf("[%s] session timeout. session=%s", group.UniqueKey, session.UniqueKey()) session.Dispose() - group.DelRTSPSubSession(session) + group.delRTSPSubSession(session) } } } @@ -657,7 +657,10 @@ func (group *Group) delRTSPPubSession(session *rtsp.PubSession) { group.rtspPubSession = nil group.delIn() } - +func (group *Group) delRTSPSubSession(session *rtsp.SubSession) { + nazalog.Debugf("[%s] [%s] del rtsp SubSession from group.", group.UniqueKey, session.UniqueKey()) + delete(group.rtspSubSessionSet, session) +} func (group *Group) delRTMPPullSession(session *rtmp.PullSession) { nazalog.Debugf("[%s] [%s] del rtmp PullSession from group.", group.UniqueKey, session.UniqueKey())