Code Review
/
ric-plt
/
rtmgr.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Fixed integration and subscription routes related issues for R3
[ric-plt/rtmgr.git]
/
cmd
/
rtmgr.go
diff --git
a/cmd/rtmgr.go
b/cmd/rtmgr.go
index
101c743
..
568b7ad
100644
(file)
--- a/
cmd/rtmgr.go
+++ b/
cmd/rtmgr.go
@@
-47,7
+47,7
@@
import (
)
const SERVICENAME = "rtmgr"
)
const SERVICENAME = "rtmgr"
-const INTERVAL time.Duration =
2
+const INTERVAL time.Duration =
60
var (
args map[string]*string
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 {
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 {
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
}
triggerSBI <- true
+
+ time.Sleep(INTERVAL * time.Second)
+ rtmgr.Logger.Debug("Periodic loop timed out. Setting triggerSBI flag to distribute updated routes.")
}
}
}
}