mirror
/
av
mirror of https://bitbucket.org/ausocean/av.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

mts: made psi counter max packet interval const

This commit is contained in:
saxon 2018-11-21 00:51:57 +10:30
parent 7a1c628731
commit 2ff7e6318d
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
stream/mts/encoder.go
View File

@ -38,7 +38,10 @@ import (
"bitbucket.org/ausocean/av/stream/mts/pes" "bitbucket.org/ausocean/av/stream/mts/pes"
) )
const psiPacketSize = 184 const (
psiPacketSize = 184
psiSendCount = 100
)
// TODO: really need to finish the at and pmt stuff - this is too hacky // TODO: really need to finish the at and pmt stuff - this is too hacky
var ( var (
@ -197,7 +200,7 @@ const (
// generate handles the incoming data and generates equivalent mpegts packets - // generate handles the incoming data and generates equivalent mpegts packets -
// sending them to the output channel // sending them to the output channel
func (e *Encoder) Encode(nalu []byte) error { func (e *Encoder) Encode(nalu []byte) error {
if e.psiCount == 0 { if e.psiCount <= 0 {
// Write PAT // Write PAT
patPkt := Packet{ patPkt := Packet{
PUSI: true, PUSI: true,
@ -223,7 +226,7 @@ func (e *Encoder) Encode(nalu []byte) error {
if err != nil { if err != nil {
return err return err
} }
e.psiCount = 100 e.psiCount = psiSendCount
} }
e.psiCount -= 1 e.psiCount -= 1
// Prepare PES data. // Prepare PES data.