m.Unlock()
updateEp()
return sendRoutesToAll()
+ //return sendPartialRoutesToAll(nil, rtmgr.XappType)
}
}
addSubscription(&rtmgr.Subs, data)
xapp.Logger.Debug("Endpoints: %v", rtmgr.Eps)
updateEp()
- return sendRoutesToAll()
+ return sendPartialRoutesToAll(data, rtmgr.SubsType)
}
func subscriptionExists(data *models.XappSubscriptionData) bool {
err, IsDuplicate := validateE2tData(data)
if IsDuplicate == true {
updateEp()
+ //return sendPartialRoutesToAll(nil, rtmgr.E2Type)
return sendRoutesToAll()
}
sdlEngine.WriteNewE2TInstance(xapp.Config.GetString("rtfile"), e2data, meiddata)
m.Unlock()
updateEp()
+ //sendPartialRoutesToAll(nil, rtmgr.E2Type)
sendRoutesToAll()
time.Sleep(10 * time.Second)
for ep, value := range rtmgr.RMRConnStatus {