From 3cba14f1d3caa4448683d582acda542747a2a043 Mon Sep 17 00:00:00 2001 From: "joe_zhang2006@163.com" Date: Tue, 16 Jan 2024 16:13:31 +0800 Subject: [PATCH] =?UTF-8?q?[fix]=E4=BF=AE=E6=AD=A3flv=E6=92=AD=E6=94=BE?= =?UTF-8?q?=E5=99=A8=E5=85=B3=E9=97=AD=E6=97=B6=EF=BC=8C=E5=8F=A5=E6=9F=84?= =?UTF-8?q?=E6=9C=AA=E9=87=8A=E6=94=BE=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/http_server_handler.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pkg/logic/http_server_handler.go b/pkg/logic/http_server_handler.go index df609ff..6a98656 100644 --- a/pkg/logic/http_server_handler.go +++ b/pkg/logic/http_server_handler.go @@ -78,6 +78,7 @@ func (h *HttpServerHandler) ServeSubSession(writer http.ResponseWriter, req *htt err = session.RunLoop() Log.Debugf("[%s] httpflv sub session loop done. err=%v", session.UniqueKey(), err) h.observer.OnDelHttpflvSubSession(session) + _ = session.Dispose() return } @@ -92,6 +93,7 @@ func (h *HttpServerHandler) ServeSubSession(writer http.ResponseWriter, req *htt err = session.RunLoop() Log.Debugf("[%s] httpts sub session loop done. err=%v", session.UniqueKey(), err) h.observer.OnDelHttptsSubSession(session) + _ = session.Dispose() return } }