-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
- }
- }
- }
- }
- return nil, nil, nil, nil, err
-}
-
-func serveSBI(triggerSBI <-chan bool, sbiEngine sbi.Engine, sdlEngine sdl.Engine, rpeEngine rpe.Engine, m *sync.Mutex) {
- for {
- if <-triggerSBI {
- m.Lock()
- data, err := sdlEngine.ReadAll(xapp.Config.GetString("rtfile"))
- m.Unlock()
- if err != nil || data == nil {
- xapp.Logger.Error("Cannot get data from sdl interface due to: " + err.Error())
- continue
- }
- 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())
- }
- }
- }
-}
-
-func serve(nbiEngine nbi.Engine, sbiEngine sbi.Engine, sdlEngine sdl.Engine, rpeEngine rpe.Engine, m *sync.Mutex) {
-
- triggerSBI := make(chan bool)
-
- nbiErr := nbiEngine.Initialize(xapp.Config.GetString("xmurl"), xapp.Config.GetString("nbiurl"), xapp.Config.GetString("rtfile"), xapp.Config.GetString("cfgfile"),
- sdlEngine, rpeEngine, triggerSBI, m)
- if nbiErr != nil {
- xapp.Logger.Error("Failed to initialize nbi due to: " + nbiErr.Error())
- return
- }
-
- err := sbiEngine.Initialize(xapp.Config.GetString("sbiurl"))
- if err != nil {
- 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, m)
-
- for {
- if xapp.Config.GetString("nbi") == "httpGetter" {
- data, err := nbiEngine.(*nbi.HttpGetter).FetchAllXApps(xapp.Config.GetString("xmurl"))
- if err != nil {
- xapp.Logger.Error("Cannot fetch xapp data due to: " + err.Error())
- } else if data != nil {
- sdlEngine.WriteXApps(xapp.Config.GetString("rtfile"), data)
- }
- }
-
- triggerSBI <- true
-
- time.Sleep(INTERVAL * time.Second)
- xapp.Logger.Debug("Periodic loop timed out. Setting triggerSBI flag to distribute updated routes.")
- }
-}