thefoxon/joy4
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix demuxer bug

Browse Source
This commit is contained in:
nareix 2016-06-30 23:21:27 +08:00
parent 9ffa28a3fd
commit 93f7f62fad
2 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
demuxer.go
View File

@ -70,7 +70,7 @@ func (self *Demuxer) ReadPacket() (pkt av.Packet, err error) {
}
func (self *Demuxer) poll() (err error) {
for self.gotpkt {
for !self.gotpkt {
if err = self.readTSPacket(); err != nil {
return
}
@ -108,6 +108,7 @@ func (self *Demuxer) readTSPacket() (err error) {
stream.idx = i
stream.demuxer = self
stream.pid = info.ElementaryPID
stream.streamType = info.StreamType
switch info.StreamType {
case ElementaryStreamTypeH264:
self.streams = append(self.streams, stream)
@ -142,19 +143,21 @@ func (self *Stream) payloadEnd() (err error) {
dts = pts
}
self.pkt = av.Packet{
pkt := &self.demuxer.pkt
*pkt = av.Packet{
Idx: int8(self.idx),
IsKeyFrame: self.tshdr.RandomAccessIndicator,
Time: time.Duration(dts)*time.Second / time.Duration(PTS_HZ),
Data: payload,
}
if pts != dts {
self.pkt.CompositionTime = time.Duration(pts-dts)*time.Second / time.Duration(PTS_HZ)
pkt.CompositionTime = time.Duration(pts-dts)*time.Second / time.Duration(PTS_HZ)
}
self.demuxer.gotpkt = true
if self.CodecData == nil {
if self.streamType == ElementaryStreamTypeAdtsAAC {
switch self.streamType {
case ElementaryStreamTypeAdtsAAC:
var config aacparser.MPEG4AudioConfig
if config, _, _, _, err = aacparser.ReadADTSFrame(payload); err != nil {
err = fmt.Errorf("ReadADTSFrame failed: %s", err)
@ -168,7 +171,8 @@ func (self *Stream) payloadEnd() (err error) {
if self.CodecData, err = aacparser.NewCodecDataFromMPEG4AudioConfigBytes(bw.Bytes()); err != nil {
return
}
} else if self.streamType == ElementaryStreamTypeH264 {
case ElementaryStreamTypeH264:
if false {
fmt.Println(hex.Dump(payload))
}

1
stream.go
View File

@ -25,7 +25,6 @@ type Stream struct {
cacheSize int
idx int
pkt av.Packet
}
func timeToPesTs(tm time.Duration) uint64 {