mirror of https://bitbucket.org/ausocean/av.git
trying to slow things down a little
This commit is contained in:
parent
2289bb8e5a
commit
5bb2bcc5f6
|
@ -392,11 +392,9 @@ func (r *revid) outputClips() {
|
||||||
}
|
}
|
||||||
// So that we don't fill up the log, once we reach the maxSendFailedErrorCount
|
// So that we don't fill up the log, once we reach the maxSendFailedErrorCount
|
||||||
// we will add some delay to slow things down until we have a connection again
|
// we will add some delay to slow things down until we have a connection again
|
||||||
if errorCount > maxSendFailedErrorCount {
|
time.Sleep(time.Duration(sendFailedDelay) * time.Second)
|
||||||
time.Sleep(time.Duration(sendFailedDelay) * time.Second)
|
|
||||||
}
|
|
||||||
r.Log(Error, err2.Error())
|
r.Log(Error, err2.Error())
|
||||||
if r.config.Output == NativeRtmp && errorCount > 10 {
|
if r.config.Output == NativeRtmp {
|
||||||
r.rtmpInst.EndSession()
|
r.rtmpInst.EndSession()
|
||||||
r.rtmpInst = rtmp.NewRTMPSession(r.config.RtmpUrl, rtmpConnectionTimout)
|
r.rtmpInst = rtmp.NewRTMPSession(r.config.RtmpUrl, rtmpConnectionTimout)
|
||||||
err = r.rtmpInst.StartSession()
|
err = r.rtmpInst.StartSession()
|
||||||
|
|
Loading…
Reference in New Issue