From 90ab3fdf68641d69deef37381d670bd8dd74f934 Mon Sep 17 00:00:00 2001 From: cnderrauber Date: Fri, 23 Feb 2024 13:10:58 +0800 Subject: [PATCH] Reduce FrameIntegrityChecker's allocation (#2504) --- pkg/sfu/buffer/frameintegrity.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/sfu/buffer/frameintegrity.go b/pkg/sfu/buffer/frameintegrity.go index bc6fe30a7..536f793cf 100644 --- a/pkg/sfu/buffer/frameintegrity.go +++ b/pkg/sfu/buffer/frameintegrity.go @@ -23,7 +23,7 @@ type FrameEntity struct { endSeq *uint64 integrity bool - packetsConsective func(uint64, uint64) bool + pktHistory *PacketHistory } func (fe *FrameEntity) AddPacket(extSeq uint64, ddVal *dd.DependencyDescriptor) { @@ -40,7 +40,7 @@ func (fe *FrameEntity) AddPacket(extSeq uint64, ddVal *dd.DependencyDescriptor) } if fe.startSeq != nil && fe.endSeq != nil { - if fe.packetsConsective(*fe.startSeq, *fe.endSeq) { + if fe.pktHistory.PacketsConsecutive(*fe.startSeq, *fe.endSeq) { fe.integrity = true } } @@ -179,7 +179,7 @@ func NewFrameIntegrityChecker(frameCount, packetCount int) *FrameIntegrityChecke } for i := range fc.frames { - fc.frames[i].packetsConsective = fc.pktHistory.PacketsConsecutive + fc.frames[i].pktHistory = fc.pktHistory fc.frames[i].Reset() } return fc