X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=cmd%2Frtmgr.go;h=834df26d15bfb386a2e00676b565d962cc923a8e;hb=bfeca7737cc003f149ca8b01d1aaf484dcb762d7;hp=24b917c4ee696f05ded1c551cbdff4a7028c9883;hpb=aaf8d396257a455247b24716a32b05fc3fd145c2;p=ric-plt%2Frtmgr.git diff --git a/cmd/rtmgr.go b/cmd/rtmgr.go index 24b917c..834df26 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,132 +32,56 @@ */ 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" - "routing-manager/pkg/rpe" + "routing-manager/pkg/nbi/restful" "routing-manager/pkg/rtmgr" - "routing-manager/pkg/sbi" - "routing-manager/pkg/sdl" "syscall" "time" ) 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", "httpRESTful", "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") - args["rpe"] = flag.String("rpe", "rmrpush", "Route Policy Engine to be used. Valid values are: 'rmrpush'") - args["sdl"] = flag.String("sdl", "file", "Data store engine 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 | TRACE") - flag.Parse() -} - -func initRtmgr() (nbiEngine nbi.Engine, sbiEngine sbi.Engine, sdlEngine sdl.Engine, rpeEngine rpe.Engine, err error) { - if nbiEngine, err = nbi.GetNbi(*args["nbi"]); err == nil && nbiEngine != nil { - if sbiEngine, err = sbi.GetSbi(*args["sbi"]); err == nil && sbiEngine != nil { - if sdlEngine, err = sdl.GetSdl(*args["sdl"]); err == nil && sdlEngine != nil { - if rpeEngine, err = rpe.GetRpe(*args["rpe"]); err == nil && rpeEngine != nil { - return nbiEngine, sbiEngine, sdlEngine, rpeEngine, nil - } - } - } - } - return nil, nil, nil, nil, err -} - -func serveSBI(triggerSBI <-chan bool, sbiEngine sbi.Engine, sdlEngine sdl.Engine, rpeEngine rpe.Engine) { - for { - if <-triggerSBI { - data, err := sdlEngine.ReadAll(*args["filename"]) - if err != nil || data == nil { - rtmgr.Logger.Error("Cannot get data from sdl interface due to: " + err.Error()) - continue - } - sbiEngine.UpdateEndpoints(data) - policies := rpeEngine.GeneratePolicies(rtmgr.Eps) - err = sbiEngine.DistributeAll(policies) - if err != nil { - rtmgr.Logger.Error("Routing table cannot be published due to: " + err.Error()) - } - } - } -} - -func serve(nbiEngine nbi.Engine, sbiEngine sbi.Engine, sdlEngine sdl.Engine, rpeEngine rpe.Engine) { - - triggerSBI := make(chan bool) - - nbiErr := nbiEngine.Initialize(*args["xm-url"], *args["nbi-if"], *args["filename"], *args["configfile"], - sdlEngine, rpeEngine, triggerSBI) - if nbiErr != nil { - rtmgr.Logger.Error("Failed to initialize nbi due to: " + nbiErr.Error()) - return - } - - err := sbiEngine.Initialize(*args["sbi-if"]) - if err != nil { - rtmgr.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) - - for { - time.Sleep(INTERVAL * time.Second) - if *args["nbi"] == "httpGetter" { - data, err := nbiEngine.(*nbi.HttpGetter).FetchAllXApps(*args["xm-url"]) - if err != nil { - rtmgr.Logger.Error("Cannot fetch xapp data due to: " + err.Error()) - } else if data != nil { - sdlEngine.WriteXApps(*args["filename"], data) - } - } - - triggerSBI <- true - } -} func SetupCloseHandler() { c := make(chan os.Signal, 2) 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()) - 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.Mtype = make(rtmgr.MessageTypeList) + rtmgr.Rtmgr_ready = false + rtmgr.RMRConnStatus = make(map[string]bool) + + // RMR thread is starting port: 4560 + c := nbi.NewControl() + go c.Run() + + // 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("rtmgr:4560")) + xapp.Logger.Info("created dummy Wormhole ID for routingmanager and dummy_whid :%d", dummy_whid) + + go func() { + restful.LaunchRest(xapp.Config.GetString("nbiurl")) + }() + + nbi.Serve() os.Exit(0) }