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
}
}
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
}
if err != nil {
xapp.Logger.Error("Routing table cannot be published due to: " + err.Error())
return
- }
+ }*/
}
func sendRoutesToAll() (err error) {