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 37934ad..c8ad5c6 100644 (file)
--- a/cmd/rtmgr.go
+++ b/cmd/rtmgr.go
@@ -66,20 +66,20 @@ func main() {
        xapp.Logger.Info("Start " + SERVICENAME + " service")
        rtmgr.Eps = make(rtmgr.Endpoints)
        rtmgr.Mtype = make(rtmgr.MessageTypeList)
-       rtmgr.RmrEp = make(rtmgr.ProcessMultipleRMR)
        rtmgr.Rtmgr_ready = false
+       rtmgr.RMRConnStatus = make(map[string]bool)
 
-// RMR thread is starting port: 4560
+       // RMR thread is starting port: 4560
        c := nbi.NewControl()
        go c.Run()
 
-// Waiting for RMR to be ready
+       // 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)
+               time.Sleep(time.Duration(2) * time.Second)
        }
 
-       dummy_whid := int(xapp.Rmr.Openwh("localhost:4560"))
+       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()