- if _, ok := r.register[sequenceNumber]; ok == false {
- r.register[sequenceNumber] = &Subscription{
- Seq: sequenceNumber,
- Active: false,
- RmrEndpoint: endPoint,
- Meid: meid,
- Trans: nil,
- }
- return r.register[sequenceNumber]
+ }
+ r.mutex.Unlock()
+
+ //
+ // Wait some time before really do route updates
+ //
+ if waitRouteClean > 0 {
+ subs.mutex.Unlock()
+ time.Sleep(waitRouteClean)
+ subs.mutex.Lock()
+ }
+
+ xapp.Logger.Info("Registry: Cleaning %s", subs.String())
+
+ //
+ // Subscription route updates
+ //
+ if delStatus {
+ if epamount == 0 {
+ tmpList := RmrEndpointList{}
+ tmpList.AddEndpoint(trans.GetEndpoint())
+ subRouteAction := SubRouteInfo{DELETE, tmpList, subs.Seq}
+ r.rtmgrClient.SubscriptionRequestUpdate(subRouteAction)
+ } else {
+ subRouteAction := SubRouteInfo{UPDATE, subs.EpList, subs.Seq}
+ r.rtmgrClient.SubscriptionRequestUpdate(subRouteAction)