From 78501cce3f2f9f98b1b08f1dc549228e8a9105f1 Mon Sep 17 00:00:00 2001 From: David Colburn Date: Mon, 9 Sep 2024 15:32:14 -0700 Subject: [PATCH] update vp8Munger --- pkg/pipeline/source/sdk/translator.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/pkg/pipeline/source/sdk/translator.go b/pkg/pipeline/source/sdk/translator.go index 723cb73b..e148a9f5 100644 --- a/pkg/pipeline/source/sdk/translator.go +++ b/pkg/pipeline/source/sdk/translator.go @@ -62,7 +62,7 @@ func (t *VP8Translator) Translate(pkt *rtp.Packet) { extPkt := &buffer.ExtPacket{ Packet: pkt, - Arrival: time.Now(), + Arrival: time.Now().UnixNano(), Payload: vp8Packet, KeyFrame: vp8Packet.IsKeyFrame, VideoLayer: buffer.VideoLayer{ @@ -76,13 +76,14 @@ func (t *VP8Translator) Translate(pkt *rtp.Packet) { t.vp8Munger.SetLast(extPkt) } else { payload := make([]byte, 1460) - incomingHeaderSize, outgoingHeaderSize, err := t.vp8Munger.UpdateAndGet(extPkt, false, pkt.SequenceNumber != t.lastSN+1, extPkt.Temporal, payload) + incomingHeaderSize, header, err := t.vp8Munger.UpdateAndGet(extPkt, false, pkt.SequenceNumber != t.lastSN+1, extPkt.Temporal) if err != nil { t.logger.Warnw("could not update VP8 packet", err) return } - copy(payload[outgoingHeaderSize:], extPkt.Packet.Payload[incomingHeaderSize:]) - pkt.Payload = payload[:outgoingHeaderSize+len(extPkt.Packet.Payload)-incomingHeaderSize] + copy(payload, header) + n := copy(payload[len(header):], extPkt.Packet.Payload[incomingHeaderSize:]) + pkt.Payload = payload[:len(header)+n] } }