Open RMR connection in a new thread

[ric-plt/rtmgr.git] / cmd / rtmgr.go

diff --git a/cmd/rtmgr.go b/cmd/rtmgr.go
index 24b917c..c8ad5c6 100644 (file)
--- 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.
    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).
+
+

 ==================================================================================
 */
 /*
 ==================================================================================
 */
 /*


@@ -27,131 +33,55 @@
 package main
 
 //TODO: change flag to pflag (won't need any argument parse)
 package main
 
 //TODO: change flag to pflag (won't need any argument parse)

+

 import (
 import (

-       "flag"
+       "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"

        "os"
        "os/signal"
        "routing-manager/pkg/nbi"
        "os"
        "os/signal"
        "routing-manager/pkg/nbi"

-       "routing-manager/pkg/rpe"
+       //"routing-manager/pkg/rpe"

        "routing-manager/pkg/rtmgr"
        "routing-manager/pkg/rtmgr"

-       "routing-manager/pkg/sbi"
-       "routing-manager/pkg/sdl"
+       //"routing-manager/pkg/sbi"
+       //"routing-manager/pkg/sdl"

        "syscall"
        "time"
 )
 
 const SERVICENAME = "rtmgr"
        "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
 
 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() {
                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()
        SetupCloseHandler()

-       rtmgr.Logger.Info("Start " + SERVICENAME + " service")
+
+       xapp.Logger.Info("Start " + SERVICENAME + " service")

        rtmgr.Eps = make(rtmgr.Endpoints)
        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)
+
+       nbi.Serve()

        os.Exit(0)
 }
        os.Exit(0)
 }