X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=cmd%2Frtmgr.go;h=63b67b739cb85b647e0a486adbd0f41b7b1f5a2f;hb=0baa70de661cc0bb5065a604701dee33df8d92ef;hp=f2b39033f5f0c8563fa29846b1203aaa96f3346e;hpb=92162653c9741f2417d1a36ec1c211d6863d0a68;p=ric-plt%2Frtmgr.git diff --git a/cmd/rtmgr.go b/cmd/rtmgr.go index f2b3903..63b67b7 100644 --- a/cmd/rtmgr.go +++ b/cmd/rtmgr.go @@ -14,6 +14,12 @@ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. + + + This source code is part of the near-RT RIC (RAN Intelligent Controller) + platform project (RICP). + + ================================================================================== */ /* @@ -26,8 +32,10 @@ */ package main +//TODO: change flag to pflag (won't need any argument parse) + import ( - "flag" + "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp" "os" "os/signal" "routing-manager/pkg/nbi" @@ -37,42 +45,18 @@ import ( "routing-manager/pkg/sdl" "syscall" "time" + "sync" ) const SERVICENAME = "rtmgr" -const INTERVAL time.Duration = 2 - -var ( - args map[string]*string -) - -func parseArgs() { - // TODO: arguments should be validated (filename; xm-url; sbi-if; rest-url; rest-port) - args = make(map[string]*string) - args["configfile"] = flag.String("configfile", "/etc/rtmgrcfg.json", "Routing manager's configuration file path") - args["nbi"] = flag.String("nbi", "httpGetter", "Northbound interface module to be used. Valid values are: 'httpGetter | httpRESTful'") - args["sbi"] = flag.String("sbi", "nngpush", "Southbound interface module to be used. Valid values are: 'nngpush | nngpub'") - args["rpe"] = flag.String("rpe", "rmrpush", "Route Policy Engine to be used. Valid values are: 'rmrpush | rmrpub'") - args["sdl"] = flag.String("sdl", "file", "Datastore enginge to be used. Valid values are: 'file'") - args["xm-url"] = flag.String("xm-url", "http://localhost:3000/xapps", "HTTP URL where xApp Manager exposes the entire xApp List") - args["nbi-if"] = flag.String("nbi-if", "http://localhost:8888", "Base HTTP URL where routing manager will be listening on") - args["sbi-if"] = flag.String("sbi-if", "0.0.0.0", "IPv4 address of interface where Southbound socket to be opened") - args["filename"] = flag.String("filename", "/db/rt.json", "Absolute path of file where the route information to be stored") - args["loglevel"] = flag.String("loglevel", "INFO", "INFO | WARN | ERROR | DEBUG") - flag.Parse() -} - -func initRtmgr() (nbi.NbiEngine, sbi.SbiEngine, sdl.SdlEngine, rpe.RpeEngine, error) { - var err error - var nbii nbi.NbiEngine - var sbii sbi.SbiEngine - var sdli sdl.SdlEngine - var rpei rpe.RpeEngine - if nbii, err = nbi.GetNbi(*args["nbi"]); err == nil && nbii != nil { - if sbii, err = sbi.GetSbi(*args["sbi"]); err == nil && sbii != nil { - if sdli, err = sdl.GetSdl(*args["sdl"]); err == nil && sdli != nil { - if rpei, err = rpe.GetRpe(*args["rpe"]); err == nil && rpei != nil { - return nbii, sbii, sdli, rpei, nil +const INTERVAL time.Duration = 60 + +func initRtmgr() (nbiEngine nbi.Engine, sbiEngine sbi.Engine, sdlEngine sdl.Engine, rpeEngine rpe.Engine, err error) { + if nbiEngine, err = nbi.GetNbi(xapp.Config.GetString("nbi")); err == nil && nbiEngine != nil { + if sbiEngine, err = sbi.GetSbi(xapp.Config.GetString("sbi")); err == nil && sbiEngine != nil { + if sdlEngine, err = sdl.GetSdl(xapp.Config.GetString("sdl")); err == nil && sdlEngine != nil { + if rpeEngine, err = rpe.GetRpe(xapp.Config.GetString("rpe")); err == nil && rpeEngine != nil { + return nbiEngine, sbiEngine, sdlEngine, rpeEngine, nil } } } @@ -80,58 +64,82 @@ func initRtmgr() (nbi.NbiEngine, sbi.SbiEngine, sdl.SdlEngine, rpe.RpeEngine, er return nil, nil, nil, nil, err } -func serveSBI(triggerSBI <-chan bool, sbiEngine sbi.SbiEngine, sdlEngine sdl.SdlEngine, rpeEngine rpe.RpeEngine) { + + +func serveSBI(triggerSBI <-chan bool, sbiEngine sbi.Engine, sdlEngine sdl.Engine, rpeEngine rpe.Engine, m *sync.Mutex) { for { if <-triggerSBI { - data, err := sdlEngine.ReadAll(*args["filename"]) + m.Lock() + data, err := sdlEngine.ReadAll(xapp.Config.GetString("rtfile")) + m.Unlock() if err != nil || data == nil { - rtmgr.Logger.Error("cannot get data from sdl interface due to: " + err.Error()) + xapp.Logger.Error("Cannot get data from sdl interface due to: " + err.Error()) continue } sbiEngine.UpdateEndpoints(data) - policies := rpeEngine.GeneratePolicies(rtmgr.Eps) + policies := rpeEngine.GeneratePolicies(rtmgr.Eps, data) err = sbiEngine.DistributeAll(policies) if err != nil { - rtmgr.Logger.Error("routing rable cannot be published due to: " + err.Error()) + xapp.Logger.Error("Routing table cannot be published due to: " + err.Error()) } } } } -func serve(nbiEngine nbi.NbiEngine, sbiEngine sbi.SbiEngine, sdlEngine sdl.SdlEngine, rpeEngine rpe.RpeEngine) { +func sendRoutesToAll(sbiEngine sbi.Engine, sdlEngine sdl.Engine, rpeEngine rpe.Engine) { + + data, err := sdlEngine.ReadAll(xapp.Config.GetString("rtfile")) + if err != nil || data == nil { + xapp.Logger.Error("Cannot get data from sdl interface due to: " + err.Error()) + return + } + sbiEngine.UpdateEndpoints(data) + policies := rpeEngine.GeneratePolicies(rtmgr.Eps, data) + err = sbiEngine.DistributeAll(policies) + if err != nil { + xapp.Logger.Error("Routing table cannot be published due to: " + err.Error()) + return + } +} + + +func serve(nbiEngine nbi.Engine, sbiEngine sbi.Engine, sdlEngine sdl.Engine, rpeEngine rpe.Engine, m *sync.Mutex) { triggerSBI := make(chan bool) - nbiErr := nbiEngine.Initialize(*args["xm-url"], *args["nbi-if"], *args["filename"], *args["configfile"], - sdlEngine, rpeEngine, triggerSBI) + nbiErr := nbiEngine.Initialize(xapp.Config.GetString("xmurl"), xapp.Config.GetString("nbiurl"), xapp.Config.GetString("rtfile"), xapp.Config.GetString("cfgfile"), xapp.Config.GetString("e2murl"), + sdlEngine, rpeEngine, triggerSBI, m) if nbiErr != nil { - rtmgr.Logger.Error("fail to initialize nbi due to: " + nbiErr.Error()) + xapp.Logger.Error("Failed to initialize nbi due to: " + nbiErr.Error()) return } - err := sbiEngine.Initialize(*args["sbi-if"]) + err := sbiEngine.Initialize(xapp.Config.GetString("sbiurl")) if err != nil { - rtmgr.Logger.Info("fail to open pub socket due to: " + err.Error()) + xapp.Logger.Info("Failed to open push socket due to: " + err.Error()) return } defer nbiEngine.Terminate() defer sbiEngine.Terminate() // This SBI Go routine is trtiggered by periodic main loop and when data is recieved on REST interface. - go serveSBI(triggerSBI, sbiEngine, sdlEngine, rpeEngine) + go serveSBI(triggerSBI, sbiEngine, sdlEngine, rpeEngine, m) for { - time.Sleep(INTERVAL * time.Second) - if *args["nbi"] == "httpGetter" { - data, err := nbiEngine.(*nbi.HttpGetter).FetchAllXapps(*args["xm-url"]) + if xapp.Config.GetString("nbi") == "httpGetter" { + data, err := nbiEngine.(*nbi.HttpGetter).FetchAllXApps(xapp.Config.GetString("xmurl")) if err != nil { - rtmgr.Logger.Error("cannot fetch xapp data dute to: " + err.Error()) + xapp.Logger.Error("Cannot fetch xapp data due to: " + err.Error()) } else if data != nil { - sdlEngine.WriteXapps(*args["filename"], data) + sdlEngine.WriteXApps(xapp.Config.GetString("rtfile"), data) } } - triggerSBI <- true + sendRoutesToAll(sbiEngine, sdlEngine, rpeEngine) + + rtmgr.Rtmgr_ready = true + time.Sleep(INTERVAL * time.Second) + xapp.Logger.Debug("Periodic loop timed out. Setting triggerSBI flag to distribute updated routes.") } } @@ -140,22 +148,40 @@ func SetupCloseHandler() { signal.Notify(c, os.Interrupt, syscall.SIGTERM) go func() { <-c - rtmgr.Logger.Info("\r- Ctrl+C pressed in Terminal") + xapp.Logger.Info("\r- Ctrl+C pressed in Terminal") os.Exit(0) }() } func main() { - parseArgs() - rtmgr.SetLogLevel(*args["loglevel"]) + nbiEngine, sbiEngine, sdlEngine, rpeEngine, err := initRtmgr() if err != nil { - rtmgr.Logger.Error(err.Error()) + xapp.Logger.Error(err.Error()) os.Exit(1) } + SetupCloseHandler() - rtmgr.Logger.Info("Start " + SERVICENAME + " service") + + xapp.Logger.Info("Start " + SERVICENAME + " service") rtmgr.Eps = make(rtmgr.Endpoints) - serve(nbiEngine, sbiEngine, sdlEngine, rpeEngine) + rtmgr.Rtmgr_ready = false + + var m sync.Mutex + +// RMR thread is starting port: 4560 + c := nbi.NewControl() + go c.Run(sbiEngine, sdlEngine, rpeEngine, &m) + +// Waiting for RMR to be ready + time.Sleep(time.Duration(2) * time.Second) + for xapp.Rmr.IsReady() == false { + time.Sleep(time.Duration(2) * time.Second) + } + + dummy_whid := int(xapp.Rmr.Openwh("localhost:4560")) + xapp.Logger.Info("created dummy Wormhole ID for routingmanager and dummy_whid :%d", dummy_whid) + + serve(nbiEngine, sbiEngine, sdlEngine, rpeEngine, &m) os.Exit(0) }