X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=pkg%2Fnbi%2Fcontrol.go;h=8d9e6c40a5b7d07dc5416dabd99beba46f08cbf6;hb=d14518e192178f0df3dc52bd804a9d0cc600bac7;hp=04c71a4f4aa32a2a95de863048415329fcf1eaf4;hpb=df23f25ac56eb0076e6e8801bb6080468ccf44b6;p=ric-plt%2Frtmgr.git

diff --git a/pkg/nbi/control.go b/pkg/nbi/control.go
index 04c71a4..8d9e6c4 100644
--- a/pkg/nbi/control.go
+++ b/pkg/nbi/control.go
@@ -25,55 +25,53 @@ package nbi
 import "C"
 
 import (
-        "errors"
-        "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
-        "strconv"
+	"errors"
+	"gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
 	"routing-manager/pkg/rpe"
 	"routing-manager/pkg/rtmgr"
-	"routing-manager/pkg/sdl"
 	"routing-manager/pkg/sbi"
+	"routing-manager/pkg/sdl"
+	"strconv"
 	"sync"
 )
 
-
 func NewControl() Control {
 
-        return Control{make(chan *xapp.RMRParams)}
+	return Control{make(chan *xapp.RMRParams)}
 }
 
-
 type Control struct {
-        rcChan      chan *xapp.RMRParams
+	rcChan chan *xapp.RMRParams
 }
 
-
 func (c *Control) Run(sbiEngine sbi.Engine, sdlEngine sdl.Engine, rpeEngine rpe.Engine, m *sync.Mutex) {
-        go c.controlLoop(sbiEngine, sdlEngine, rpeEngine, m)
-        xapp.Run(c)
+	go c.controlLoop(sbiEngine, sdlEngine, rpeEngine, m)
+	xapp.Run(c)
 }
 
 func (c *Control) Consume(rp *xapp.RMRParams) (err error) {
-        c.rcChan <- rp
-        return
+	c.rcChan <- rp
+	return
 }
 
 func (c *Control) controlLoop(sbiEngine sbi.Engine, sdlEngine sdl.Engine, rpeEngine rpe.Engine, m *sync.Mutex) {
 	for {
 		msg := <-c.rcChan
+		xapp_msg := sbi.RMRParams{msg}
 		switch msg.Mtype {
 		case xapp.RICMessageTypes["RMRRM_REQ_TABLE"]:
-			if (rtmgr.Rtmgr_ready == false) {
-					xapp.Logger.Info("Update Route Table Request(RMR to RM), message discarded as routing manager is not ready")
+			if rtmgr.Rtmgr_ready == false {
+				xapp.Logger.Info("Update Route Table Request(RMR to RM), message discarded as routing manager is not ready")
 			} else {
-					xapp.Logger.Info("Update Route Table Request(RMR to RM)")
+				xapp.Logger.Info("Update Route Table Request(RMR to RM)")
 				go c.handleUpdateToRoutingManagerRequest(msg, sbiEngine, sdlEngine, rpeEngine, m)
 			}
 		case xapp.RICMessageTypes["RMRRM_TABLE_STATE"]:
-		       xapp.Logger.Info("state of table to route mgr %v", msg)
+			xapp.Logger.Info("state of table to route mgr %s,payload %s", xapp_msg.String(), msg.Payload)
 
 		default:
-		        err := errors.New("Message Type " + strconv.Itoa(msg.Mtype) + " is discarded")
-		        xapp.Logger.Error("Unknown message type: %v", err)
+			err := errors.New("Message Type " + strconv.Itoa(msg.Mtype) + " is discarded")
+			xapp.Logger.Error("Unknown message type: %v", err)
 		}
 	}
 }
@@ -95,7 +93,7 @@ func (c *Control) handleUpdateToRoutingManagerRequest(params *xapp.RMRParams, sb
 
 	ep := sbiEngine.CreateEndpoint(string(params.Payload))
 	if ep == nil {
-		xapp.Logger.Error("Update Routing Table Request can't handle due to end point %s is not avail in complete ep list: ",string(params.Payload))
+		xapp.Logger.Error("Update Routing Table Request can't handle due to end point %s is not avail in complete ep list: ", string(params.Payload))
 		return
 	}