X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=cmd%2Frtmgr.go;fp=cmd%2Frtmgr.go;h=568b7ad4f3287a10dcadc1bee2007106393e7d01;hb=b47d12de30e72b6e1017c93ca487279b09038e00;hp=101c74377313477923de7503f16695e877eac7bc;hpb=89c2cdeff5dc079ab1aca01e2e830a961095198f;p=ric-plt%2Frtmgr.git diff --git a/cmd/rtmgr.go b/cmd/rtmgr.go index 101c743..568b7ad 100644 --- a/cmd/rtmgr.go +++ b/cmd/rtmgr.go @@ -47,7 +47,7 @@ import ( ) const SERVICENAME = "rtmgr" -const INTERVAL time.Duration = 2 +const INTERVAL time.Duration = 60 var ( args map[string]*string @@ -123,7 +123,6 @@ func serve(nbiEngine nbi.Engine, sbiEngine sbi.Engine, sdlEngine sdl.Engine, rpe go serveSBI(triggerSBI, sbiEngine, sdlEngine, rpeEngine) for { - time.Sleep(INTERVAL * time.Second) if *args["nbi"] == "httpGetter" { data, err := nbiEngine.(*nbi.HttpGetter).FetchAllXApps(*args["xm-url"]) if err != nil { @@ -134,6 +133,9 @@ func serve(nbiEngine nbi.Engine, sbiEngine sbi.Engine, sdlEngine sdl.Engine, rpe } triggerSBI <- true + + time.Sleep(INTERVAL * time.Second) + rtmgr.Logger.Debug("Periodic loop timed out. Setting triggerSBI flag to distribute updated routes.") } }