2 ==================================================================================
3 Copyright (c) 2019 AT&T Intellectual Property.
4 Copyright (c) 2019 Nokia
6 Licensed under the Apache License, Version 2.0 (the "License");
7 you may not use this file except in compliance with the License.
8 You may obtain a copy of the License at
10 http://www.apache.org/licenses/LICENSE-2.0
12 Unless required by applicable law or agreed to in writing, software
13 distributed under the License is distributed on an "AS IS" BASIS,
14 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 See the License for the specific language governing permissions and
16 limitations under the License.
17 ==================================================================================
23 "gerrit.o-ran-sc.org/r/ric-plt/e2ap/pkg/e2ap"
24 "gerrit.o-ran-sc.org/r/ric-plt/submgr/pkg/xapptweaks"
25 "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
29 //-----------------------------------------------------------------------------
31 //-----------------------------------------------------------------------------
32 type Subscription struct {
33 mutex sync.Mutex // Lock
35 registry *Registry // Registry
36 ReqId RequestId // ReqId (Requestor Id + Seq Nro a.k.a subsid)
37 Meid *xapp.RMRMeid // Meid/ RanName
38 EpList RmrEndpointList // Endpoints
39 TransLock sync.Mutex // Lock transactions, only one executed per time for subs
40 TheTrans TransactionIf // Ongoing transaction
41 SubReqMsg *e2ap.E2APSubscriptionRequest // Subscription information
42 SubRFMsg interface{} // Subscription information
45 func (s *Subscription) String() string {
46 return "subs(" + s.ReqId.String() + "/" + (&xapptweaks.RMRMeid{s.Meid}).String() + "/" + s.EpList.String() + ")"
49 func (s *Subscription) GetCachedResponse() (interface{}, bool) {
51 defer s.mutex.Unlock()
52 return s.SubRFMsg, s.valid
55 func (s *Subscription) SetCachedResponse(subRFMsg interface{}, valid bool) (interface{}, bool) {
57 defer s.mutex.Unlock()
60 return s.SubRFMsg, s.valid
63 func (s *Subscription) GetReqId() *RequestId {
65 defer s.mutex.Unlock()
69 func (s *Subscription) GetMeid() *xapp.RMRMeid {
71 defer s.mutex.Unlock()
78 func (s *Subscription) GetTransaction() TransactionIf {
80 defer s.mutex.Unlock()
84 func (s *Subscription) WaitTransactionTurn(trans TransactionIf) {
91 func (s *Subscription) ReleaseTransactionTurn(trans TransactionIf) {
93 if trans != nil && trans == s.TheTrans {
100 func (s *Subscription) IsMergeable(trans *TransactionXapp, subReqMsg *e2ap.E2APSubscriptionRequest) bool {
102 defer s.mutex.Unlock()
104 if s.valid == false {
108 if s.SubReqMsg == nil {
112 if s.Meid.RanName != trans.Meid.RanName {
116 // EventTrigger check
117 if s.SubReqMsg.EventTriggerDefinition.InterfaceDirection != subReqMsg.EventTriggerDefinition.InterfaceDirection ||
118 s.SubReqMsg.EventTriggerDefinition.ProcedureCode != subReqMsg.EventTriggerDefinition.ProcedureCode ||
119 s.SubReqMsg.EventTriggerDefinition.TypeOfMessage != subReqMsg.EventTriggerDefinition.TypeOfMessage {
123 if s.SubReqMsg.EventTriggerDefinition.InterfaceId.GlobalEnbId.Present != subReqMsg.EventTriggerDefinition.InterfaceId.GlobalEnbId.Present ||
124 s.SubReqMsg.EventTriggerDefinition.InterfaceId.GlobalEnbId.NodeId != subReqMsg.EventTriggerDefinition.InterfaceId.GlobalEnbId.NodeId ||
125 s.SubReqMsg.EventTriggerDefinition.InterfaceId.GlobalEnbId.PlmnIdentity.String() != subReqMsg.EventTriggerDefinition.InterfaceId.GlobalEnbId.PlmnIdentity.String() {
129 if s.SubReqMsg.EventTriggerDefinition.InterfaceId.GlobalGnbId.Present != subReqMsg.EventTriggerDefinition.InterfaceId.GlobalGnbId.Present ||
130 s.SubReqMsg.EventTriggerDefinition.InterfaceId.GlobalGnbId.NodeId != subReqMsg.EventTriggerDefinition.InterfaceId.GlobalGnbId.NodeId ||
131 s.SubReqMsg.EventTriggerDefinition.InterfaceId.GlobalGnbId.PlmnIdentity.String() != subReqMsg.EventTriggerDefinition.InterfaceId.GlobalGnbId.PlmnIdentity.String() {
136 if len(s.SubReqMsg.ActionSetups) != len(subReqMsg.ActionSetups) {
140 for _, acts := range s.SubReqMsg.ActionSetups {
141 for _, actt := range subReqMsg.ActionSetups {
142 if acts.ActionId != actt.ActionId {
145 if acts.ActionType != actt.ActionType {
149 if acts.ActionType != e2ap.E2AP_ActionTypeReport {
153 if acts.ActionDefinition.Present != actt.ActionDefinition.Present ||
154 acts.ActionDefinition.StyleId != actt.ActionDefinition.StyleId ||
155 acts.ActionDefinition.ParamId != actt.ActionDefinition.ParamId {
158 if acts.SubsequentAction.Present != actt.SubsequentAction.Present ||
159 acts.SubsequentAction.Type != actt.SubsequentAction.Type ||
160 acts.SubsequentAction.TimetoWait != actt.SubsequentAction.TimetoWait {