zishuo/webrtc
1
0
Fork 0
mirror of https://github.com/pion/webrtc.git synced 2025-09-26 19:21:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

IVF writer fix invalid timestamp into headers

Browse Source
This commit is contained in:
Radek Gruchalski
2024-08-04 21:55:25 +02:00
committed by Eric Daniels
parent 8ec98b7c0d
commit 4f40756d9c
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/media/ivfwriter/ivfwriter.go
View File

@@ -109,10 +109,10 @@ func (i *IVFWriter) writeHeader() error {
return err
}
func (i *IVFWriter) writeFrame(frame []byte) error {
func (i *IVFWriter) writeFrame(frame []byte, timestamp uint64) error {
frameHeader := make([]byte, 12)
binary.LittleEndian.PutUint32(frameHeader[0:], uint32(len(frame))) // Frame length
binary.LittleEndian.PutUint64(frameHeader[4:], i.count) // PTS
binary.LittleEndian.PutUint64(frameHeader[4:], timestamp) // 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); err != nil {
if err := i.writeFrame(i.currentFrame, uint64(packet.Header.Timestamp)); 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]); err != nil {
if err := i.writeFrame(obus[j], uint64(packet.Header.Timestamp)); err != nil {
return err
}
}