From e88c243efa6861e91f0f740aec3601b7ff797404 Mon Sep 17 00:00:00 2001
From: yangjiechina <1534796060@qq.com>
Date: Sat, 22 Jun 2024 16:25:27 +0800
Subject: [PATCH] =?UTF-8?q?source=E5=85=B3=E9=97=AD=E6=97=B6,=20=E5=85=B3?=
 =?UTF-8?q?=E9=97=AD=E7=BD=91=E7=BB=9C=E8=BF=9E=E6=8E=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 stream/source.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/stream/source.go b/stream/source.go
index 2f49f77..3641ff7 100644
--- a/stream/source.go
+++ b/stream/source.go
@@ -255,7 +255,7 @@ func (s *PublishSource) LoopEvent() {
 
 			if err := s.inputCB(data); err != nil {
 				log.Sugar.Errorf("处理输入流失败 释放source:%s err:%s", s.Id_, err.Error())
-				s.Close()
+				s.doClose()
 			}
 			break
 		case sink := <-s.playingEventQueue:
@@ -439,6 +439,10 @@ func (s *PublishSource) doClose() {
 		return
 	}
 
+	if s.Conn != nil {
+		s.Conn.Close()
+	}
+
 	//清空未写完的buffer
 	for _, buffer := range s.pktBuffers {
 		if buffer != nil {