X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fnbi%2Fcontrol.go;h=0ab3f069e3a055033ee10d536fb23ee93c8b52d5;hb=refs%2Fchanges%2F35%2F4535%2F1;hp=5cde1b0a3e7c4c2bf487dbee2f80f3fdba1b1182;hpb=8f7ca65ce6b2691e08bb3496c14fae88e32ad973;p=ric-plt%2Frtmgr.git diff --git a/pkg/nbi/control.go b/pkg/nbi/control.go index 5cde1b0..0ab3f06 100644 --- a/pkg/nbi/control.go +++ b/pkg/nbi/control.go @@ -77,7 +77,6 @@ func initRtmgr() (nbiEngine Engine, sbiEngine sbi.Engine, sdlEngine sdl.Engine, 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 { - fmt.Printf("%v,%v,%v,%v",nbiEngine, sbiEngine, sdlEngine, rpeEngine) return nbiEngine, sbiEngine, sdlEngine, rpeEngine, nil } } @@ -137,16 +136,16 @@ func (c *Control) handleUpdateToRoutingManagerRequest(params *xapp.RMRParams) { xapp.Logger.Info("Update Route Table Request, msg.String() : %s", msg.String()) xapp.Logger.Info("Update Route Table Request, params.Payload : %s", string(params.Payload)) - m.Lock() + /*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()) return - } + }*/ - ep := sbiEngine.CreateEndpoint(string(params.Payload)) - if ep == nil { + sbiEngine.CreateEndpoint(string(params.Payload),msg.String()) + /*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)) return } @@ -156,7 +155,7 @@ func (c *Control) handleUpdateToRoutingManagerRequest(params *xapp.RMRParams) { if err != nil { xapp.Logger.Error("Routing table cannot be published due to: " + err.Error()) return - } + }*/ } func sendRoutesToAll() (err error) {