fix: 减少packet计数发生crash问题

This commit is contained in:
ydajiang
2025-05-17 22:50:18 +08:00
parent 7486fc1491
commit d71014ae7f

View File

@@ -314,7 +314,11 @@ func (s *PublishSource) OnPacket(packet *avformat.AVPacket) {
s.streamPublisher.Post(&StreamEvent{StreamEventTypePacket, packetPtr})
// 释放未引用的AVPacket
for old := packets.Get(0); old.UseCount() < 2; old = packets.Get(0) {
for packets.Size() > 0 {
if packets.Get(0).UseCount() > 1 {
break
}
packets.Remove(0).Release()
s.TransDemuxer.DiscardHeadPacket(packet.BufferIndex)
}