From 8bba0acfcf6241e1dfd76676e85516dd75daceec Mon Sep 17 00:00:00 2001
From: David Chen <chenosaurus@gmail.com>
Date: Fri, 28 Aug 2026 17:17:11 -0700
Subject: [PATCH] Potential fix for pull request finding

Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com>
---
 pkg/sfu/downtrack.go | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/pkg/sfu/downtrack.go b/pkg/sfu/downtrack.go
index 088084804..c0949ffe0 100644
--- a/pkg/sfu/downtrack.go
+++ b/pkg/sfu/downtrack.go
@@ -2532,13 +2532,15 @@ func (d *DownTrack) onMediaPacketSentForFEC(hdr *rtp.Header, payload []byte) {
 
 	bytesSent := uint64(0)
 	for i := range fecPackets {
-		fecHdr := fecPackets[i].Header
-		d.addDummyExtensions(&fecHdr)
+		fecHdr := RTPHeaderFactory.Get().(*rtp.Header)
+		*fecHdr = fecPackets[i].Header
+		d.addDummyExtensions(fecHdr)
 		headerSize := fecHdr.MarshalSize()
 
 		pacerPacket := pacer.PacketFactory.Get().(*pacer.Packet)
 		*pacerPacket = pacer.Packet{
-			Header:             &fecHdr,
+			Header:             fecHdr,
+			HeaderPool:         RTPHeaderFactory,
 			HeaderSize:         headerSize,
 			Payload:            fecPackets[i].Payload,
 			ProbeClusterId:     ccutils.ProbeClusterId(d.probeClusterId.Load()),
@@ -2546,12 +2548,11 @@ func (d *DownTrack) onMediaPacketSentForFEC(hdr *rtp.Header, payload []byte) {
 			TransportWideExtID: uint8(d.transportWideExtID),
 			WriteStream:        d.writeStream,
 		}
-		bytesSent += uint64(headerSize + len(fecPackets[i].Payload))
+		bytesSent += uint64(len(fecPackets[i].Payload))
 		d.pacer.Enqueue(pacerPacket)
 	}
 
 	prometheus.RecordFECDownstreamSent(len(fecPackets), bytesSent)
-}
 
 // FECWriterStats returns cumulative downstream FlexFEC generation counters,
 // the second return indicates whether FEC generation is active.