External/mediamtx
1
0
Fork 1
mirror of https://github.com/bluenviron/mediamtx.git synced 2025-12-28 14:02:02 -08:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

update gortsplib (#1571)

Browse source
This commit is contained in:
Alessandro Ros 2023-03-14 18:24:33 +01:00 • committed by GitHub
parent ed45a09800
commit 33b72c5018
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
8 changed files with 18 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

4
internal/formatprocessor/h264.go
View file

@ -237,7 +237,7 @@ func (t *formatProcessorH264) Process(unit Unit, hasNonRTSPReaders bool) error {
}
// DecodeUntilMarker() is necessary, otherwise Encode() generates partial groups
au, PTS, err := t.decoder.DecodeUntilMarker(pkt)
au, pts, err := t.decoder.DecodeUntilMarker(pkt)
if err != nil {
if err == rtph264.ErrNonStartingPacketAndNoPrevious || err == rtph264.ErrMorePacketsNeeded {
return nil
@ -246,7 +246,7 @@ func (t *formatProcessorH264) Process(unit Unit, hasNonRTSPReaders bool) error {
}
tunit.AU = au
tunit.PTS = PTS
tunit.PTS = pts
tunit.AU = t.remuxAccessUnit(tunit.AU)
}

4
internal/formatprocessor/h265.go
View file

@ -258,7 +258,7 @@ func (t *formatProcessorH265) Process(unit Unit, hasNonRTSPReaders bool) error {
}
// DecodeUntilMarker() is necessary, otherwise Encode() generates partial groups
au, PTS, err := t.decoder.DecodeUntilMarker(pkt)
au, pts, err := t.decoder.DecodeUntilMarker(pkt)
if err != nil {
if err == rtph265.ErrNonStartingPacketAndNoPrevious || err == rtph265.ErrMorePacketsNeeded {
return nil
@ -267,7 +267,7 @@ func (t *formatProcessorH265) Process(unit Unit, hasNonRTSPReaders bool) error {
}
tunit.AU = au
tunit.PTS = PTS
tunit.PTS = pts
tunit.AU = t.remuxAccessUnit(tunit.AU)
}

4
internal/formatprocessor/mpeg4audio.go
View file

@ -69,7 +69,7 @@ func (t *formatProcessorMPEG4Audio) Process(unit Unit, hasNonRTSPReaders bool) e
t.decoder = t.format.CreateDecoder()
}
aus, PTS, err := t.decoder.Decode(pkt)
aus, pts, err := t.decoder.Decode(pkt)
if err != nil {
if err == rtpmpeg4audio.ErrMorePacketsNeeded {
return nil
@ -78,7 +78,7 @@ func (t *formatProcessorMPEG4Audio) Process(unit Unit, hasNonRTSPReaders bool) e
}
tunit.AUs = aus
tunit.PTS = PTS
tunit.PTS = pts
}
// route packet as is

4
internal/formatprocessor/opus.go
View file

@ -69,13 +69,13 @@ func (t *formatProcessorOpus) Process(unit Unit, hasNonRTSPReaders bool) error {
t.decoder = t.format.CreateDecoder()
}
frame, PTS, err := t.decoder.Decode(pkt)
frame, pts, err := t.decoder.Decode(pkt)
if err != nil {
return err
}
tunit.Frame = frame
tunit.PTS = PTS
tunit.PTS = pts
}
// route packet as is

4
internal/formatprocessor/vp8.go
View file

@ -69,7 +69,7 @@ func (t *formatProcessorVP8) Process(unit Unit, hasNonRTSPReaders bool) error {
t.decoder = t.format.CreateDecoder()
}
frame, PTS, err := t.decoder.Decode(pkt)
frame, pts, err := t.decoder.Decode(pkt)
if err != nil {
if err == rtpvp8.ErrMorePacketsNeeded {
return nil
@ -78,7 +78,7 @@ func (t *formatProcessorVP8) Process(unit Unit, hasNonRTSPReaders bool) error {
}
tunit.Frame = frame
tunit.PTS = PTS
tunit.PTS = pts
}
// route packet as is

4
internal/formatprocessor/vp9.go
View file

@ -69,7 +69,7 @@ func (t *formatProcessorVP9) Process(unit Unit, hasNonRTSPReaders bool) error {
t.decoder = t.format.CreateDecoder()
}
frame, PTS, err := t.decoder.Decode(pkt)
frame, pts, err := t.decoder.Decode(pkt)
if err != nil {
if err == rtpvp9.ErrMorePacketsNeeded {
return nil
@ -78,7 +78,7 @@ func (t *formatProcessorVP9) Process(unit Unit, hasNonRTSPReaders bool) error {
}
tunit.Frame = frame
tunit.PTS = PTS
tunit.PTS = pts
}
// route packet as is