mirror of https://bitbucket.org/ausocean/av.git
revid/revid.go: defer r.wg.Done() in revid.outputClips routine
This commit is contained in:
parent
a4d179039b
commit
de4f471201
|
@ -495,6 +495,7 @@ func (r *Revid) Update(vars map[string]string) error {
|
||||||
// outputClips takes the clips produced in the packClips method and outputs them
|
// outputClips takes the clips produced in the packClips method and outputs them
|
||||||
// to the desired output defined in the revid config
|
// to the desired output defined in the revid config
|
||||||
func (r *Revid) outputClips() {
|
func (r *Revid) outputClips() {
|
||||||
|
defer r.wg.Done()
|
||||||
lastTime := time.Now()
|
lastTime := time.Now()
|
||||||
var count int
|
var count int
|
||||||
loop:
|
loop:
|
||||||
|
@ -583,7 +584,6 @@ loop:
|
||||||
r.config.Logger.Log(logger.Error, pkg+"failed to close output"+strconv.Itoa(i)+" destination", "error", err.Error())
|
r.config.Logger.Log(logger.Error, pkg+"failed to close output"+strconv.Itoa(i)+" destination", "error", err.Error())
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
r.wg.Done()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// startRaspivid sets up things for input from raspivid i.e. starts
|
// startRaspivid sets up things for input from raspivid i.e. starts
|
||||||
|
|
Loading…
Reference in New Issue