if waitRouteClean > 0 {
// Wait here that response is delivered to xApp via RMR before route is cleaned
xapp.Logger.Debug("Pending %v in order to wait route cleanup", waitRouteClean)
+ r.mutex.Unlock()
time.Sleep(waitRouteClean)
+ r.mutex.Lock()
}
xapp.Logger.Debug("CLEAN %s", subs.String())
// Endpoint of merged subscription is being deleted
xapp.Logger.Debug("Subscription route update WriteSubscriptionToDb")
- c.WriteSubscriptionToDb(subs)
+ err := c.WriteSubscriptionToDb(subs)
+ if err != nil {
+ xapp.Logger.Error("tracker.UnTrackTransaction() failed:%s", err.Error())
+ }
c.UpdateCounter(cUnmergedSubscriptions)
}
return nil
// Delete REST subscription from registry and db
for restSubId, restSubs := range r.restSubscriptions {
- if restSubs.Meid == ranName && restSubs.SubReqOngoing == true || restSubs.SubDelReqOngoing == true {
- // Subscription creation or deletion processes need to be processed gracefully till the end.
- // Subscription is deleted at end of the process in both cases.
- xapp.Logger.Debug("Registry: REST subscription under prosessing ongoing cannot delete it yet. RestSubId=%v, SubReqOngoing=%v, SubDelReqOngoing=%v", restSubId, restSubs.SubReqOngoing, restSubs.SubDelReqOngoing)
- continue
- } else {
- xapp.Logger.Debug("Registry: REST subscription delete. subId=%v", restSubId)
- delete(r.restSubscriptions, restSubId)
- c.RemoveRESTSubscriptionFromDb(restSubId)
+ if restSubs.Meid == ranName {
+ if restSubs.SubReqOngoing == true || restSubs.SubDelReqOngoing == true {
+ // Subscription creation or deletion processes need to be processed gracefully till the end.
+ // Subscription is deleted at end of the process in both cases.
+ xapp.Logger.Debug("Registry: REST subscription under prosessing ongoing cannot delete it yet. RestSubId=%v, SubReqOngoing=%v, SubDelReqOngoing=%v", restSubId, restSubs.SubReqOngoing, restSubs.SubDelReqOngoing)
+ continue
+ } else {
+ xapp.Logger.Debug("Registry: REST subscription delete. subId=%v", restSubId)
+ delete(r.restSubscriptions, restSubId)
+ c.RemoveRESTSubscriptionFromDb(restSubId)
+ }
}
}
}