From c09a1324338cfdfc452581a4e5d6a60170bc4804 Mon Sep 17 00:00:00 2001 From: ydajiang Date: Wed, 4 Jun 2025 19:32:34 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20rtsp=20udp=E6=8B=89=E6=B5=81=E5=8F=91?= =?UTF-8?q?=E7=94=9Fcrash=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rtsp/rtsp_sink.go | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/rtsp/rtsp_sink.go b/rtsp/rtsp_sink.go index 3d68ea4..cc581ed 100644 --- a/rtsp/rtsp_sink.go +++ b/rtsp/rtsp_sink.go @@ -86,16 +86,13 @@ func (s *Sink) Write(index int, data []*collections.ReferenceCounter[[]byte], rt return nil } - for i, bytes := range data { + for _, bytes := range data { sender := s.senders[index] sender.PktCount++ sender.OctetCount += len(bytes.Get()) if s.TCPStreaming { - // 一次发送会花屏? - // return s.BaseSink.Write(index, data, rtpTime) - s.BaseSink.Write(index, data[i:i+1], rtpTime, keyVideo) - //s.Conn.Write(bytes.Get()) - } else { + return s.BaseSink.Write(index, data, rtpTime, keyVideo) + } else if sender.RtpConn != nil { // 发送rtcp sr包 sender.RtpConn.Write(bytes.Get()[OverTcpHeaderSize:])