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

printing clearing output chan less

This commit is contained in:
Saxon1 2018-05-24 11:58:49 +09:30
parent e76deb3864
commit 8282cd3880
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
revid/Revid.go
View File

@ -339,18 +339,23 @@ done:
func (r *revid) packClips() { func (r *revid) packClips() {
clipSize := 0 clipSize := 0
packetCount := 0 packetCount := 0
outputChanFullFlag := false
for r.isRunning { for r.isRunning {
// Get some memory from the ring buffer for out clip // Get some memory from the ring buffer for out clip
var clip []byte var clip []byte
var err error var err error
if clip, err = r.ringBuffer.Get(); err != nil && r.isRunning { if clip, err = r.ringBuffer.Get(); err != nil && r.isRunning {
if !outputChanFullFlag {
r.Log(Error, err.Error()) r.Log(Error, err.Error())
r.Log(Warning, "Clearing output chan!") r.Log(Warning, "Clearing output chan!")
outputChanFullFlag = true
}
for clip, err = r.ringBuffer.Get(); err != nil && r.isRunning; { for clip, err = r.ringBuffer.Get(); err != nil && r.isRunning; {
time.Sleep(time.Duration(10) * time.Millisecond) time.Sleep(time.Duration(10) * time.Millisecond)
clip, err = r.ringBuffer.Get() clip, err = r.ringBuffer.Get()
} }
r.Log(Debug, "Finally got mem from ringbuffer!") r.Log(Debug, "Finally got mem from ringbuffer!")
outputChanFullFlag = false
} }
for r.isRunning { for r.isRunning {