kunmeng/vdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix ContinuityCounter bug

Browse Source
This commit is contained in:
deepch
2022-07-16 16:02:21 +03:00
parent 37a9a8619c
commit 31d128e853
1 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
format/ts/muxer.go
View File

@@ -67,11 +67,16 @@ func (self *Muxer) newStream(idx int, codec av.CodecData) (err error) {
return return
} }
func (self *Muxer) writePaddingTSPackets(tsw *tsio.TSWriter) (err error) { func (self *Muxer) writePaddingTSPackets(streamW *Stream) (err error) {
for tsw.ContinuityCounter&0xf != 0x0 { for streamW.tsw.ContinuityCounter&0xf != 0x0 {
if err = tsw.WritePackets(self.w, self.datav[:1], 0, false, true); err != nil { header := tsio.TSHeader{
PID: uint(streamW.pid),
ContinuityCounter: streamW.tsw.ContinuityCounter,
}
if _, err = tsio.WriteTSHeader(self.w, header, 0); err != nil {
return return
} }
streamW.tsw.ContinuityCounter++
} }
return return
} }
@@ -79,7 +84,7 @@ func (self *Muxer) writePaddingTSPackets(tsw *tsio.TSWriter) (err error) {
func (self *Muxer) WriteTrailer() (err error) { func (self *Muxer) WriteTrailer() (err error) {
if self.PaddingToMakeCounterCont { if self.PaddingToMakeCounterCont {
for _, stream := range self.streams { for _, stream := range self.streams {
if err = self.writePaddingTSPackets(stream.tsw); err != nil { if err = self.writePaddingTSPackets(stream); err != nil {
return return
} }
} }