X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=cmd%2Frtmgr.go;h=63b67b739cb85b647e0a486adbd0f41b7b1f5a2f;hb=0baa70de661cc0bb5065a604701dee33df8d92ef;hp=093da71bd75c4e2592d14c85ed3b61ca773791b8;hpb=16d84d6f7d3489e65e0a83ba9c0d5d62c3914c7f;p=ric-plt%2Frtmgr.git

diff --git a/cmd/rtmgr.go b/cmd/rtmgr.go
index 093da71..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,49 +32,31 @@
 */
 package main
 
+//TODO: change flag to pflag (won't need any argument parse)
+
 import (
-	"flag"
-	"nbi"
+	"gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
 	"os"
-	"rpe"
-	"rtmgr"
-	"sbi"
-	"sdl"
+	"os/signal"
+	"routing-manager/pkg/nbi"
+	"routing-manager/pkg/rpe"
+	"routing-manager/pkg/rtmgr"
+	"routing-manager/pkg/sbi"
+	"routing-manager/pkg/sdl"
+	"syscall"
 	"time"
+	"sync"
 )
 
 const SERVICENAME = "rtmgr"
-const INTERVAL time.Duration = 2
-
-var (
-	args map[string]*string
-)
+const INTERVAL time.Duration = 60
 
-func parseArgs() {
-	// TODO: arguments should be validated (filename; xm-url; sbi-if)
-	args = make(map[string]*string)
-	args["nbi"] = flag.String("nbi", "httpGetter", "Northbound interface module to be used. Valid values are: 'httpGetter'")
-	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["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.NbiEngineConfig, *sbi.SbiEngineConfig, *sdl.SdlEngineConfig, *rpe.RpeEngineConfig, error) {
-	var err error
-	var nbii *nbi.NbiEngineConfig
-	var sbii *sbi.SbiEngineConfig
-	var sdli *sdl.SdlEngineConfig
-	var rpei *rpe.RpeEngineConfig
-	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
+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
 				}
 			}
 		}
@@ -76,45 +64,124 @@ func initRtmgr() (*nbi.NbiEngineConfig, *sbi.SbiEngineConfig, *sdl.SdlEngineConf
 	return nil, nil, nil, nil, err
 }
 
-func serve(nbii *nbi.NbiEngineConfig, sbii *sbi.SbiEngineConfig, sdli *sdl.SdlEngineConfig, rpei *rpe.RpeEngineConfig) {
-	err := sbii.OpenSocket(*args["sbi-if"])
+
+
+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 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(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 {
+		xapp.Logger.Error("Failed to initialize nbi due to: " + nbiErr.Error())
+		return
+	}
+
+	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 sbii.CloseSocket()
+	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 {
-		time.Sleep(INTERVAL * time.Second)
-		data, err := nbii.BatchFetch(*args["xm-url"])
-		if err != nil {
-			rtmgr.Logger.Error("cannot get data from " + nbii.Engine.Name + " interface dute to: " + err.Error())
-		} else {
-			sdli.WriteAll(*args["filename"], data)
-		}
-		data, err = sdli.ReadAll(*args["filename"])
-		if err != nil || data == nil {
-			rtmgr.Logger.Error("cannot get data from " + sdli.Engine.Name + " interface dute to: " + err.Error())
-			continue
-		}
-		sbi.UpdateEndpointList(data, sbii)
-		policies := rpei.GeneratePolicies(rtmgr.Eps)
-		err = sbii.DistributeAll(policies)
-		if err != nil {
-			rtmgr.Logger.Error("routing rable cannot be published due to: " + err.Error())
+		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)
+			}
 		}
+
+		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.")
 	}
 }
 
+func SetupCloseHandler() {
+	c := make(chan os.Signal, 2)
+	signal.Notify(c, os.Interrupt, syscall.SIGTERM)
+	go func() {
+		<-c
+		xapp.Logger.Info("\r- Ctrl+C pressed in Terminal")
+		os.Exit(0)
+	}()
+}
+
 func main() {
-	parseArgs()
-	rtmgr.SetLogLevel(*args["loglevel"])
-	nbii, sbii, sdli, rpei, err := initRtmgr()
+
+	nbiEngine, sbiEngine, sdlEngine, rpeEngine, err := initRtmgr()
 	if err != nil {
-		rtmgr.Logger.Error(err.Error())
+		xapp.Logger.Error(err.Error())
 		os.Exit(1)
 	}
-	rtmgr.Logger.Info("Start " + SERVICENAME + " service")
+
+	SetupCloseHandler()
+
+	xapp.Logger.Info("Start " + SERVICENAME + " service")
 	rtmgr.Eps = make(rtmgr.Endpoints)
-	serve(nbii, sbii, sdli, rpei)
+	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)
 }