Bouncer/src/xapp-asn/e2sm/e2sm_subscription.cc

   1 /*
   2 # ==================================================================================
   3 # Copyright (c) 2020 HCL Technologies Limited.
   4 #
   5 # Licensed under the Apache License, Version 2.0 (the "License");
   6 # you may not use this file except in compliance with the License.
   7 # You may obtain a copy of the License at
   8 #
   9 # http://www.apache.org/licenses/LICENSE-2.0
  10 #
  11 # Unless required by applicable law or agreed to in writing, software
  12 # distributed under the License is distributed on an "AS IS" BASIS,
  13 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14 # See the License for the specific language governing permissions and
  15 # limitations under the License.
  16 # ==================================================================================
  17 */
  18
  19 /* Classes to handle E2 service model based on e2sm-Bouncer-v001.asn */
  20
  21 #include "e2sm_subscription.hpp"
  22
  23  //initialize
  24  e2sm_subscription::e2sm_subscription(void){
  25
  26         memset(&event_fmt1, 0, sizeof(E2SM_Bouncer_EventTriggerDefinition_Format1_t));
  27
  28         memset(&actn_fmt1, 0, sizeof(E2SM_Bouncer_ActionDefinition_Format1_t));
  29
  30
  31         ran_param = 0;
  32         ran_param = (RANparameter_Item_t*)calloc(1, sizeof(RANparameter_Item_t));
  33         assert(ran_param != 0);
  34
  35     event_trigger = 0;
  36     event_trigger = ( E2SM_Bouncer_EventTriggerDefinition_t *)calloc(1, sizeof( E2SM_Bouncer_EventTriggerDefinition_t));
  37     assert(event_trigger != 0);
  38
  39     action_defn = 0;
  40     action_defn = (E2SM_Bouncer_ActionDefinition_t*)calloc(1, sizeof(E2SM_Bouncer_ActionDefinition_t));
  41     assert(action_defn !=0);
  42
  43     errbuf_len = 128;
  44   };
  45
  46  e2sm_subscription::~e2sm_subscription(void){
  47
  48   mdclog_write(MDCLOG_DEBUG, "Freeing event trigger object memory");
  49
  50   event_trigger->choice.eventDefinition_Format1 = 0;
  51
  52   action_defn->choice.actionDefinition_Format1 = 0;
  53
  54   free(ran_param);
  55
  56   ASN_STRUCT_FREE(asn_DEF_E2SM_Bouncer_EventTriggerDefinition, event_trigger);
  57   ASN_STRUCT_FREE(asn_DEF_E2SM_Bouncer_ActionDefinition, action_defn);
  58
  59
  60 };
  61
  62 bool e2sm_subscription::encode_event_trigger(unsigned char *buf, size_t *size, e2sm_subscription_helper &helper){
  63
  64   ASN_STRUCT_RESET(asn_DEF_E2SM_Bouncer_EventTriggerDefinition, event_trigger);
  65
  66   bool res;
  67   res = set_fields(event_trigger, helper);
  68   if (!res){
  69
  70     return false;
  71   }
  72
  73   int ret_constr = asn_check_constraints(&asn_DEF_E2SM_Bouncer_EventTriggerDefinition, event_trigger, errbuf, &errbuf_len);
  74   if(ret_constr){
  75     error_string.assign(&errbuf[0], errbuf_len);
  76     return false;
  77   }
  78
  79   xer_fprint(stdout, &asn_DEF_E2SM_Bouncer_EventTriggerDefinition, event_trigger);
  80
  81   asn_enc_rval_t retval = asn_encode_to_buffer(0, ATS_ALIGNED_BASIC_PER, &asn_DEF_E2SM_Bouncer_EventTriggerDefinition, event_trigger, buf, *size);
  82
  83   if(retval.encoded == -1){
  84     error_string.assign(strerror(errno));
  85     return false;
  86   }
  87   else if (retval.encoded > *size){
  88     std::stringstream ss;
  89     ss  <<"Error encoding event trigger definition. Reason =  encoded pdu size " << retval.encoded << " exceeds buffer size " << *size << std::endl;
  90     error_string = ss.str();
  91     return false;
  92   }
  93   else{
  94     *size = retval.encoded;
  95   }
  96
  97   return true;
  98 }
  99
 100 bool e2sm_subscription::encode_action_defn(unsigned char *buf, size_t *size, e2sm_subscription_helper &helper){
 101
 102   bool res;
 103   res = set_fields(action_defn, helper);
 104   if (!res){
 105     return false;
 106   }
 107
 108
 109   int ret_constr = asn_check_constraints(&asn_DEF_E2SM_Bouncer_ActionDefinition, action_defn, errbuf, &errbuf_len);
 110   if(ret_constr){
 111     error_string.assign(&errbuf[0], errbuf_len);
 112     return false;
 113   }
 114
 115   xer_fprint(stdout, &asn_DEF_E2SM_Bouncer_ActionDefinition, action_defn);
 116
 117   asn_enc_rval_t retval = asn_encode_to_buffer(0, ATS_ALIGNED_BASIC_PER, &asn_DEF_E2SM_Bouncer_ActionDefinition, action_defn, buf, *size);
 118
 119   if(retval.encoded == -1){
 120     error_string.assign(strerror(errno));
 121     return false;
 122   }
 123   else if (retval.encoded > *size){
 124     std::stringstream ss;
 125     ss  <<"Error encoding action definition. Reason =  encoded pdu size " << retval.encoded << " exceeds buffer size " << *size << std::endl;
 126     error_string = ss.str();
 127     return false;
 128   }
 129   else{
 130     *size = retval.encoded;
 131   }
 132
 133   return true;
 134 }
 135
 136 bool e2sm_subscription::set_fields(E2SM_Bouncer_EventTriggerDefinition_t * ref_event_trigger, e2sm_subscription_helper & helper){
 137
 138  if(ref_event_trigger == 0){
 139     error_string = "Invalid reference for Event Trigger Definition set fields";
 140     return false;
 141   }
 142
 143   ref_event_trigger->present = E2SM_Bouncer_EventTriggerDefinition_PR_eventDefinition_Format1;
 144
 145   event_fmt1.triggerNature = helper.triger_nature;
 146
 147   ref_event_trigger->choice.eventDefinition_Format1 = &event_fmt1;
 148
 149   return true;
 150 };
 151
 152 bool e2sm_subscription::set_fields(E2SM_Bouncer_ActionDefinition_t * ref_action_defn, e2sm_subscription_helper & helper){
 153
 154  if(ref_action_defn == 0){
 155     error_string = "Invalid reference for Event Action Definition set fields";
 156     return false;
 157   }
 158   ref_action_defn->present = E2SM_Bouncer_ActionDefinition_PR_actionDefinition_Format1;
 159
 160
 161   ranparam_helper_t paramlst = helper.get_paramlist();
 162
 163   for(RANParam_Helper item:paramlst){
 164           ran_param->ranParameter_ID = item.getran_helper()._param_id;
 165           ran_param->ranParameter_Name.buf = item.getran_helper()._param_name;
 166           ran_param->ranParameter_Name.size = item.getran_helper()._param_name_len;
 167           ran_param->ranParameter_Test = item.getran_helper()._param_test;
 168           ran_param->ranParameter_Value.buf = item.getran_helper()._param_value;
 169           ran_param->ranParameter_Value.size = item.getran_helper()._param_value_len;
 170           ASN_SEQUENCE_ADD(&(actn_fmt1.ranParameter_List->list.array), ran_param);
 171   }
 172
 173
 174   ref_action_defn->choice.actionDefinition_Format1 = &actn_fmt1;
 175
 176
 177   return true;
 178 };
 179