mirror of https://bitbucket.org/ausocean/av.git
still trying to fix things
This commit is contained in:
parent
51b18fbaa7
commit
a416edfc74
|
@ -223,7 +223,7 @@ func main() {
|
||||||
config.IntraRefreshPeriod = *configFlags[intraRefreshPeriodPtr]
|
config.IntraRefreshPeriod = *configFlags[intraRefreshPeriodPtr]
|
||||||
|
|
||||||
// Also give the config a logger object
|
// Also give the config a logger object
|
||||||
config.Logger = smartLogger.New(loggerVerbosity, smartLogger.White)
|
// config.Logger = smartLogger.New(loggerVerbosity, smartLogger.White)
|
||||||
|
|
||||||
time.Sleep(time.Duration(prepTime) * time.Second)
|
time.Sleep(time.Duration(prepTime) * time.Second)
|
||||||
createRevidInstance()
|
createRevidInstance()
|
||||||
|
|
|
@ -314,7 +314,9 @@ func (r *revid) packClips() {
|
||||||
// Keep clearing output chan until out buffer has some space
|
// Keep clearing output chan until out buffer has some space
|
||||||
for clip, err = r.ringBuffer.Get(); err != nil; {
|
for clip, err = r.ringBuffer.Get(); err != nil; {
|
||||||
r.flushData()
|
r.flushData()
|
||||||
|
r.Log(Debug,"Ending rtmp session")
|
||||||
r.rtmpInst.EndSession()
|
r.rtmpInst.EndSession()
|
||||||
|
r.Log(Debug, "Creating new session")
|
||||||
r.rtmpInst = rtmp.NewRTMPSession(r.config.RtmpUrl, rtmpConnectionTimout)
|
r.rtmpInst = rtmp.NewRTMPSession(r.config.RtmpUrl, rtmpConnectionTimout)
|
||||||
rtmpError := r.rtmpInst.StartSession()
|
rtmpError := r.rtmpInst.StartSession()
|
||||||
if rtmpError != nil {
|
if rtmpError != nil {
|
||||||
|
|
Loading…
Reference in New Issue