Code Review
/
ric-plt
/
rtmgr.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Unit test case correction
[ric-plt/rtmgr.git]
/
pkg
/
nbi
/
control.go
diff --git
a/pkg/nbi/control.go
b/pkg/nbi/control.go
index
0ab3f06
..
db6c405
100644
(file)
--- a/
pkg/nbi/control.go
+++ b/
pkg/nbi/control.go
@@
-136,26
+136,34
@@
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))
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
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
- }
*/
+ }
-
sbiEngine.CreateEndpoint(string(params.Payload),msg.String(
))
-
/*
if ep == nil {
+
ep := sbiEngine.CheckEndpoint(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))
return
}
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
}
+ epstr,whid := sbiEngine.CreateEndpoint(msg.String())
+ if epstr == nil || whid < 0 {
+ xapp.Logger.Error("Wormhole Id creation failed %d for %s",whid,msg.String() )
+ return
+ }
+ /*This is to ensure the latest routes are sent.
+ Assumption is that in this time interval the routes are built for this endpoint */
+ time.Sleep(100 * time.Millisecond)
policies := rpeEngine.GeneratePolicies(rtmgr.Eps, data)
policies := rpeEngine.GeneratePolicies(rtmgr.Eps, data)
- err = sbiEngine.DistributeToEp(policies,
ep
)
+ err = sbiEngine.DistributeToEp(policies,
*epstr, whid
)
if err != nil {
xapp.Logger.Error("Routing table cannot be published due to: " + err.Error())
return
if err != nil {
xapp.Logger.Error("Routing table cannot be published due to: " + err.Error())
return
- }
*/
+ }
}
func sendRoutesToAll() (err error) {
}
func sendRoutesToAll() (err error) {