--- /dev/null
+\r
+\r
+/*\r
+==================================================================================\r
+ Copyright (c) 2018-2019 AT&T Intellectual Property.\r
+\r
+ Licensed under the Apache License, Version 2.0 (the "License");\r
+ you may not use this file except in compliance with the License.\r
+ You may obtain a copy of the License at\r
+\r
+ http://www.apache.org/licenses/LICENSE-2.0\r
+\r
+ Unless required by applicable law or agreed to in writing, software\r
+ distributed under the License is distributed on an "AS IS" BASIS,\r
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ See the License for the specific language governing permissions and\r
+ limitations under the License.\r
+==================================================================================\r
+*/\r
+\r
+\r
+#include "subscription_response.hpp"\r
+\r
+/* The xAPP need only worry about the get_fields from a response, since it does\r
+not generate a response. Generating response however is included to support testing. \r
+*/\r
+\r
+\r
+// Primarly for generation\r
+subscription_response::subscription_response(void){\r
+\r
+ e2ap_pdu_obj = 0;\r
+ e2ap_pdu_obj = (E2AP_PDU_t *)calloc(1, sizeof(E2AP_PDU_t));\r
+ assert(e2ap_pdu_obj != 0);\r
+\r
+ successMsg = 0;\r
+ successMsg = (SuccessfulOutcome_t *)calloc(1, sizeof(SuccessfulOutcome_t));\r
+ assert(successMsg != 0);\r
+\r
+ unsuccessMsg = 0;\r
+ unsuccessMsg = (UnsuccessfulOutcome_t *)calloc(1, sizeof(UnsuccessfulOutcome_t));\r
+ assert(unsuccessMsg != 0);\r
+\r
+ IE_array = 0;\r
+ IE_array = (RICsubscriptionResponse_IEs_t *)calloc(NUM_SUBSCRIPTION_RESPONSE_IES, sizeof(RICsubscriptionResponse_IEs_t));\r
+ assert(IE_array != 0);\r
+\r
+ IE_Failure_array = 0;\r
+ IE_Failure_array = (RICsubscriptionFailure_IEs_t *)calloc(NUM_SUBSCRIPTION_FAILURE_IES, sizeof(RICsubscriptionFailure_IEs_t));\r
+ assert(IE_Failure_array != 0);\r
+\r
+ ie_admitted_list = 0;\r
+ ie_admitted_list = (RICaction_Admitted_ItemIEs_t *)calloc(INITIAL_LIST_SIZE, sizeof(RICaction_Admitted_ItemIEs_t));\r
+ assert(ie_admitted_list != 0);\r
+ ie_admitted_list_size = INITIAL_LIST_SIZE;\r
+ \r
+ ie_not_admitted_list = 0;\r
+ ie_not_admitted_list = (RICaction_NotAdmitted_ItemIEs_t *)calloc(INITIAL_LIST_SIZE, sizeof(RICaction_NotAdmitted_ItemIEs_t));\r
+ assert(ie_not_admitted_list != 0);\r
+ ie_not_admitted_list_size = INITIAL_LIST_SIZE;\r
+ \r
+ \r
+};\r
+\r
+ \r
+\r
+// Clear assigned protocolIE list from RIC indication IE container\r
+subscription_response::~subscription_response(void){\r
+\r
+ mdclog_write(MDCLOG_INFO, "Freeing subscription response memory for");\r
+ RICaction_Admitted_List_t * response_admitted_list = (RICaction_Admitted_List_t *) &(IE_array[2].value.choice.RICaction_Admitted_List);\r
+ \r
+ for(int i = 0; i < response_admitted_list->list.size; i++){\r
+ response_admitted_list->list.array[i] = 0;\r
+ }\r
+\r
+ \r
+ if (response_admitted_list->list.size > 0){\r
+ free(response_admitted_list->list.array);\r
+ response_admitted_list->list.array = 0;\r
+ response_admitted_list->list.size = 0;\r
+ response_admitted_list->list.count = 0;\r
+ }\r
+\r
+ \r
+ RICaction_NotAdmitted_List_t * response_not_admitted_list = &(IE_array[3].value.choice.RICaction_NotAdmitted_List);\r
+ for(int i = 0; i < response_not_admitted_list->list.size; i++){\r
+ response_not_admitted_list->list.array[i] = 0;\r
+ }\r
+ \r
+ if (response_not_admitted_list->list.size > 0){\r
+ free(response_not_admitted_list->list.array);\r
+ response_not_admitted_list->list.array = 0;\r
+ response_not_admitted_list->list.size = 0;\r
+ response_not_admitted_list->list.count = 0;\r
+ }\r
+ \r
+ RICsubscriptionResponse_t * ric_subscription_response = &(successMsg->value.choice.RICsubscriptionResponse);\r
+ for(int i = 0; i < ric_subscription_response->protocolIEs.list.size ; i++){\r
+ ric_subscription_response->protocolIEs.list.array[i] = 0;\r
+ }\r
+ \r
+ if (ric_subscription_response->protocolIEs.list.size > 0){\r
+ free(ric_subscription_response->protocolIEs.list.array);\r
+ ric_subscription_response->protocolIEs.list.array = 0;\r
+ ric_subscription_response->protocolIEs.list.size = 0;\r
+ ric_subscription_response->protocolIEs.list.count = 0;\r
+ }\r
+ \r
+ \r
+ RICaction_NotAdmitted_List_t * failure_not_admitted_list = &(IE_Failure_array[2].value.choice.RICaction_NotAdmitted_List);\r
+ for(int i = 0; i < failure_not_admitted_list->list.size; i++){\r
+ failure_not_admitted_list->list.array[i] = 0;\r
+ }\r
+\r
+ if ( failure_not_admitted_list->list.size > 0){\r
+ free( failure_not_admitted_list->list.array);\r
+ failure_not_admitted_list->list.array = 0;\r
+ failure_not_admitted_list->list.size = 0;\r
+ failure_not_admitted_list->list.count = 0;\r
+ }\r
+ \r
+ \r
+ RICsubscriptionFailure_t * ric_subscription_failure = &(unsuccessMsg->value.choice.RICsubscriptionFailure);\r
+ for(int i = 0; i < ric_subscription_failure->protocolIEs.list.size; i++){\r
+ ric_subscription_failure->protocolIEs.list.array[i] = 0;\r
+ }\r
+ \r
+ if ( ric_subscription_failure->protocolIEs.list.size > 0){\r
+ free(ric_subscription_failure->protocolIEs.list.array);\r
+ ric_subscription_failure->protocolIEs.list.array = 0;\r
+ ric_subscription_failure->protocolIEs.list.size = 0;\r
+ ric_subscription_failure->protocolIEs.list.count = 0;\r
+ }\r
+\r
+ \r
+\r
+ free(ie_admitted_list); \r
+ free(ie_not_admitted_list);\r
+ free(IE_Failure_array);\r
+ free(IE_array);\r
+\r
+ \r
+ ASN_STRUCT_FREE(asn_DEF_SuccessfulOutcome, successMsg);\r
+ ASN_STRUCT_FREE(asn_DEF_UnsuccessfulOutcome, unsuccessMsg);\r
+\r
+ \r
+ e2ap_pdu_obj->choice.initiatingMessage = NULL;\r
+ e2ap_pdu_obj->present = E2AP_PDU_PR_NOTHING;\r
+ ASN_STRUCT_FREE(asn_DEF_E2AP_PDU, e2ap_pdu_obj);\r
+\r
+ mdclog_write(MDCLOG_INFO, "Freed subscription response memory ");\r
+\r
+ \r
+};\r
+\r
+\r
+bool subscription_response::encode_e2ap_subscription_response(unsigned char *buf, size_t *size, E2AP_PDU_t *e2ap_pdu, subscription_response_helper &dinput, bool is_success){\r
+\r
+ //memset(e2ap_pdu, 0, sizeof(E2AP_PDU_t));\r
+\r
+ if(is_success){\r
+ set_fields(successMsg, dinput);\r
+ e2ap_pdu_obj->present = E2AP_PDU_PR_successfulOutcome;\r
+ e2ap_pdu_obj->choice.successfulOutcome = successMsg;\r
+ }\r
+ else{\r
+ set_fields(unsuccessMsg, dinput);\r
+ e2ap_pdu_obj->present = E2AP_PDU_PR_unsuccessfulOutcome;\r
+ e2ap_pdu_obj->choice.unsuccessfulOutcome = unsuccessMsg;\r
+ }\r
+ \r
+ //xer_fprint(stdout, &asn_DEF_E2AP_PDU, e2ap_pdu_obj);\r
+\r
+ int ret_constr = asn_check_constraints(&asn_DEF_E2AP_PDU, (void *) e2ap_pdu_obj, errbuf, &errbuf_len);\r
+ if(ret_constr){\r
+ error_string.assign(errbuf, errbuf_len);\r
+ error_string = "Constraints failed for encoding subscription response. Reason = " + error_string;\r
+ return false;\r
+ }\r
+ \r
+ asn_enc_rval_t res = asn_encode_to_buffer(0, ATS_ALIGNED_BASIC_PER, &asn_DEF_E2AP_PDU, e2ap_pdu_obj, buf, *size);\r
+ \r
+ if(res.encoded == -1){\r
+ std::cout <<"Error encoding PDU. Reason =" << strerror(errno) << std::endl;\r
+ return false;\r
+ }\r
+ else {\r
+ if(*size < res.encoded){\r
+ fprintf(stderr, "Buffer assigned too small to encode: %s",(char *)(asn_DEF_E2AP_PDU.name));\r
+ res.encoded = -1;\r
+ return false;\r
+ }\r
+ }\r
+ \r
+ *size = res.encoded;\r
+ return true;\r
+ \r
+}\r
+ \r
+void subscription_response::set_fields(SuccessfulOutcome_t *success, subscription_response_helper &helper){\r
+\r
+ int ie_index;\r
+\r
+ success->procedureCode = ProcedureCode_id_ricSubscription;\r
+ success->criticality = Criticality_reject;\r
+ success->value.present = SuccessfulOutcome__value_PR_RICsubscriptionResponse; \r
+ \r
+ RICsubscriptionResponse_t * subscription_response = &(success->value.choice.RICsubscriptionResponse);\r
+ subscription_response->protocolIEs.list.count = 0;\r
+ \r
+ ie_index = 0;\r
+ RICsubscriptionResponse_IEs_t *ies_ricreq = &IE_array[ie_index];\r
+ \r
+ ies_ricreq->criticality = Criticality_reject;\r
+ ies_ricreq->id = ProtocolIE_ID_id_RICrequestID;\r
+ ies_ricreq->value.present = RICsubscriptionResponse_IEs__value_PR_RICrequestID;\r
+ RICrequestID_t *ricrequest_ie = &ies_ricreq->value.choice.RICrequestID;\r
+ ricrequest_ie->ricRequestorID = helper.get_request_id();\r
+ ricrequest_ie->ricRequestSequenceNumber = helper.get_req_seq();\r
+ ASN_SEQUENCE_ADD(&subscription_response->protocolIEs, ies_ricreq);\r
+\r
+ \r
+ ie_index = 1;\r
+ RICsubscriptionResponse_IEs_t *ies_ranfunc = &IE_array[ie_index];\r
+ ies_ranfunc->criticality = Criticality_reject;\r
+ ies_ranfunc->id = ProtocolIE_ID_id_RANfunctionID;\r
+ ies_ranfunc->value.present = RICsubscriptionResponse_IEs__value_PR_RANfunctionID;\r
+ RANfunctionID_t *ranfunction_ie = &ies_ranfunc->value.choice.RANfunctionID;\r
+ *ranfunction_ie = helper.get_function_id();\r
+ ASN_SEQUENCE_ADD(&subscription_response->protocolIEs, ies_ranfunc);\r
+ \r
+ ie_index = 2;\r
+ RICsubscriptionResponse_IEs_t *ies_admitted_actid = &IE_array[ie_index];\r
+ ies_admitted_actid->criticality = Criticality_reject;\r
+ ies_admitted_actid->id = ProtocolIE_ID_id_RICactions_Admitted;\r
+ ies_admitted_actid->value.present = RICsubscriptionResponse_IEs__value_PR_RICaction_Admitted_List;\r
+ RICaction_Admitted_List_t *ric_admitted_actions_ie = &ies_admitted_actid->value.choice.RICaction_Admitted_List;\r
+ \r
+ std::vector<ActionResponse> * ref_admitted_action_array = helper.get_admitted_list();\r
+ // realloc ?\r
+ if (ref_admitted_action_array->size() >= ie_admitted_list_size){\r
+ RICaction_Admitted_ItemIEs_t * new_ref = 0;\r
+ ie_admitted_list_size = 2 * ref_admitted_action_array->size();\r
+ new_ref = (RICaction_Admitted_ItemIEs_t *) realloc(ie_admitted_list, ie_admitted_list_size * sizeof(RICaction_Admitted_ItemIEs_t));\r
+ assert(new_ref != 0);\r
+ ie_admitted_list = new_ref;\r
+ };\r
+ \r
+ ric_admitted_actions_ie->list.count = 0; \r
+ for(int i = 0; i < ref_admitted_action_array->size(); i ++){\r
+ ie_admitted_list[i].criticality = Criticality_ignore;\r
+ ie_admitted_list[i].id = ProtocolIE_ID_id_RICaction_Admitted_Item ;\r
+ ie_admitted_list[i].value.present = RICaction_Admitted_ItemIEs__value_PR_RICaction_Admitted_Item;\r
+ ie_admitted_list[i].value.choice.RICaction_Admitted_Item.ricActionID = (*ref_admitted_action_array)[i].get_id();\r
+ ASN_SEQUENCE_ADD(ric_admitted_actions_ie, &(ie_admitted_list[i]));\r
+ }\r
+ \r
+ ASN_SEQUENCE_ADD(&subscription_response->protocolIEs, ies_admitted_actid);\r
+ \r
+ ie_index = 3;\r
+ RICsubscriptionResponse_IEs_t *ies_notadmitted_actid = &IE_array[ie_index];\r
+ ies_notadmitted_actid->criticality = Criticality_reject;\r
+ ies_notadmitted_actid->id = ProtocolIE_ID_id_RICactions_NotAdmitted;\r
+ ies_notadmitted_actid->value.present = RICsubscriptionResponse_IEs__value_PR_RICaction_NotAdmitted_List;\r
+ RICaction_NotAdmitted_List_t *ric_not_admitted_actions_ie = &ies_notadmitted_actid->value.choice.RICaction_NotAdmitted_List;\r
+ \r
+ std::vector<ActionResponse> * ref_notadmitted_action_array = helper.get_not_admitted_list();\r
+ //realloc ?\r
+ if (ref_notadmitted_action_array->size() >= ie_not_admitted_list_size){\r
+ RICaction_NotAdmitted_ItemIEs_t * new_ref = 0;\r
+ ie_not_admitted_list_size = 2 * ref_notadmitted_action_array->size();\r
+ new_ref = (RICaction_NotAdmitted_ItemIEs_t *) realloc(ie_not_admitted_list, ie_not_admitted_list_size * sizeof(RICaction_NotAdmitted_ItemIEs_t));\r
+ assert(new_ref != 0);\r
+ ie_not_admitted_list = new_ref;\r
+ };\r
+ \r
+ \r
+ // reset the list count\r
+ ric_not_admitted_actions_ie->list.count = 0; \r
+ for(int i = 0; i < ref_notadmitted_action_array->size(); i ++){\r
+ ie_not_admitted_list[i].criticality = Criticality_ignore;\r
+ ie_not_admitted_list[i].id = ProtocolIE_ID_id_RICaction_NotAdmitted_Item ;\r
+ ie_not_admitted_list[i].value.present = RICaction_NotAdmitted_ItemIEs__value_PR_RICaction_NotAdmitted_Item;;\r
+ ie_not_admitted_list[i].value.choice.RICaction_NotAdmitted_Item.ricActionID = (*ref_notadmitted_action_array)[i].get_id();\r
+\r
+ int cause = (*ref_notadmitted_action_array)[i].get_cause();\r
+ switch(cause){\r
+ case RICcause_PR_radioNetwork:\r
+ ie_not_admitted_list[i].value.choice.RICaction_NotAdmitted_Item.ricCause.choice.radioNetwork = (*ref_notadmitted_action_array)[i].get_sub_cause();\r
+ break;\r
+ case RICcause_PR_transport:\r
+ ie_not_admitted_list[i].value.choice.RICaction_NotAdmitted_Item.ricCause.choice.transport = (*ref_notadmitted_action_array)[i].get_sub_cause();\r
+ break;\r
+ case RICcause_PR_protocol:\r
+ ie_not_admitted_list[i].value.choice.RICaction_NotAdmitted_Item.ricCause.choice.protocol= (*ref_notadmitted_action_array)[i].get_sub_cause();\r
+ break;\r
+ case RICcause_PR_misc:\r
+ ie_not_admitted_list[i].value.choice.RICaction_NotAdmitted_Item.ricCause.choice.misc = (*ref_notadmitted_action_array)[i].get_sub_cause();\r
+ break;\r
+ case RICcause_PR_ric:\r
+ ie_not_admitted_list[i].value.choice.RICaction_NotAdmitted_Item.ricCause.choice.ric = (*ref_notadmitted_action_array)[i].get_sub_cause();\r
+ break;\r
+ default:\r
+ std::cout <<"Error ! Illegal cause enum" << cause << std::endl;\r
+ return;\r
+ }\r
+\r
+ ie_not_admitted_list[i].value.choice.RICaction_NotAdmitted_Item.ricCause.present = (RICcause_PR)cause; \r
+ ASN_SEQUENCE_ADD(ric_not_admitted_actions_ie, &(ie_not_admitted_list[i]));\r
+ }\r
+ \r
+ ASN_SEQUENCE_ADD(&subscription_response->protocolIEs, ies_notadmitted_actid);\r
+ \r
+ \r
+}\r
+\r
+void subscription_response:: get_fields(SuccessfulOutcome_t * success_msg, subscription_response_helper & dout)\r
+{\r
+ RICrequestID_t *requestid;\r
+ RANfunctionID_t * ranfunctionid;\r
+ RICaction_Admitted_List_t * ric_admitted_action_list;\r
+ RICaction_NotAdmitted_List_t * ric_not_admitted_action_list;\r
+ \r
+ for(int edx = 0; edx < success_msg->value.choice.RICsubscriptionResponse.protocolIEs.list.count; edx++) {\r
+ RICsubscriptionResponse_IEs_t *memb_ptr = success_msg->value.choice.RICsubscriptionResponse.protocolIEs.list.array[edx];\r
+ \r
+ switch(memb_ptr->id)\r
+ {\r
+ case (ProtocolIE_ID_id_RICrequestID):\r
+ requestid = &memb_ptr->value.choice.RICrequestID;\r
+ dout.set_request(requestid->ricRequestorID, requestid->ricRequestSequenceNumber);\r
+ break;\r
+ \r
+ case (ProtocolIE_ID_id_RANfunctionID):\r
+ ranfunctionid = &memb_ptr->value.choice.RANfunctionID;\r
+ dout.set_function_id(*ranfunctionid);\r
+ break;\r
+ \r
+ case (ProtocolIE_ID_id_RICactions_Admitted):\r
+ ric_admitted_action_list = &memb_ptr->value.choice.RICaction_Admitted_List;\r
+ \r
+ // admitted actions\r
+ for(int index = 0; index < ric_admitted_action_list->list.count; index ++){\r
+ RICaction_Admitted_ItemIEs_t * item = (RICaction_Admitted_ItemIEs_t *)ric_admitted_action_list->list.array[index];\r
+ long int id = item->value.choice.RICaction_Admitted_Item.ricActionID;\r
+ dout.get_admitted_list()->push_back(ActionResponse(id));\r
+ };\r
+\r
+ break;\r
+\r
+ case (ProtocolIE_ID_id_RICactions_NotAdmitted):\r
+ ric_not_admitted_action_list = &memb_ptr->value.choice.RICaction_NotAdmitted_List;\r
+ \r
+ for(int index = 0; index < ric_not_admitted_action_list->list.count; index ++){\r
+ RICaction_NotAdmitted_ItemIEs_t * item = (RICaction_NotAdmitted_ItemIEs_t *)ric_not_admitted_action_list->list.array[index];\r
+ long int id = item->value.choice.RICaction_NotAdmitted_Item.ricActionID;\r
+ int cause = item->value.choice.RICaction_NotAdmitted_Item.ricCause.present;\r
+ int sub_cause;\r
+ switch(cause){\r
+ \r
+ case RICcause_PR_radioNetwork :\r
+ sub_cause = item->value.choice.RICaction_NotAdmitted_Item.ricCause.choice.radioNetwork;\r
+ break;\r
+ \r
+ case RICcause_PR_transport :\r
+ sub_cause = item->value.choice.RICaction_NotAdmitted_Item.ricCause.choice.transport;\r
+ break;\r
+ \r
+ case RICcause_PR_protocol :\r
+ sub_cause = item->value.choice.RICaction_NotAdmitted_Item.ricCause.choice.protocol;\r
+ break;\r
+ \r
+ case RICcause_PR_misc :\r
+ sub_cause = item->value.choice.RICaction_NotAdmitted_Item.ricCause.choice.misc;\r
+ break;\r
+ \r
+ case RICcause_PR_ric :\r
+ sub_cause = item->value.choice.RICaction_NotAdmitted_Item.ricCause.choice.ric;\r
+ break;\r
+ \r
+ default:\r
+ std::cout <<"Error ! Illegal cause enum" << cause << std::endl;\r
+ return;\r
+ } \r
+ dout.get_not_admitted_list()->push_back(ActionResponse(id, cause, sub_cause));\r
+ }\r
+ break;\r
+ }\r
+ \r
+ }\r
+ \r
+ //asn_fprint(stdout, &asn_DEF_E2AP_PDU, e2pdu);\r
+}\r
+\r
+\r
+void subscription_response::set_fields(UnsuccessfulOutcome_t *unsuccess, subscription_response_helper &helper){\r
+\r
+ int ie_index;\r
+\r
+ unsuccess->procedureCode = ProcedureCode_id_ricSubscription;\r
+ unsuccess->criticality = Criticality_reject;\r
+ unsuccess->value.present = UnsuccessfulOutcome__value_PR_RICsubscriptionFailure;\r
+\r
+ RICsubscriptionFailure_t * ric_subscription_failure = &(unsuccess->value.choice.RICsubscriptionFailure);\r
+ ric_subscription_failure->protocolIEs.list.count = 0;\r
+ \r
+ ie_index = 0;\r
+ RICsubscriptionFailure_IEs_t *ies_ricreq = &IE_Failure_array[ie_index];\r
+ ies_ricreq->criticality = Criticality_reject;\r
+ ies_ricreq->id = ProtocolIE_ID_id_RICrequestID;\r
+ ies_ricreq->value.present = RICsubscriptionFailure_IEs__value_PR_RICrequestID;\r
+ RICrequestID_t *ricrequest_ie = &ies_ricreq->value.choice.RICrequestID;\r
+ ricrequest_ie->ricRequestorID = helper.get_request_id();\r
+ ricrequest_ie->ricRequestSequenceNumber = helper.get_req_seq();\r
+ ASN_SEQUENCE_ADD(&ric_subscription_failure->protocolIEs, ies_ricreq);\r
+ \r
+ ie_index = 1;\r
+ RICsubscriptionFailure_IEs_t *ies_ranfunc = &IE_Failure_array[ie_index];\r
+ ies_ranfunc->criticality = Criticality_reject;\r
+ ies_ranfunc->id = ProtocolIE_ID_id_RANfunctionID;\r
+ ies_ranfunc->value.present = RICsubscriptionFailure_IEs__value_PR_RANfunctionID;\r
+ RANfunctionID_t *ranfunction_ie = &ies_ranfunc->value.choice.RANfunctionID;\r
+ *ranfunction_ie = helper.get_function_id();\r
+ ASN_SEQUENCE_ADD(&ric_subscription_failure->protocolIEs, ies_ranfunc);\r
+ \r
+\r
+ ie_index = 2;\r
+ RICsubscriptionFailure_IEs_t *ies_notadmitted_actid = &IE_Failure_array[ie_index];\r
+ ies_notadmitted_actid->criticality = Criticality_reject;\r
+ ies_notadmitted_actid->id = ProtocolIE_ID_id_RICactions_NotAdmitted;\r
+ std::vector<ActionResponse> * ref_notadmitted_action_array = helper.get_not_admitted_list();\r
+\r
+ //realloc ?\r
+ if (ref_notadmitted_action_array->size() >= ie_not_admitted_list_size){\r
+ RICaction_NotAdmitted_ItemIEs_t * new_ref = 0;\r
+ ie_not_admitted_list_size = 2 * ref_notadmitted_action_array->size();\r
+ new_ref = (RICaction_NotAdmitted_ItemIEs_t *) realloc(ie_not_admitted_list, ie_not_admitted_list_size * sizeof(RICaction_NotAdmitted_ItemIEs_t));\r
+ assert(new_ref != 0);\r
+ ie_not_admitted_list = new_ref;\r
+ };\r
+ \r
+ ies_notadmitted_actid->value.present = RICsubscriptionFailure_IEs__value_PR_RICaction_NotAdmitted_List;\r
+ RICaction_NotAdmitted_List_t *ric_not_admitted_actions_ie = &ies_notadmitted_actid->value.choice.RICaction_NotAdmitted_List;\r
+\r
+\r
+ // reset the list count on ricAction_ToBeSetup_List;\r
+ ric_not_admitted_actions_ie->list.count = 0; \r
+ for(int i = 0; i < ref_notadmitted_action_array->size(); i ++){\r
+ ie_not_admitted_list[i].criticality = Criticality_ignore;\r
+ ie_not_admitted_list[i].id = ProtocolIE_ID_id_RICaction_NotAdmitted_Item ;\r
+ ie_not_admitted_list[i].value.present = RICaction_NotAdmitted_ItemIEs__value_PR_RICaction_NotAdmitted_Item;;\r
+ ie_not_admitted_list[i].value.choice.RICaction_NotAdmitted_Item.ricActionID = (*ref_notadmitted_action_array)[i].get_id();\r
+\r
+ int cause = (*ref_notadmitted_action_array)[i].get_cause();\r
+ switch(cause){\r
+ case RICcause_PR_radioNetwork:\r
+ ie_not_admitted_list[i].value.choice.RICaction_NotAdmitted_Item.ricCause.choice.radioNetwork = (*ref_notadmitted_action_array)[i].get_sub_cause();\r
+ break;\r
+ case RICcause_PR_transport:\r
+ ie_not_admitted_list[i].value.choice.RICaction_NotAdmitted_Item.ricCause.choice.transport = (*ref_notadmitted_action_array)[i].get_sub_cause();\r
+ break;\r
+ case RICcause_PR_protocol:\r
+ ie_not_admitted_list[i].value.choice.RICaction_NotAdmitted_Item.ricCause.choice.protocol= (*ref_notadmitted_action_array)[i].get_sub_cause();\r
+ break;\r
+ case RICcause_PR_misc:\r
+ ie_not_admitted_list[i].value.choice.RICaction_NotAdmitted_Item.ricCause.choice.misc = (*ref_notadmitted_action_array)[i].get_sub_cause();\r
+ break;\r
+ case RICcause_PR_ric:\r
+ ie_not_admitted_list[i].value.choice.RICaction_NotAdmitted_Item.ricCause.choice.ric = (*ref_notadmitted_action_array)[i].get_sub_cause();\r
+ break;\r
+ default:\r
+ std::cout <<"Error ! Illegal cause enum" << cause << std::endl;\r
+ return;\r
+ }\r
+\r
+ ie_not_admitted_list[i].value.choice.RICaction_NotAdmitted_Item.ricCause.present = (RICcause_PR)cause;\r
+ \r
+ ASN_SEQUENCE_ADD(ric_not_admitted_actions_ie, &(ie_not_admitted_list[i]));\r
+ }\r
+ \r
+ ASN_SEQUENCE_ADD(&ric_subscription_failure->protocolIEs, ies_notadmitted_actid);\r
+\r
+\r
+ // // criticality diagnostics is not generated/parsed currently since optional\r
+ // i = 3;\r
+ // RICsubscriptionFailure_IEs_t *ies_criticality_diagnostics= &IE_Failure_array[i];\r
+ // ies_criticality_diagnostics->criticality = Criticality_ignore;\r
+ // ies_criticality_diagnostics->id = ProtocolIE_ID_id_CriticalityDiagnostics ;\r
+ // ies_criticality_diagnostics->value.present = RICsubscriptionFailure_IEs__value_PR_NOTHING;\r
+\r
+ \r
+}\r
+\r
+void subscription_response:: get_fields(UnsuccessfulOutcome_t * unsuccess_msg, subscription_response_helper & dout)\r
+{\r
+ RICrequestID_t *requestid;\r
+ RANfunctionID_t * ranfunctionid;\r
+ RICaction_NotAdmitted_List_t * ric_not_admitted_action_list;\r
+ \r
+ for(int edx = 0; edx < unsuccess_msg->value.choice.RICsubscriptionFailure.protocolIEs.list.count; edx++) {\r
+ RICsubscriptionFailure_IEs_t *memb_ptr = unsuccess_msg->value.choice.RICsubscriptionFailure.protocolIEs.list.array[edx];\r
+ \r
+ switch(memb_ptr->id)\r
+ {\r
+ case (ProtocolIE_ID_id_RICrequestID):\r
+ requestid = &memb_ptr->value.choice.RICrequestID;\r
+ dout.set_request(requestid->ricRequestorID, requestid->ricRequestSequenceNumber);\r
+ break;\r
+ \r
+ case (ProtocolIE_ID_id_RANfunctionID):\r
+ ranfunctionid = &memb_ptr->value.choice.RANfunctionID;\r
+ dout.set_function_id(*ranfunctionid);\r
+ break;\r
+ \r
+\r
+ case (ProtocolIE_ID_id_RICactions_NotAdmitted):\r
+ ric_not_admitted_action_list = &memb_ptr->value.choice.RICaction_NotAdmitted_List;\r
+ \r
+ for(int index = 0; index < ric_not_admitted_action_list->list.count; index ++){\r
+ RICaction_NotAdmitted_ItemIEs_t * item = (RICaction_NotAdmitted_ItemIEs_t *)ric_not_admitted_action_list->list.array[index];\r
+ long int id = item->value.choice.RICaction_NotAdmitted_Item.ricActionID;\r
+ int cause = item->value.choice.RICaction_NotAdmitted_Item.ricCause.present;\r
+ int sub_cause;\r
+ switch(cause){\r
+ \r
+ case RICcause_PR_radioNetwork :\r
+ sub_cause = item->value.choice.RICaction_NotAdmitted_Item.ricCause.choice.radioNetwork;\r
+ break;\r
+ \r
+ case RICcause_PR_transport :\r
+ sub_cause = item->value.choice.RICaction_NotAdmitted_Item.ricCause.choice.transport;\r
+ break;\r
+ \r
+ case RICcause_PR_protocol :\r
+ sub_cause = item->value.choice.RICaction_NotAdmitted_Item.ricCause.choice.protocol;\r
+ break;\r
+ \r
+ case RICcause_PR_misc :\r
+ sub_cause = item->value.choice.RICaction_NotAdmitted_Item.ricCause.choice.misc;\r
+ break;\r
+ \r
+ case RICcause_PR_ric :\r
+ sub_cause = item->value.choice.RICaction_NotAdmitted_Item.ricCause.choice.ric;\r
+ break;\r
+ \r
+ default:\r
+ std::cout <<"Error ! Illegal cause enum" << cause << std::endl;\r
+ return;\r
+ } \r
+ dout.get_not_admitted_list()->push_back(ActionResponse(id, cause, sub_cause));\r
+ }\r
+ break;\r
+ }\r
+ \r
+ }\r
+ \r
+ //asn_fprint(stdout, &asn_DEF_E2AP_PDU, e2pdu);\r
+}\r
+\r
+\r
+\r
Code Review / ric-app / kpimon.git / blobdiff