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

pktreorder: add debug print

Browse Source
This commit is contained in:
nareix 2016-06-07 18:15:08 +08:00
parent ca45b8cc97
commit e81f77b92d
1 changed files with 18 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
pktreorder/pktreorder.go
View File

@ -2,9 +2,12 @@ package pktreorder
import ( import (
"github.com/nareix/av" "github.com/nareix/av"
"fmt"
"io" "io"
) )
const debug = false
type stream struct { type stream struct {
isVideo bool isVideo bool
pkts []av.Packet pkts []av.Packet
@ -36,8 +39,10 @@ func (self *Queue) chooseStream() (chosen int) {
minpos = stream.pos minpos = stream.pos
chosen = i chosen = i
} }
if debug {
fmt.Println("pktreorder: chooseStream", "flush", flush, "i", i, "pkts", len(stream.pkts))
}
} }
return return
} }
@ -72,6 +77,10 @@ func (self *Queue) ReadPacket() (i int, pkt av.Packet, err error) {
} }
func (self *Queue) WritePacket(i int, pkt av.Packet) (err error) { func (self *Queue) WritePacket(i int, pkt av.Packet) (err error) {
if debug {
fmt.Println("pktreorder: WritePacket", "i", i, "Duration", fmt.Sprintf("%.2f", pkt.Duration))
}
stream := self.streams[i] stream := self.streams[i]
stream.pkts = append(stream.pkts, pkt) stream.pkts = append(stream.pkts, pkt)
self.pktnr++ self.pktnr++
@ -89,6 +98,10 @@ func (self *Queue) CanReadPacket() bool {
return true return true
} }
func (self *Queue) CanWritePacket() bool {
return self.err == nil
}
func (self *Queue) EndWritePacket(err error) { func (self *Queue) EndWritePacket(err error) {
if err == nil { if err == nil {
err = io.EOF err = io.EOF
@ -96,3 +109,7 @@ func (self *Queue) EndWritePacket(err error) {
self.err = err self.err = err
} }
func (self *Queue) Error() error {
return self.err
}