-func (s *Subscription) Release() {
- xapp.Logger.Info("Subscription: Releasing %s", s)
- s.mutex.Lock()
- defer s.mutex.Unlock()
- s.registry.DelSubscription(s.Seq)
- err := s.updateRouteImpl(DELETE)
- if err != nil {
- xapp.Logger.Error("Registry: Failed to del route. SubId: %d, RmrEndpoint: %s", s.Seq, s.RmrEndpoint)
+ for _, acts := range s.SubReqMsg.ActionSetups {
+ for _, actt := range subReqMsg.ActionSetups {
+ if acts.ActionId != actt.ActionId {
+ return false
+ }
+ if acts.ActionType != actt.ActionType {
+ return false
+ }
+
+ if acts.ActionType != e2ap.E2AP_ActionTypeReport {
+ return false
+ }
+
+ if acts.RicActionDefinitionPresent != actt.RicActionDefinitionPresent {
+ return false
+ }
+
+ if acts.ActionDefinitionChoice.Data.Length != actt.ActionDefinitionChoice.Data.Length {
+ return false
+ }
+ for i := uint64(0); i < acts.ActionDefinitionChoice.Data.Length; i++ {
+ if acts.ActionDefinitionChoice.Data.Data[i] != actt.ActionDefinitionChoice.Data.Data[i] {
+ return false
+ }
+ }
+ //reflect.DeepEqual(acts.ActionDefinitionChoice, actt.ActionDefinitionChoice)
+
+ if acts.SubsequentAction.Present != actt.SubsequentAction.Present ||
+ acts.SubsequentAction.Type != actt.SubsequentAction.Type ||
+ acts.SubsequentAction.TimetoWait != actt.SubsequentAction.TimetoWait {
+ return false
+ }
+ }