diff --git a/revid/Revid.go b/revid/Revid.go index 6313ba76..16330691 100644 --- a/revid/Revid.go +++ b/revid/Revid.go @@ -382,6 +382,7 @@ func (r *revid) outputClips() { r.Log(Debug,"About to send!") err2 := r.sendClip(clip) r.Log(Debug,"Finished send!") + for ; err2 != nil; errorCount++ { r.Log(Warning, "Send failed trying again!") // If the clip size is not bigger than the threshold then we classify @@ -402,6 +403,7 @@ func (r *revid) outputClips() { r.Log(Error, err2.Error()) if r.config.Output == NativeRtmp && errorCount > 10 { r.rtmpInst.EndSession() + r.rtmpInst = rtmp.NewRTMPSession(r.config.RtmpUrl, rtmpConnectionTimout) err = r.rtmpInst.StartSession() } }