From 2c5317f0e28874df3f2239ce6f40c6c5e74fe535 Mon Sep 17 00:00:00 2001 From: Kevin Caffrey Date: Mon, 16 Dec 2024 11:27:59 -0500 Subject: [PATCH] rename to highestAdded --- internal/rtpbuffer/rtpbuffer.go | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/internal/rtpbuffer/rtpbuffer.go b/internal/rtpbuffer/rtpbuffer.go index dd1d87ef..1deefeea 100644 --- a/internal/rtpbuffer/rtpbuffer.go +++ b/internal/rtpbuffer/rtpbuffer.go @@ -17,10 +17,10 @@ const ( // RTPBuffer stores RTP packets and allows custom logic around the lifetime of them via the PacketFactory type RTPBuffer struct { - packets []*RetainablePacket - size uint16 - lastAdded uint16 - started bool + packets []*RetainablePacket + size uint16 + highestAdded uint16 + started bool } // NewRTPBuffer constructs a new RTPBuffer @@ -50,16 +50,16 @@ func (r *RTPBuffer) Add(packet *RetainablePacket) { seq := packet.sequenceNumber if !r.started { r.packets[seq%r.size] = packet - r.lastAdded = seq + r.highestAdded = seq r.started = true return } - diff := seq - r.lastAdded + diff := seq - r.highestAdded if diff == 0 { return } else if diff < Uint16SizeHalf { - for i := r.lastAdded + 1; i != seq; i++ { + for i := r.highestAdded + 1; i != seq; i++ { idx := i % r.size prevPacket := r.packets[idx] if prevPacket != nil { @@ -67,7 +67,7 @@ func (r *RTPBuffer) Add(packet *RetainablePacket) { } r.packets[idx] = nil } - r.lastAdded = seq + r.highestAdded = seq } idx := seq % r.size @@ -80,7 +80,7 @@ func (r *RTPBuffer) Add(packet *RetainablePacket) { // Get returns the RetainablePacket for the requested sequence number func (r *RTPBuffer) Get(seq uint16) *RetainablePacket { - diff := r.lastAdded - seq + diff := r.highestAdded - seq if diff >= Uint16SizeHalf { return nil }