Skip to content

Commit

Permalink
Revert "IVF writer fix invalid timestamp into headers"
Browse files Browse the repository at this point in the history
This reverts commit 4f40756.
  • Loading branch information
xdrudis authored and edaniels committed Jan 2, 2025
1 parent 92fce5f commit 0ae39fd
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions pkg/media/ivfwriter/ivfwriter.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down Expand Up @@ -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
Expand All @@ -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
}
}
Expand Down

0 comments on commit 0ae39fd

Please sign in to comment.