From 0ae39fd72a5fd1a17758a2958839fae9055cb247 Mon Sep 17 00:00:00 2001 From: Xavier Drudis Date: Thu, 2 Jan 2025 08:13:44 -0800 Subject: [PATCH] Revert "IVF writer fix invalid timestamp into headers" This reverts commit 4f40756d9c2500efc24244a518f134dab580cbb0. --- pkg/media/ivfwriter/ivfwriter.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/media/ivfwriter/ivfwriter.go b/pkg/media/ivfwriter/ivfwriter.go index 6af42ce5414..49911ebba9a 100644 --- a/pkg/media/ivfwriter/ivfwriter.go +++ b/pkg/media/ivfwriter/ivfwriter.go @@ -109,10 +109,10 @@ func (i *IVFWriter) writeHeader() error { return err } -func (i *IVFWriter) writeFrame(frame []byte, timestamp uint64) error { +func (i *IVFWriter) writeFrame(frame []byte) error { frameHeader := make([]byte, 12) binary.LittleEndian.PutUint32(frameHeader[0:], uint32(len(frame))) // Frame length - binary.LittleEndian.PutUint64(frameHeader[4:], timestamp) // PTS + binary.LittleEndian.PutUint64(frameHeader[4:], i.count) // PTS i.count++ if _, err := i.ioWriter.Write(frameHeader); err != nil { @@ -153,7 +153,7 @@ func (i *IVFWriter) WriteRTP(packet *rtp.Packet) error { return nil } - if err := i.writeFrame(i.currentFrame, uint64(packet.Header.Timestamp)); err != nil { + if err := i.writeFrame(i.currentFrame); err != nil { return err } i.currentFrame = nil @@ -169,7 +169,7 @@ func (i *IVFWriter) WriteRTP(packet *rtp.Packet) error { } for j := range obus { - if err := i.writeFrame(obus[j], uint64(packet.Header.Timestamp)); err != nil { + if err := i.writeFrame(obus[j]); err != nil { return err } }