#include <stdio.h>
#include <string.h>
-#include <iostream>
-#include <unistd.h>
-#include <vector>
-
-#include "encode_kpm.hpp"
-
-using namespace std;
-
-void encode_kpm_function_description(E2SM_KPM_RANfunction_Description_t* ranfunc_desc) {
-
- printf("kpm0\n");
-
- uint8_t *buf = (uint8_t*)"ORAN-E2SM-KPM";
- uint8_t *buf2 = (uint8_t*)"KPM monitor";
- uint8_t *buf3 = (uint8_t*)"OID123";
- long inst = 1;
-
- ASN_STRUCT_RESET(asn_DEF_E2SM_KPM_RANfunction_Description, ranfunc_desc);
-
- ranfunc_desc->ranFunction_Name.ranFunction_ShortName.size = strlen((char*)buf);
- ranfunc_desc->ranFunction_Name.ranFunction_ShortName.buf = (uint8_t*)calloc(strlen((char*)buf), sizeof(uint8_t));
- memcpy(ranfunc_desc->ranFunction_Name.ranFunction_ShortName.buf, buf, ranfunc_desc->ranFunction_Name.ranFunction_ShortName.size);
-
- // ranfunc_desc->ranFunction_Name.ranFunction_Description = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
- ranfunc_desc->ranFunction_Name.ranFunction_Description.buf = (uint8_t*)calloc(1,strlen((char*)buf2));
- memcpy(ranfunc_desc->ranFunction_Name.ranFunction_Description.buf, buf2, strlen((char*)buf2));
- ranfunc_desc->ranFunction_Name.ranFunction_Description.size = strlen((char*)buf2);
- ranfunc_desc->ranFunction_Name.ranFunction_Instance = &inst;
-
- printf("kpm0.9\n");
-
- // ranfunc_desc->ranFunction_Name.ranFunction_E2SM_OID = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
- ranfunc_desc->ranFunction_Name.ranFunction_E2SM_OID.buf = (uint8_t*)calloc(1,strlen((char*)buf3));
- memcpy(ranfunc_desc->ranFunction_Name.ranFunction_E2SM_OID.buf, buf3, strlen((char*)buf3));
- ranfunc_desc->ranFunction_Name.ranFunction_E2SM_OID.size = strlen((char*)buf3);
-
- printf("kpm2\n");
-
-
- RIC_EventTriggerStyle_List_t *trigger_style =
- (RIC_EventTriggerStyle_List_t*)calloc(1, sizeof(RIC_EventTriggerStyle_List_t));
- trigger_style->ric_EventTriggerStyle_Type = 1;
- uint8_t *buf4 = (uint8_t*)"Periodic report";
- // trigger_style->ric_EventTriggerStyle_Name = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
- trigger_style->ric_EventTriggerStyle_Name.buf = (uint8_t*)calloc(1,strlen((char*)buf4));
- memcpy(trigger_style->ric_EventTriggerStyle_Name.buf, buf4, strlen((char*)buf4));
- trigger_style->ric_EventTriggerStyle_Name.size = strlen((char*)buf4);
- trigger_style->ric_EventTriggerFormat_Type = 5;
-
- printf("kpm3\n");
-
- ranfunc_desc->e2SM_KPM_RANfunction_Item.ric_EventTriggerStyle_List =
- (E2SM_KPM_RANfunction_Description::E2SM_KPM_RANfunction_Description__e2SM_KPM_RANfunction_Item::E2SM_KPM_RANfunction_Description__e2SM_KPM_RANfunction_Item__ric_EventTriggerStyle_List*)calloc(1,sizeof(E2SM_KPM_RANfunction_Description::E2SM_KPM_RANfunction_Description__e2SM_KPM_RANfunction_Item::E2SM_KPM_RANfunction_Description__e2SM_KPM_RANfunction_Item__ric_EventTriggerStyle_List));
-
- int ret = ASN_SEQUENCE_ADD(&ranfunc_desc->e2SM_KPM_RANfunction_Item.ric_EventTriggerStyle_List->list , trigger_style);
- printf("ret is %d\n", ret);
-
- RIC_ReportStyle_List_t *report_style1 = (RIC_ReportStyle_List_t*)calloc(1, sizeof(RIC_ReportStyle_List_t));
- report_style1->ric_ReportStyle_Type = 1;
-
- uint8_t *buf5 = (uint8_t*)"O-DU Measurement Container for the 5GC connected deployment";
-
- printf("kpm4\n");
-
- // report_style1->ric_ReportStyle_Name = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
- report_style1->ric_ReportStyle_Name.buf = (uint8_t*)calloc(1,strlen((char*)buf5));
- memcpy(report_style1->ric_ReportStyle_Name.buf, buf5, strlen((char*)buf5));
- report_style1->ric_ReportStyle_Name.size = strlen((char*)buf5);
- report_style1->ric_IndicationHeaderFormat_Type = 1;
- report_style1->ric_IndicationMessageFormat_Type = 1;
-
- printf("kpm5\n");
-
- RIC_ReportStyle_List_t *report_style2 = (RIC_ReportStyle_List_t*)calloc(1, sizeof(RIC_ReportStyle_List_t));
- report_style2->ric_ReportStyle_Type = 2;
-
- uint8_t *buf6 = (uint8_t*)"O-DU Measurement Container for the EPC connected deployment";
-
- // report_style2->ric_ReportStyle_Name = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
-
-
- report_style2->ric_ReportStyle_Name.buf = (uint8_t*)calloc(1,strlen((char*)buf6));
- memcpy(report_style2->ric_ReportStyle_Name.buf, buf6, strlen((char*)buf6));
- report_style2->ric_ReportStyle_Name.size = strlen((char*)buf6);
- report_style2->ric_IndicationHeaderFormat_Type = 1;
- report_style2->ric_IndicationMessageFormat_Type = 1;
-
- printf("kpm6\n");
-
- RIC_ReportStyle_List_t *report_style3 = (RIC_ReportStyle_List_t*)calloc(1, sizeof(RIC_ReportStyle_List_t));
- report_style3->ric_ReportStyle_Type = 3;
-
- uint8_t *buf7 = (uint8_t*)"O-CU-CP Measurement Container for the 5GC connected deployment";
-
- // report_style3->ric_ReportStyle_Name = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
- report_style3->ric_ReportStyle_Name.buf = (uint8_t*)calloc(1,strlen((char*)buf7));
- memcpy(report_style3->ric_ReportStyle_Name.buf, buf7, strlen((char*)buf7));
- report_style3->ric_ReportStyle_Name.size = strlen((char*)buf7);
- report_style3->ric_IndicationHeaderFormat_Type = 1;
- report_style3->ric_IndicationMessageFormat_Type = 1;
-
- RIC_ReportStyle_List_t *report_style4 = (RIC_ReportStyle_List_t*)calloc(1, sizeof(RIC_ReportStyle_List_t));
- report_style4->ric_ReportStyle_Type = 4;
-
- uint8_t *buf8 = (uint8_t*)"O-CU-CP Measurement Container for the EPC connected deployment";
-
- // report_style3->ric_ReportStyle_Name = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
- report_style4->ric_ReportStyle_Name.buf = (uint8_t*)calloc(1,strlen((char*)buf8));
- memcpy(report_style4->ric_ReportStyle_Name.buf, buf8, strlen((char*)buf8));
- report_style4->ric_ReportStyle_Name.size = strlen((char*)buf8);
- report_style4->ric_IndicationHeaderFormat_Type = 1;
- report_style4->ric_IndicationMessageFormat_Type = 1;
-
- RIC_ReportStyle_List_t *report_style5 = (RIC_ReportStyle_List_t*)calloc(1, sizeof(RIC_ReportStyle_List_t));
- report_style5->ric_ReportStyle_Type = 5;
-
- uint8_t *buf9 = (uint8_t*)"O-CU-UP Measurement Container for the 5GC connected deployment";
-
- // report_style3->ric_ReportStyle_Name = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
- report_style5->ric_ReportStyle_Name.buf = (uint8_t*)calloc(1,strlen((char*)buf9));
- memcpy(report_style5->ric_ReportStyle_Name.buf, buf9, strlen((char*)buf9));
- report_style5->ric_ReportStyle_Name.size = strlen((char*)buf9);
- report_style5->ric_IndicationHeaderFormat_Type = 1;
- report_style5->ric_IndicationMessageFormat_Type = 1;
-
-
- RIC_ReportStyle_List_t *report_style6 = (RIC_ReportStyle_List_t*)calloc(1, sizeof(RIC_ReportStyle_List_t));
- report_style6->ric_ReportStyle_Type = 6;
-
- uint8_t *buf10 = (uint8_t*)"O-CU-UP Measurement Container for the EPC connected deployment";
-
- // report_style3->ric_ReportStyle_Name = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
- report_style6->ric_ReportStyle_Name.buf = (uint8_t*)calloc(1,strlen((char*)buf10));
- memcpy(report_style6->ric_ReportStyle_Name.buf, buf10, strlen((char*)buf10));
- report_style6->ric_ReportStyle_Name.size = strlen((char*)buf10);
- report_style6->ric_IndicationHeaderFormat_Type = 1;
- report_style6->ric_IndicationMessageFormat_Type = 1;
-
-
- ranfunc_desc->e2SM_KPM_RANfunction_Item.ric_ReportStyle_List =
- (E2SM_KPM_RANfunction_Description::E2SM_KPM_RANfunction_Description__e2SM_KPM_RANfunction_Item::E2SM_KPM_RANfunction_Description__e2SM_KPM_RANfunction_Item__ric_ReportStyle_List*)calloc(1,sizeof(E2SM_KPM_RANfunction_Description::E2SM_KPM_RANfunction_Description__e2SM_KPM_RANfunction_Item::E2SM_KPM_RANfunction_Description__e2SM_KPM_RANfunction_Item__ric_ReportStyle_List));
-
- ASN_SEQUENCE_ADD(&ranfunc_desc->e2SM_KPM_RANfunction_Item.ric_ReportStyle_List->list, report_style1);
- ASN_SEQUENCE_ADD(&ranfunc_desc->e2SM_KPM_RANfunction_Item.ric_ReportStyle_List->list, report_style2);
- ASN_SEQUENCE_ADD(&ranfunc_desc->e2SM_KPM_RANfunction_Item.ric_ReportStyle_List->list, report_style3);
- ASN_SEQUENCE_ADD(&ranfunc_desc->e2SM_KPM_RANfunction_Item.ric_ReportStyle_List->list, report_style4);
- ASN_SEQUENCE_ADD(&ranfunc_desc->e2SM_KPM_RANfunction_Item.ric_ReportStyle_List->list, report_style5);
- ASN_SEQUENCE_ADD(&ranfunc_desc->e2SM_KPM_RANfunction_Item.ric_ReportStyle_List->list, report_style6);
-
- xer_fprint(stderr, &asn_DEF_E2SM_KPM_RANfunction_Description, ranfunc_desc);
-
-}
-
-void encode_e2sm_kpm_indication_header(E2SM_KPM_IndicationHeader_t *ihead, uint8_t *plmnid_buf, uint8_t *sst_buf, uint8_t *sd_buf,
- long fqival, long qcival, uint8_t *nrcellid_buf, uint8_t *gnbid_buf, int gnbid_unused,
- uint8_t *cuupid_buf, uint8_t *duid_buf, uint8_t *cuupname_buf) {
-
-
- //uint8_t *plmnid_buf = (uint8_t*)"747";
- //uint8_t *sst_buf = (uint8_t*)"1";
- //uint8_t *sd_buf = (uint8_t*)"100";
-
- E2SM_KPM_IndicationHeader_Format1_t* ind_header =
- (E2SM_KPM_IndicationHeader_Format1_t*)calloc(1,sizeof(E2SM_KPM_IndicationHeader_Format1_t));
-
- // long fqival = 9;
- // long qcival = 9;
-
- SNSSAI_t *snssai = (SNSSAI_t*)calloc(1, sizeof(SNSSAI_t));
- ASN_STRUCT_RESET(asn_DEF_SNSSAI,snssai);
- snssai->sST.buf = (uint8_t*)calloc(1,1);
- snssai->sST.size = 1;
- memcpy(snssai->sST.buf, sst_buf, 1);
- snssai->sD = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
- snssai->sD->buf = (uint8_t*)calloc(1,3);
- snssai->sD->size = 3;
- memcpy(snssai->sD->buf, sd_buf, 3);
-
- BIT_STRING_t *nrcellid = (BIT_STRING_t*)calloc(1, sizeof(BIT_STRING_t));;
- nrcellid->buf = (uint8_t*)calloc(1,5);
- nrcellid->size = 5;
- memcpy(nrcellid->buf, nrcellid_buf, 5);
- /*
- nrcellid->buf[0] = 0x22;
- nrcellid->buf[1] = 0x5B;
- nrcellid->buf[2] = 0xD6;
- nrcellid->buf[3] = 0x00;
- nrcellid->buf[4] = 0x70;
- */
- nrcellid->bits_unused = 4;
-
-
- INTEGER_t *cuup_id = (INTEGER_t*)calloc(1, sizeof(INTEGER_t));
- // uint8_t buffer[1];
- // buffer[0] = 20000;
- cuup_id->buf = (uint8_t*)calloc(1,1);
- memcpy(cuup_id->buf, cuupid_buf, 1);
- cuup_id->size = 1;
-
- INTEGER_t *du_id = (INTEGER_t*)calloc(1, sizeof(INTEGER_t));
- // uint8_t buffer_duid[1];
- // buffer_duid[0] = 20000;
- du_id->buf = (uint8_t*)calloc(1,1);
- memcpy(du_id->buf, duid_buf, 1);
- du_id->size = 1;
-
-
- // uint8_t *buf5 = (uint8_t*)"GNBCUUP5";
- OCTET_STRING_t *cuupname = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
- cuupname->size = 8;
- cuupname->buf = (uint8_t*)calloc(1,8);
- memcpy(cuupname->buf, cuupname_buf, cuupname->size);
-
- OCTET_STRING_t *plmnid_id_GlobalKPMnode_ID = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- plmnid_id_GlobalKPMnode_ID->size = strlen((char *)plmnid_buf);
- plmnid_id_GlobalKPMnode_ID->buf = (uint8_t*)calloc(plmnid_id_GlobalKPMnode_ID->size, sizeof(uint8_t));
- memcpy(plmnid_id_GlobalKPMnode_ID->buf, plmnid_buf, plmnid_id_GlobalKPMnode_ID->size);
-
- BIT_STRING_t *gnb_bstring_id_GlobalKPMnode_ID = (BIT_STRING_t*)calloc(1, sizeof(BIT_STRING_t));
- gnb_bstring_id_GlobalKPMnode_ID->size = strlen((char *)gnbid_buf);
- gnb_bstring_id_GlobalKPMnode_ID->buf = (uint8_t*)calloc(gnb_bstring_id_GlobalKPMnode_ID->size, sizeof(uint8_t));
- memcpy(gnb_bstring_id_GlobalKPMnode_ID->buf, gnbid_buf, gnb_bstring_id_GlobalKPMnode_ID->size);
- gnb_bstring_id_GlobalKPMnode_ID->bits_unused = gnbid_unused;
-
- ind_header->id_GlobalKPMnode_ID = (GlobalKPMnode_ID*)calloc(1,sizeof(GlobalKPMnode_ID));
- ind_header->id_GlobalKPMnode_ID->present = GlobalKPMnode_ID_PR_gNB;
- ind_header->id_GlobalKPMnode_ID->choice.gNB.global_gNB_ID.gnb_id.present = GNB_ID_Choice_PR_gnb_ID;
- ind_header->id_GlobalKPMnode_ID->choice.gNB.global_gNB_ID.gnb_id.choice.gnb_ID = *gnb_bstring_id_GlobalKPMnode_ID;
- ind_header->id_GlobalKPMnode_ID->choice.gNB.global_gNB_ID.plmn_id = *plmnid_id_GlobalKPMnode_ID;
- ind_header->id_GlobalKPMnode_ID->choice.gNB.gNB_CU_UP_ID = cuup_id;
- if (plmnid_id_GlobalKPMnode_ID) free(plmnid_id_GlobalKPMnode_ID);
- if (gnb_bstring_id_GlobalKPMnode_ID) free(gnb_bstring_id_GlobalKPMnode_ID);
-
-
- OCTET_STRING_t *plmnid_nRCGI = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- plmnid_nRCGI->buf = (uint8_t*)calloc(3,1);
- plmnid_nRCGI->size = 3;
- memcpy(plmnid_nRCGI->buf, plmnid_buf, plmnid_nRCGI->size);
-
- ind_header->nRCGI = (NRCGI*)calloc(1,sizeof(NRCGI));
- ind_header->nRCGI->pLMN_Identity = *plmnid_nRCGI;
- ind_header->nRCGI->nRCellIdentity = *nrcellid;
- if (plmnid_nRCGI) free(plmnid_nRCGI);
- if (nrcellid) free(nrcellid);
-
-
- OCTET_STRING_t *plmnid = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- plmnid->buf = (uint8_t*)calloc(3,1);
- plmnid->size = 3;
- memcpy(plmnid->buf, plmnid_buf, plmnid->size);
-
- ind_header->pLMN_Identity = plmnid;
- // memcpy(ind_header->fiveQI, &fqival, 4);
-
- ind_header->sliceID = snssai;
- // memcpy(ind_header->qci, &qcival, 4);
-
-
- ind_header->gNB_Name = (GNB_Name*)calloc(1,sizeof(GNB_Name));
- ind_header->gNB_Name->present = GNB_Name_PR_gNB_CU_UP_Name;
- ind_header->gNB_Name->choice.gNB_CU_UP_Name = *cuupname;
- if (cuupname) free(cuupname);
-
-
- OCTET_STRING_t *plmnid_global_GNB_ID = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- plmnid_global_GNB_ID->buf = (uint8_t*)calloc(3,1);
- plmnid_global_GNB_ID->size = 3;
- memcpy(plmnid_global_GNB_ID->buf, plmnid_buf, plmnid_global_GNB_ID->size);
-
- BIT_STRING_t *gnb_bstring_global_GNB_ID = (BIT_STRING_t*)calloc(1, sizeof(BIT_STRING_t));;
- gnb_bstring_global_GNB_ID->buf = (uint8_t*)calloc(1,4);
- gnb_bstring_global_GNB_ID->size = 4;
- memcpy(gnb_bstring_global_GNB_ID->buf, gnbid_buf, 4);
- gnb_bstring_global_GNB_ID->bits_unused = gnbid_unused;
-
- ind_header->global_GNB_ID = (GlobalgNB_ID*)calloc(1,sizeof(GlobalgNB_ID));
- ind_header->global_GNB_ID->plmn_id = *plmnid_global_GNB_ID;
- ind_header->global_GNB_ID->gnb_id.present = GNB_ID_Choice_PR_gnb_ID;
- ind_header->global_GNB_ID->gnb_id.choice.gnb_ID = *gnb_bstring_global_GNB_ID;
- if (plmnid_global_GNB_ID) free(plmnid_global_GNB_ID);
- if (gnb_bstring_global_GNB_ID) free(gnb_bstring_global_GNB_ID);
-
-
- // long msg_type = 2;
- // ind_header->message_Type = &msg_type;
- ind_header->gNB_DU_ID = du_id;
-
-
- ihead->present = E2SM_KPM_IndicationHeader_PR_indicationHeader_Format1;
- ihead->choice.indicationHeader_Format1 = *ind_header;
- if (ind_header) free(ind_header);
-
- xer_fprint(stderr, &asn_DEF_E2SM_KPM_IndicationHeader, ihead);
-
-}
-
-
-
-void encode_kpm_ocuup_user_level(RAN_Container_t *ranco,
- uint8_t *plmnid_buf,
- uint8_t *nrcellid_buf,
- uint8_t *crnti_buf,
- int bytes_dl,
- int bytes_ul) {
-
- uint8_t *buf = (uint8_t*)"2020.06.13 13:01:05.222";
- Timestamp_t *ts = (Timestamp_t*)calloc(1,sizeof(Timestamp_t));
- ts->buf = (uint8_t*)calloc(strlen((char*)buf),1);
- ts->size = strlen((char*)buf);
- memcpy(ts->buf,buf,ts->size);
-
- printf("enc1\n");
-
- CU_UP_Usage_Report_CellResourceReportItem_t *report_item =
- (CU_UP_Usage_Report_CellResourceReportItem_t*)calloc(1,sizeof(CU_UP_Usage_Report_CellResourceReportItem_t));
-
- // uint8_t *buf2 = (uint8_t*)"747";
-
- OCTET_STRING_t *plmnidstr = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- plmnidstr->buf = (uint8_t*)calloc(3,1);
- plmnidstr->size = 3;
- memcpy(plmnidstr->buf, plmnid_buf, plmnidstr->size);
-
- printf("enc2\n");
-
- NRCellIdentity_t *nrcellid = (NRCellIdentity_t*)calloc(1,sizeof(NRCellIdentity_t));
- // uint8_t* buf3 = (uint8_t*)"12340";
- nrcellid->buf = (uint8_t*)calloc(1,5);
- memcpy(nrcellid->buf, nrcellid_buf, 5);
- nrcellid->size = 5;
- nrcellid->bits_unused = 4;
-
- NRCGI *nrcgi = (NRCGI*)calloc(1,sizeof(NRCGI));
- nrcgi->pLMN_Identity = *plmnidstr;
- nrcgi->nRCellIdentity = *nrcellid;
- if (plmnidstr) free(plmnidstr);
- if (nrcellid) free(nrcellid);
-
- printf("enc3\n");
-
- report_item->nRCGI = *nrcgi;
- if (nrcgi) free(nrcgi);
-
- CU_UP_Usage_Report_UeResourceReportItem *ue_report_item =
- (CU_UP_Usage_Report_UeResourceReportItem*)calloc(1,sizeof(CU_UP_Usage_Report_UeResourceReportItem));
-
- printf("enc3.2\n");
-
- // uint8_t* crnti_str = (uint8_t*)"1111";
- OCTET_STRING *crnti = (OCTET_STRING*)calloc(1,sizeof(OCTET_STRING));
- crnti->buf = (uint8_t*)calloc(1,4);
-
- printf("enc3.3\n");
-
- crnti->size = strlen((char*)crnti_buf);
-
- printf("enc3.4\n");
- memcpy(crnti->buf, crnti_buf, crnti->size);
-
- printf("enc4\n");
-
- INTEGER_t *bytesdl = (INTEGER_t*)calloc(1, sizeof(INTEGER_t));
- int array_size_dl;
-
- if (bytes_dl <= 64) {
- array_size_dl = 1;
-
- uint8_t buffer[array_size_dl];
- buffer[0] = bytes_dl & 0xFF;
- bytesdl->buf = (uint8_t*)calloc(1,1);
- memcpy(bytesdl->buf,buffer,1);
- bytesdl->size = 1;
-
- } else if (bytes_dl <= 16384) {
- array_size_dl = 2;
-
- uint8_t buffer[array_size_dl];
- buffer[0] = (bytes_dl >> 8) & 0xFF;
- buffer[1] = bytes_dl & 0xFF;
- bytesdl->buf = (uint8_t*)calloc(2,1);
- memcpy(bytesdl->buf,buffer,2);
- bytesdl->size = 2;
-
- } else if (bytes_dl <= 4194304) {
- array_size_dl = 3;
-
- uint8_t buffer[array_size_dl];
- buffer[0] = (bytes_dl >> 16) & 0xFF;
- buffer[1] = (bytes_dl >> 8) & 0xFF;
- buffer[2] = bytes_dl & 0xFF;
- bytesdl->buf = (uint8_t*)calloc(3,1);
- memcpy(bytesdl->buf,buffer,3);
- bytesdl->size = 3;
-
- } else if (bytes_dl <= 1073741824) {
- array_size_dl = 4;
- uint8_t buffer[array_size_dl];
- buffer[0] = (bytes_dl >> 24) & 0xFF;
- buffer[1] = (bytes_dl >> 16) & 0xFF;
- buffer[2] = (bytes_dl >> 8) & 0xFF;
- buffer[3] = bytes_dl & 0xFF;
- bytesdl->buf = (uint8_t*)calloc(4,1);
- memcpy(bytesdl->buf,buffer,4);
- bytesdl->size = 4;
- }
-
-
- INTEGER_t *bytesul = (INTEGER_t*)calloc(1, sizeof(INTEGER_t));
-
- int array_size_ul;
-
- if (bytes_ul <= 64) {
- array_size_ul = 1;
-
- uint8_t buffer[array_size_ul];
- buffer[0] = bytes_ul & 0xFF;
- bytesul->buf = (uint8_t*)calloc(1,1);
- memcpy(bytesul->buf,buffer,1);
- bytesul->size = 1;
-
- } else if (bytes_ul <= 16384) {
- array_size_ul = 2;
-
- uint8_t buffer[array_size_ul];
- buffer[0] = (bytes_ul >> 8) & 0xFF;
- buffer[1] = bytes_ul & 0xFF;
- bytesul->buf = (uint8_t*)calloc(2,1);
- memcpy(bytesul->buf,buffer,2);
- bytesul->size = 2;
-
- } else if (bytes_ul <= 4194304) {
- array_size_ul = 3;
-
- uint8_t buffer[array_size_ul];
- buffer[0] = (bytes_ul >> 16) & 0xFF;
- buffer[1] = (bytes_ul >> 8) & 0xFF;
- buffer[2] = bytes_ul & 0xFF;
- bytesul->buf = (uint8_t*)calloc(3,1);
- memcpy(bytesul->buf,buffer,3);
- bytesul->size = 3;
-
- } else if (bytes_ul <= 1073741824) {
- array_size_ul = 4;
- uint8_t buffer[array_size_ul];
- buffer[0] = (bytes_ul >> 24) & 0xFF;
- buffer[1] = (bytes_ul >> 16) & 0xFF;
- buffer[2] = (bytes_ul >> 8) & 0xFF;
- buffer[3] = bytes_ul & 0xFF;
- bytesul->buf = (uint8_t*)calloc(4,1);
- memcpy(bytesul->buf,buffer,4);
- bytesul->size = 4;
- }
-
-
-
- ue_report_item->c_RNTI = *crnti;
- ue_report_item->pDCPBytesDL = bytesdl;
- ue_report_item->pDCPBytesUL = bytesul;
- if (crnti) free(crnti);
-
-
- ASN_SEQUENCE_ADD(&report_item->ueResourceReportList.list, ue_report_item);
-
- ranco->timestamp = *ts;
- ranco->reportContainer.present = RAN_Container__reportContainer_PR_oCU_UP_UE;
- ASN_SEQUENCE_ADD(&ranco->reportContainer.choice.oCU_UP_UE.cellResourceReportList.list, report_item);
- if (ts) free(ts);
-
- xer_fprint(stderr, &asn_DEF_RAN_Container, ranco);
-
-}
-
-void encode_kpm_ocucp_user_level(RAN_Container_t *ranco,
- uint8_t *plmnid_buf,
- uint8_t *nrcellid_buf,
- uint8_t *crnti_buf,
- const uint8_t *serving_buf,
- const uint8_t *neighbor_buf) {
- uint8_t *buf = (uint8_t*)"2020.06.13 13:01:05.222";
- Timestamp_t *ts = (Timestamp_t*)calloc(1,sizeof(Timestamp_t));
- ts->buf = (uint8_t*)calloc(strlen((char*)buf),1);
- ts->size = strlen((char*)buf);
- memcpy(ts->buf,buf,ts->size);
-
- printf("enc1\n");
-
- CU_CP_Usage_Report_CellResourceReportItem_t *report_item =
- (CU_CP_Usage_Report_CellResourceReportItem_t*)calloc(1,sizeof(CU_CP_Usage_Report_CellResourceReportItem_t));
-
- int plmnid_size = strlen((char*)plmnid_buf);
- OCTET_STRING_t *plmnidstr = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- plmnidstr->buf = (uint8_t*)calloc(plmnid_size,1);
- plmnidstr->size = plmnid_size;
- memcpy(plmnidstr->buf, plmnid_buf, plmnidstr->size);
-
- printf("enc2\n");
-
- NRCellIdentity_t *nrcellid = (NRCellIdentity_t*)calloc(1,sizeof(NRCellIdentity_t));
-
- // int nrcellid_size = strlen((char*)nrcellid_buf);
- int nrcellid_size = 5;
- nrcellid->buf = (uint8_t*)calloc(1, nrcellid_size);
- memcpy(nrcellid->buf, nrcellid_buf, nrcellid_size);
- nrcellid->size = 5;
- nrcellid->bits_unused = 4;
-
- NRCGI *nrcgi = (NRCGI*)calloc(1,sizeof(NRCGI));
- nrcgi->pLMN_Identity = *plmnidstr;
- nrcgi->nRCellIdentity = *nrcellid;
- if (plmnidstr) free(plmnidstr);
- if (nrcellid) free(nrcellid);
-
- printf("enc3\n");
-
- report_item->nRCGI = *nrcgi;
- if (nrcgi) free(nrcgi);
-
- CU_CP_Usage_Report_UeResourceReportItem *ue_report_item =
- (CU_CP_Usage_Report_UeResourceReportItem*)calloc(1,sizeof(CU_CP_Usage_Report_UeResourceReportItem));
-
- printf("enc3.2\n");
-
-
- int crnti_size = strlen((char*)crnti_buf);
- OCTET_STRING *crnti = (OCTET_STRING*)calloc(1,sizeof(OCTET_STRING));
- crnti->buf = (uint8_t*)calloc(1, crnti_size);
-
- printf("enc3.3\n");
-
- crnti->size = strlen((char*)crnti_buf);
-
- printf("enc3.4\n");
- memcpy(crnti->buf, crnti_buf, crnti->size);
-
- // uint8_t *buf_serving = (uint8_t*)"RSRP10";
-
- int serving_buf_len = strlen((char*)serving_buf);
- OCTET_STRING_t *servingstr = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- servingstr->buf = (uint8_t*)calloc(serving_buf_len,1);
- servingstr->size = serving_buf_len;
- memcpy(servingstr->buf, serving_buf, servingstr->size);
-
-
- int neighbor_buf_len = strlen((char*)neighbor_buf);
- // uint8_t *buf_neighbor = (uint8_t*)"-10,-15";
- OCTET_STRING_t *neighborstr = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- ts->buf = (uint8_t*)calloc(neighbor_buf_len,1);
- neighborstr->buf = (uint8_t*)calloc(neighbor_buf_len,1);
- neighborstr->size = neighbor_buf_len;
- memcpy(neighborstr->buf, neighbor_buf, neighborstr->size);
-
- ue_report_item->c_RNTI = *crnti;
- ue_report_item->serving_Cell_RF_Type = servingstr;
- ue_report_item->neighbor_Cell_RF = neighborstr;
- if (crnti) free(crnti);
-
-
- ASN_SEQUENCE_ADD(&report_item->ueResourceReportList.list, ue_report_item);
-
- ranco->timestamp = *ts;
- ranco->reportContainer.present = RAN_Container__reportContainer_PR_oCU_CP_UE;
- ASN_SEQUENCE_ADD(&ranco->reportContainer.choice.oCU_CP_UE.cellResourceReportList.list, report_item);
- if (ts->buf) free(ts->buf);
- if (ts) free(ts);
-
- xer_fprint(stderr, &asn_DEF_RAN_Container, ranco);
-
-
-}
-
-void encode_kpm_ocucp_user_level(RAN_Container_t *ranco) {
-
- uint8_t *buf = (uint8_t*)"2020.06.13 13:01:05.222";
- Timestamp_t *ts = (Timestamp_t*)calloc(1,sizeof(Timestamp_t));
- ts->buf = (uint8_t*)calloc(strlen((char*)buf),1);
- ts->size = strlen((char*)buf);
- memcpy(ts->buf,buf,ts->size);
-
- printf("enc1\n");
-
- CU_CP_Usage_Report_CellResourceReportItem_t *report_item =
- (CU_CP_Usage_Report_CellResourceReportItem_t*)calloc(1,sizeof(CU_CP_Usage_Report_CellResourceReportItem_t));
-
- uint8_t *buf2 = (uint8_t*)"747";
-
- OCTET_STRING_t *plmnidstr = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- plmnidstr->buf = (uint8_t*)calloc(3,1);
- plmnidstr->size = 3;
- memcpy(plmnidstr->buf, buf2, plmnidstr->size);
-
- printf("enc2\n");
-
- NRCellIdentity_t *nrcellid = (NRCellIdentity_t*)calloc(1,sizeof(NRCellIdentity_t));
- uint8_t* buf3 = (uint8_t*)"12340";
- nrcellid->buf = (uint8_t*)calloc(1,5);
- memcpy(nrcellid->buf, buf3, 5);
- nrcellid->size = 5;
- nrcellid->bits_unused = 4;
-
- NRCGI *nrcgi = (NRCGI*)calloc(1,sizeof(NRCGI));
- nrcgi->pLMN_Identity = *plmnidstr;
- nrcgi->nRCellIdentity = *nrcellid;
-
- printf("enc3\n");
-
- report_item->nRCGI = *nrcgi;
- if (nrcgi) free(nrcgi);
-
- CU_CP_Usage_Report_UeResourceReportItem *ue_report_item =
- (CU_CP_Usage_Report_UeResourceReportItem*)calloc(1,sizeof(CU_CP_Usage_Report_UeResourceReportItem));
-
- printf("enc3.2\n");
-
- uint8_t* crnti_str = (uint8_t*)"1111";
- OCTET_STRING *crnti = (OCTET_STRING*)calloc(1,sizeof(OCTET_STRING));
- crnti->buf = (uint8_t*)calloc(1,4);
-
- printf("enc3.3\n");
-
- crnti->size = strlen((char*)crnti_str);
-
- printf("enc3.4\n");
- memcpy(crnti->buf, crnti_str, crnti->size);
-
- uint8_t *buf_serving = (uint8_t*)"RSRP10";
- OCTET_STRING_t *servingstr = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- servingstr->buf = (uint8_t*)calloc(6,1);
- servingstr->size = 6;
- memcpy(servingstr->buf, buf_serving, servingstr->size);
-
- uint8_t *buf_neighbor = (uint8_t*)"-10,-15";
- OCTET_STRING_t *neighborstr = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- neighborstr->buf = (uint8_t*)calloc(7,1);
- neighborstr->size = 7;
- memcpy(neighborstr->buf, buf_neighbor, neighborstr->size);
-
- ue_report_item->c_RNTI = *crnti;
- ue_report_item->serving_Cell_RF_Type = servingstr;
- ue_report_item->neighbor_Cell_RF = neighborstr;
-
-
- ASN_SEQUENCE_ADD(&report_item->ueResourceReportList.list, ue_report_item);
-
- ranco->timestamp = *ts;
- ranco->reportContainer.present = RAN_Container__reportContainer_PR_oCU_CP_UE;
- ASN_SEQUENCE_ADD(&ranco->reportContainer.choice.oCU_CP_UE.cellResourceReportList.list, report_item);
-
- xer_fprint(stderr, &asn_DEF_RAN_Container, ranco);
-
-}
-
-
-void encode_kpm_odu_user_level(RAN_Container_t *ranco,
- uint8_t *plmnid_buf,
- uint8_t *nrcellid_buf,
- uint8_t *crnti_buf,
- long prb_usage_dl,
- long prb_usage_ul) {
-
- uint8_t *buf = (uint8_t*)"2020.06.13 13:01:05.222";
- Timestamp_t *ts = (Timestamp_t*)calloc(1,sizeof(Timestamp_t));
- ts->buf = (uint8_t*)calloc(strlen((char*)buf),1);
- ts->size = strlen((char*)buf);
- memcpy(ts->buf,buf,ts->size);
-
- printf("enc1\n");
-
- DU_Usage_Report_CellResourceReportItem_t *report_item =
- (DU_Usage_Report_CellResourceReportItem_t*)calloc(1,sizeof(DU_Usage_Report_CellResourceReportItem_t));
-
- // uint8_t *buf2 = (uint8_t*)"747";
-
- int plmnid_size = strlen((char*)plmnid_buf);
- OCTET_STRING_t *plmnidstr = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- plmnidstr->buf = (uint8_t*)calloc(plmnid_size,1);
- plmnidstr->size = plmnid_size;
- memcpy(plmnidstr->buf, plmnid_buf, plmnidstr->size);
-
- printf("enc2\n");
-
- NRCellIdentity_t *nrcellid = (NRCellIdentity_t*)calloc(1,sizeof(NRCellIdentity_t));
-
- // int nrcellid_size = strlen((char*)nrcellid_buf);
- int nrcellid_size = 5;
- nrcellid->buf = (uint8_t*)calloc(1,nrcellid_size);
- memcpy(nrcellid->buf, nrcellid_buf, nrcellid_size);
- nrcellid->size = nrcellid_size;
- nrcellid->bits_unused = 4;
-
- NRCGI *nrcgi = (NRCGI*)calloc(1,sizeof(NRCGI));
- nrcgi->pLMN_Identity = *plmnidstr;
- nrcgi->nRCellIdentity = *nrcellid;
- if (plmnidstr) free(plmnidstr);
- if (nrcellid) free(nrcellid);
-
- printf("enc3\n");
-
- report_item->nRCGI = *nrcgi;
- if (nrcgi) free(nrcgi);
-
- printf("enc3.1\n");
-
- DU_Usage_Report_UeResourceReportItem *ue_report_item =
- (DU_Usage_Report_UeResourceReportItem*)calloc(1,sizeof(DU_Usage_Report_UeResourceReportItem));
-
- printf("enc3.2\n");
-
- int crnti_size = strlen((char*)crnti_buf);
-
- OCTET_STRING *crnti = (OCTET_STRING*)calloc(1,sizeof(OCTET_STRING));
- crnti->buf = (uint8_t*)calloc(1,crnti_size);
-
- printf("enc3.3\n");
-
- crnti->size = strlen((char*)crnti_buf);
-
- printf("enc3.4\n");
- memcpy(crnti->buf, crnti_buf, crnti->size);
-
- printf("enc4\n");
-
- long *p_prb_usage_dl = (long*)calloc(1, sizeof(long));
- long *p_prb_usage_ul = (long*)calloc(1, sizeof(long));
- *p_prb_usage_dl = (long)prb_usage_dl;
- *p_prb_usage_ul = (long)prb_usage_ul;
-
- ue_report_item->c_RNTI = *crnti;
- ue_report_item->dl_PRBUsage = p_prb_usage_dl;
- if (crnti) free(crnti);
-
- printf("enc5\n");
-
- ue_report_item->ul_PRBUsage = p_prb_usage_ul;
-
- printf("enc6\n");
-
- ASN_SEQUENCE_ADD(&report_item->ueResourceReportList.list, ue_report_item);
-
-
- ranco->timestamp = *ts;
- ranco->reportContainer.present = RAN_Container__reportContainer_PR_oDU_UE;
- ASN_SEQUENCE_ADD(&ranco->reportContainer.choice.oDU_UE.cellResourceReportList.list, report_item);
- if (ts) free(ts);
-
- xer_fprint(stderr, &asn_DEF_RAN_Container, ranco);
-
-
-}
-
-void encode_kpm_report_rancontainer_du_parameterized(E2SM_KPM_IndicationMessage_t* indicationmessage,
- uint8_t *plmnid_buf,
- uint8_t *nrcellid_buf,
- uint8_t *crnti_buf,
- long prb_usage_dl,
- long prb_usage_ul) {
-
- RAN_Container_t *ranco = (RAN_Container_t*)calloc(1,sizeof(RAN_Container_t));
- encode_kpm_odu_user_level(ranco,plmnid_buf,nrcellid_buf,crnti_buf,prb_usage_dl,prb_usage_ul);
-
- printf("After creating RAN container, xer printing it\n");
- xer_fprint(stderr, &asn_DEF_RAN_Container, ranco);
-
- PM_Containers_List_t *containers_list = (PM_Containers_List_t*)calloc(1, sizeof(PM_Containers_List_t));
- ASN_STRUCT_RESET(asn_DEF_PM_Containers_List, containers_list);
- containers_list->theRANContainer = ranco;
-
- E2SM_KPM_IndicationMessage_Format1_t *format =
- (E2SM_KPM_IndicationMessage_Format1_t*)calloc(1, sizeof(E2SM_KPM_IndicationMessage_Format1_t));
- ASN_STRUCT_RESET(asn_DEF_E2SM_KPM_IndicationMessage_Format1, format);
-
- int ret = ASN_SEQUENCE_ADD(&format->pm_Containers.list, containers_list);
-
- E2SM_KPM_IndicationMessage__indicationMessage_PR pres = E2SM_KPM_IndicationMessage__indicationMessage_PR_indicationMessage_Format1;
-
- indicationmessage->indicationMessage.present = pres;
-
- indicationmessage->indicationMessage.choice.indicationMessage_Format1 = *format;
- if (format) free(format);
-
- char error_buf[300] = {0, };
- size_t errlen = 0;
-
- asn_check_constraints(&asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage, error_buf, &errlen);
- printf("error length %d\n", errlen);
- printf("error buf %s\n", error_buf);
-
- xer_fprint(stderr, &asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage);
-
- asn_codec_ctx_t *opt_cod;
-
- uint8_t e2smbuffer[8192] = {0, };
- size_t e2smbuffer_size = 8192;
-
- uint8_t e2smbuffer2[8192] = {0, };
- size_t e2smbuffer_size2 = 8192;
-
- asn_enc_rval_t er =
- asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_IndicationMessage,
- indicationmessage, e2smbuffer, e2smbuffer_size);
-
- fprintf(stderr, "er encded is %d\n", er.encoded);
- fprintf(stderr, "after encoding message\n");
-
-
-}
-
-void encode_kpm_report_rancontainer_cucp_parameterized(E2SM_KPM_IndicationMessage_t* indicationmessage,
- uint8_t *plmnid_buf,
- uint8_t *nrcellid_buf,
- uint8_t *crnti_buf,
- const uint8_t *serving_buf,
- const uint8_t *neighbor_buf) {
-
- RAN_Container_t *ranco = (RAN_Container_t*)calloc(1,sizeof(RAN_Container_t));
- encode_kpm_ocucp_user_level(ranco, plmnid_buf,
- nrcellid_buf, crnti_buf,
- serving_buf, neighbor_buf);
-
- printf("After creating RAN container, xer printing it\n");
- xer_fprint(stderr, &asn_DEF_RAN_Container, ranco);
-
-
- PM_Containers_List_t *containers_list = (PM_Containers_List_t*)calloc(1, sizeof(PM_Containers_List_t));
- ASN_STRUCT_RESET(asn_DEF_PM_Containers_List, containers_list);
- containers_list->theRANContainer = ranco;
-
- E2SM_KPM_IndicationMessage_Format1_t *format =
- (E2SM_KPM_IndicationMessage_Format1_t*)calloc(1, sizeof(E2SM_KPM_IndicationMessage_Format1_t));
- ASN_STRUCT_RESET(asn_DEF_E2SM_KPM_IndicationMessage_Format1, format);
-
- int ret = ASN_SEQUENCE_ADD(&format->pm_Containers.list, containers_list);
-
- E2SM_KPM_IndicationMessage__indicationMessage_PR pres = E2SM_KPM_IndicationMessage__indicationMessage_PR_indicationMessage_Format1;
-
- indicationmessage->indicationMessage.present = pres;
-
- indicationmessage->indicationMessage.choice.indicationMessage_Format1 = *format;
- if (format) free(format);
-
- char error_buf[300] = {0, };
- size_t errlen = 0;
-
- asn_check_constraints(&asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage, error_buf, &errlen);
- printf("error length %d\n", errlen);
- printf("error buf %s\n", error_buf);
-
- xer_fprint(stderr, &asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage);
-
- asn_codec_ctx_t *opt_cod;
-
- uint8_t e2smbuffer[8192] = {0, };
- size_t e2smbuffer_size = 8192;
-
- uint8_t e2smbuffer2[8192] = {0, };
- size_t e2smbuffer_size2 = 8192;
-
- asn_enc_rval_t er =
- asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_IndicationMessage,
- indicationmessage, e2smbuffer, e2smbuffer_size);
-
- fprintf(stderr, "er encded is %d\n", er.encoded);
- fprintf(stderr, "after encoding message\n");
-
-}
-
-
-void encode_kpm_report_rancontainer_cucp(E2SM_KPM_IndicationMessage_t* indicationmessage) {
-
- RAN_Container_t *ranco = (RAN_Container_t*)calloc(1,sizeof(RAN_Container_t));
- encode_kpm_ocucp_user_level(ranco);
-
- PM_Containers_List_t *containers_list = (PM_Containers_List_t*)calloc(1, sizeof(PM_Containers_List_t));
- ASN_STRUCT_RESET(asn_DEF_PM_Containers_List, containers_list);
- containers_list->theRANContainer = ranco;
-
- E2SM_KPM_IndicationMessage_Format1_t *format =
- (E2SM_KPM_IndicationMessage_Format1_t*)calloc(1, sizeof(E2SM_KPM_IndicationMessage_Format1_t));
- ASN_STRUCT_RESET(asn_DEF_E2SM_KPM_IndicationMessage_Format1, format);
-
- int ret = ASN_SEQUENCE_ADD(&format->pm_Containers.list, containers_list);
-
- E2SM_KPM_IndicationMessage__indicationMessage_PR pres = E2SM_KPM_IndicationMessage__indicationMessage_PR_indicationMessage_Format1;
-
- indicationmessage->indicationMessage.present = pres;
-
- indicationmessage->indicationMessage.choice.indicationMessage_Format1 = *format;
- if (format) free(format);
-
- char error_buf[300] = {0, };
- size_t errlen = 0;
-
- asn_check_constraints(&asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage, error_buf, &errlen);
- printf("error length %d\n", errlen);
- printf("error buf %s\n", error_buf);
-
- // xer_fprint(stderr, &asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage);
-
- asn_codec_ctx_t *opt_cod;
-
- uint8_t e2smbuffer[8192] = {0, };
- size_t e2smbuffer_size = 8192;
-
- uint8_t e2smbuffer2[8192] = {0, };
- size_t e2smbuffer_size2 = 8192;
-
- asn_enc_rval_t er =
- asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_IndicationMessage,
- indicationmessage, e2smbuffer, e2smbuffer_size);
-
- fprintf(stderr, "er encded is %d\n", er.encoded);
- fprintf(stderr, "after encoding message\n");
-
-
-}
-
-void encode_kpm_report_rancontainer_cuup_parameterized(E2SM_KPM_IndicationMessage_t* indicationmessage,
- uint8_t *plmnid_buf,
- uint8_t *nrcellid_buf,
- uint8_t *crnti_buf,
- int pdcp_bytesdl,
- int pdcp_bytesul) {
-
- RAN_Container_t *ranco = (RAN_Container_t*)calloc(1,sizeof(RAN_Container_t));
- encode_kpm_ocuup_user_level(ranco,plmnid_buf,nrcellid_buf,crnti_buf,pdcp_bytesdl,pdcp_bytesul);
-
- fprintf(stderr, "After creating RAN container, xer printing it\n");
- xer_fprint(stderr, &asn_DEF_RAN_Container, ranco);
-
- PM_Containers_List_t *containers_list = (PM_Containers_List_t*)calloc(1, sizeof(PM_Containers_List_t));
- ASN_STRUCT_RESET(asn_DEF_PM_Containers_List, containers_list);
- containers_list->theRANContainer = ranco;
-
- E2SM_KPM_IndicationMessage_Format1_t *format =
- (E2SM_KPM_IndicationMessage_Format1_t*)calloc(1, sizeof(E2SM_KPM_IndicationMessage_Format1_t));
- ASN_STRUCT_RESET(asn_DEF_E2SM_KPM_IndicationMessage_Format1, format);
-
- int ret = ASN_SEQUENCE_ADD(&format->pm_Containers.list, containers_list);
-
- E2SM_KPM_IndicationMessage__indicationMessage_PR pres = E2SM_KPM_IndicationMessage__indicationMessage_PR_indicationMessage_Format1;
-
- indicationmessage->indicationMessage.present = pres;
-
- indicationmessage->indicationMessage.choice.indicationMessage_Format1 = *format;
- if (format) free(format);
-
- char error_buf[300] = {0, };
- size_t errlen = 0;
-
- asn_check_constraints(&asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage, error_buf, &errlen);
- printf("error length %d\n", errlen);
- printf("error buf %s\n", error_buf);
-
- xer_fprint(stderr, &asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage);
-
- asn_codec_ctx_t *opt_cod;
-
- uint8_t e2smbuffer[8192] = {0, };
- size_t e2smbuffer_size = 8192;
-
- uint8_t e2smbuffer2[8192] = {0, };
- size_t e2smbuffer_size2 = 8192;
-
- // xer_fprint(stderr, &asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage);
-
- asn_enc_rval_t er =
- asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_IndicationMessage,
- indicationmessage, e2smbuffer, e2smbuffer_size);
-
- fprintf(stderr, "er encded is %d\n", er.encoded);
- fprintf(stderr, "after encoding message\n");
-
-
-}
-
-void encode_kpm_report_rancontainer_cuup(E2SM_KPM_IndicationMessage_t* indicationmessage) {
-
- RAN_Container_t *ranco = (RAN_Container_t*)calloc(1,sizeof(RAN_Container_t));
- //encode_kpm_ocuup_user_level(ranco);
-
-
- uint8_t *buf = (uint8_t*)"2020.06.13 13:01:05.222";
- Timestamp_t *ts = (Timestamp_t*)calloc(1,sizeof(Timestamp_t));
- ts->buf = (uint8_t*)calloc(strlen((char*)buf),1);
- ts->size = strlen((char*)buf);
- memcpy(ts->buf,buf,ts->size);
-
- printf("enc1\n");
-
- CU_CP_Usage_Report_CellResourceReportItem_t *report_item =
- (CU_CP_Usage_Report_CellResourceReportItem_t*)calloc(1,sizeof(CU_CP_Usage_Report_CellResourceReportItem_t));
-
- uint8_t *buf2 = (uint8_t*)"747";
-
- OCTET_STRING_t *plmnidstr = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- plmnidstr->buf = (uint8_t*)calloc(3,1);
- plmnidstr->size = 3;
- memcpy(plmnidstr->buf, buf2, plmnidstr->size);
-
- printf("enc2\n");
-
- NRCellIdentity_t *nrcellid = (NRCellIdentity_t*)calloc(1,sizeof(NRCellIdentity_t));
- uint8_t* buf3 = (uint8_t*)"12340";
- nrcellid->buf = (uint8_t*)calloc(1,5);
- memcpy(nrcellid->buf, buf3, 5);
- nrcellid->size = 5;
- nrcellid->bits_unused = 4;
-
- NRCGI *nrcgi = (NRCGI*)calloc(1,sizeof(NRCGI));
- nrcgi->pLMN_Identity = *plmnidstr;
- nrcgi->nRCellIdentity = *nrcellid;
- if (plmnidstr) free(plmnidstr);
- if (nrcellid) free(nrcellid);
-
- printf("enc3\n");
-
- report_item->nRCGI = *nrcgi;
- if (nrcgi) free(nrcgi);
-
- CU_CP_Usage_Report_UeResourceReportItem *ue_report_item =
- (CU_CP_Usage_Report_UeResourceReportItem*)calloc(1,sizeof(CU_CP_Usage_Report_UeResourceReportItem));
-
- printf("enc3.2\n");
-
- uint8_t* crnti_str = (uint8_t*)"1111";
- OCTET_STRING *crnti = (OCTET_STRING*)calloc(1,sizeof(OCTET_STRING));
- crnti->buf = (uint8_t*)calloc(1,4);
-
- printf("enc3.3\n");
-
- crnti->size = strlen((char*)crnti_str);
-
- printf("enc3.4\n");
- memcpy(crnti->buf, crnti_str, crnti->size);
-
- uint8_t *buf_serving = (uint8_t*)"RSRP10";
- OCTET_STRING_t *servingstr = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- servingstr->buf = (uint8_t*)calloc(6,1);
- servingstr->size = 6;
- memcpy(servingstr->buf, buf_serving, servingstr->size);
-
- uint8_t *buf_neighbor = (uint8_t*)"-10,-15";
- OCTET_STRING_t *neighborstr = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- neighborstr->buf = (uint8_t*)calloc(7,1);
- neighborstr->size = 7;
- memcpy(neighborstr->buf, buf_neighbor, neighborstr->size);
-
- ue_report_item->c_RNTI = *crnti;
- ue_report_item->serving_Cell_RF_Type = servingstr;
- ue_report_item->neighbor_Cell_RF = neighborstr;
-
-
- ASN_SEQUENCE_ADD(&report_item->ueResourceReportList.list, ue_report_item);
-
- ranco->timestamp = *ts;
- ranco->reportContainer.present = RAN_Container__reportContainer_PR_oCU_CP_UE;
- ASN_SEQUENCE_ADD(&ranco->reportContainer.choice.oCU_CP_UE.cellResourceReportList.list, report_item);
-
- // xer_fprint(stderr, &asn_DEF_RAN_Container, ranco);
-
-
- PM_Containers_List_t *containers_list = (PM_Containers_List_t*)calloc(1, sizeof(PM_Containers_List_t));
- ASN_STRUCT_RESET(asn_DEF_PM_Containers_List, containers_list);
- containers_list->theRANContainer = ranco;
-
- E2SM_KPM_IndicationMessage_Format1_t *format =
- (E2SM_KPM_IndicationMessage_Format1_t*)calloc(1, sizeof(E2SM_KPM_IndicationMessage_Format1_t));
- ASN_STRUCT_RESET(asn_DEF_E2SM_KPM_IndicationMessage_Format1, format);
-
- int ret = ASN_SEQUENCE_ADD(&format->pm_Containers.list, containers_list);
-
- E2SM_KPM_IndicationMessage__indicationMessage_PR pres = E2SM_KPM_IndicationMessage__indicationMessage_PR_indicationMessage_Format1;
-
- indicationmessage->indicationMessage.present = pres;
-
- indicationmessage->indicationMessage.choice.indicationMessage_Format1 = *format;
- if (format) free(format);
-
- char error_buf[300] = {0, };
- size_t errlen = 0;
-
- asn_check_constraints(&asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage, error_buf, &errlen);
- printf("error length %d\n", errlen);
- printf("error buf %s\n", error_buf);
-
- xer_fprint(stderr, &asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage);
-
- asn_codec_ctx_t *opt_cod;
-
- uint8_t e2smbuffer[8192] = {0, };
- size_t e2smbuffer_size = 8192;
-
- uint8_t e2smbuffer2[8192] = {0, };
- size_t e2smbuffer_size2 = 8192;
-
- asn_enc_rval_t er =
- asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_IndicationMessage,
- indicationmessage, e2smbuffer, e2smbuffer_size);
-
- fprintf(stderr, "er encded is %d\n", er.encoded);
- fprintf(stderr, "after encoding message\n");
-
-
-}
-
-void encode_kpm_report_style1_parameterized(E2SM_KPM_IndicationMessage_t* indicationmessage,
- long fiveqi,
- long dl_prb_usage,
- long ul_prb_usage,
- uint8_t* sst_buf,
- uint8_t* sd_buf,
- uint8_t* plmnid_buf,
- uint8_t* nrcellid_buf,
- long *dl_prbs,
- long *ul_prbs) {
-
-
- asn_codec_ctx_t *opt_cod;
-
- FQIPERSlicesPerPlmnPerCellListItem_t *fqi_item =
- (FQIPERSlicesPerPlmnPerCellListItem_t*)calloc(1,sizeof(FQIPERSlicesPerPlmnPerCellListItem_t));
-
- long *p_dl_prb_usage = (long*)calloc(1, sizeof(long));
- long *p_ul_prb_usage = (long*)calloc(1, sizeof(long));
- *p_dl_prb_usage = (long)dl_prb_usage;
- *p_ul_prb_usage = (long)ul_prb_usage;
-
- fqi_item->fiveQI = fiveqi;
- fqi_item->dl_PRBUsage = p_dl_prb_usage;
- fqi_item->ul_PRBUsage = p_ul_prb_usage;
-
- uint8_t *buf1 = (uint8_t*)"4";
-
- // std::string sd = "SD1";
- // std::vector<uint8_t> sdvec(sd.begin(), sd.end());
- // uint8_t *bufz = &sdvec[0];
- uint8_t *bufz = (uint8_t*)"SD1";
-
- SNSSAI_t *snssai = (SNSSAI_t*)calloc(1, sizeof(SNSSAI_t));
- ASN_STRUCT_RESET(asn_DEF_SNSSAI,snssai);
- snssai->sST.buf = (uint8_t*)calloc(1,1);
- snssai->sST.size = 1;
- memcpy(snssai->sST.buf, sst_buf, 1);
- snssai->sD = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
- snssai->sD->buf = (uint8_t*)calloc(1,3);
- snssai->sD->size = 3;
- memcpy(snssai->sD->buf, sd_buf, 3);
-
-
- SlicePerPlmnPerCellListItem_t *sliceitem =
- (SlicePerPlmnPerCellListItem_t*)calloc(1,sizeof(SlicePerPlmnPerCellListItem_t));
- sliceitem->sliceID = *snssai;
- ASN_SEQUENCE_ADD(&sliceitem->fQIPERSlicesPerPlmnPerCellList.list, fqi_item);
- if (snssai) free(snssai);
-
- uint8_t *buf2 = (uint8_t*)"747";
-
- OCTET_STRING_t *plmnid = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- plmnid->buf = (uint8_t*)calloc(3,1);
- plmnid->size = 3;
- memcpy(plmnid->buf, plmnid_buf, plmnid->size);
-
- ServedPlmnPerCellListItem_t *percellitem1 =
- (ServedPlmnPerCellListItem_t*)calloc(1,sizeof(ServedPlmnPerCellListItem_t));
- percellitem1->pLMN_Identity = *plmnid;
- percellitem1->du_PM_5GC = (FGC_DU_PM_Container*)calloc(1,sizeof(FGC_DU_PM_Container));
- ASN_SEQUENCE_ADD(&percellitem1->du_PM_5GC->slicePerPlmnPerCellList.list, sliceitem);
- if (plmnid) free(plmnid);
-
- OCTET_STRING_t *plmnidstr = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- plmnidstr->buf = (uint8_t*)calloc(3,1);
- plmnidstr->size = 3;
- memcpy(plmnidstr->buf, plmnid_buf, plmnidstr->size);
-
- printf("enc2\n");
-
- NRCellIdentity_t *nrcellid = (NRCellIdentity_t*)calloc(1,sizeof(NRCellIdentity_t));
- uint8_t* buf3 = (uint8_t*)"12340";
- nrcellid->buf = (uint8_t*)calloc(1,5);
- memcpy(nrcellid->buf, nrcellid_buf, 5);
- nrcellid->size = 5;
- nrcellid->bits_unused = 4;
-
- NRCGI *nrcgi = (NRCGI*)calloc(1,sizeof(NRCGI));
- nrcgi->pLMN_Identity = *plmnidstr;
- nrcgi->nRCellIdentity = *nrcellid;
- if (plmnidstr) free(plmnidstr);
- if (nrcellid) free(nrcellid);
-
-
- CellResourceReportListItem_t *listitem1 = (CellResourceReportListItem_t*)calloc(1,sizeof(CellResourceReportListItem_t));
- listitem1->nRCGI = *nrcgi;
- listitem1->dl_TotalofAvailablePRBs = dl_prbs;
- listitem1->ul_TotalofAvailablePRBs = ul_prbs;
- ASN_SEQUENCE_ADD(&listitem1->servedPlmnPerCellList.list, percellitem1);
- if (nrcgi) free(nrcgi);
-
-
- ODU_PF_Container_t *ducont = (ODU_PF_Container_t*)calloc(1,sizeof(ODU_PF_Container_t));
- ASN_STRUCT_RESET(asn_DEF_ODU_PF_Container, ducont);
- int ret = ASN_SEQUENCE_ADD(&ducont->cellResourceReportList.list, listitem1);
-
- PF_Container_PR pres1 = PF_Container_PR_oDU;
-
- PF_Container_t *pfcontainer = (PF_Container_t*)calloc(1, sizeof(PF_Container_t));
- ASN_STRUCT_RESET(asn_DEF_PF_Container, pfcontainer);
- pfcontainer->present = pres1;
- pfcontainer->choice.oDU = *ducont;
- if (ducont) free(ducont);
-
- PM_Containers_List_t *containers_list = (PM_Containers_List_t*)calloc(1, sizeof(PM_Containers_List_t));
- ASN_STRUCT_RESET(asn_DEF_PM_Containers_List, containers_list);
- containers_list->performanceContainer = pfcontainer;
-
- E2SM_KPM_IndicationMessage_Format1_t *format =
- (E2SM_KPM_IndicationMessage_Format1_t*)calloc(1, sizeof(E2SM_KPM_IndicationMessage_Format1_t));
- ASN_STRUCT_RESET(asn_DEF_E2SM_KPM_IndicationMessage_Format1, format);
-
- ret = ASN_SEQUENCE_ADD(&format->pm_Containers.list, containers_list);
-
- E2SM_KPM_IndicationMessage__indicationMessage_PR pres = E2SM_KPM_IndicationMessage__indicationMessage_PR_indicationMessage_Format1;
-
- indicationmessage->indicationMessage.present = pres;
-
- indicationmessage->indicationMessage.choice.indicationMessage_Format1 = *format;
- if (format) free(format);
-
- char error_buf[300] = {0, };
- size_t errlen = 0;
-
- asn_check_constraints(&asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage, error_buf, &errlen);
- printf("error length %d\n", errlen);
- printf("error buf %s\n", error_buf);
-
- xer_fprint(stderr, &asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage);
-
-
- uint8_t e2smbuffer[8192] = {0, };
- size_t e2smbuffer_size = 8192;
-
- uint8_t e2smbuffer2[8192] = {0, };
- size_t e2smbuffer_size2 = 8192;
-
- asn_enc_rval_t er =
- asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_IndicationMessage,
- indicationmessage, e2smbuffer, e2smbuffer_size);
-
- fprintf(stderr, "er encded is %d\n", er.encoded);
- fprintf(stderr, "after encoding message\n");
-
-
-}
-
-
-void encode_kpm_report_style1(E2SM_KPM_IndicationMessage_t* indicationmessage) {
-
- long fiveqi = 8;
- long dl_prb_usage = 50;
- long ul_prb_usage = 70;
-
- asn_codec_ctx_t *opt_cod;
-
- FQIPERSlicesPerPlmnPerCellListItem_t *fqi_item =
- (FQIPERSlicesPerPlmnPerCellListItem_t*)calloc(1,sizeof(FQIPERSlicesPerPlmnPerCellListItem_t));
- fqi_item->fiveQI = fiveqi;
- fqi_item->dl_PRBUsage = &dl_prb_usage;
- fqi_item->ul_PRBUsage = &ul_prb_usage;
-
- uint8_t *buf1 = (uint8_t*)"4";
- // std::string sd = "SD1";
- // std::vector<uint8_t> sdvec(sd.begin(), sd.end());
- // uint8_t *bufz = &sdvec[0];
- uint8_t *bufz = (uint8_t*)"SD1";
-
- SNSSAI_t *snssai = (SNSSAI_t*)calloc(1, sizeof(SNSSAI_t));
- ASN_STRUCT_RESET(asn_DEF_SNSSAI,snssai);
- snssai->sST.buf = (uint8_t*)calloc(1,1);
- snssai->sST.size = 1;
- memcpy(snssai->sST.buf, buf1, 1);
- snssai->sD = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
- snssai->sD->buf = (uint8_t*)calloc(1,3);
- snssai->sD->size = 3;
- memcpy(snssai->sD->buf, bufz, 3);
-
-
- SlicePerPlmnPerCellListItem_t *sliceitem =
- (SlicePerPlmnPerCellListItem_t*)calloc(1,sizeof(SlicePerPlmnPerCellListItem_t));
- sliceitem->sliceID = *snssai;
- ASN_SEQUENCE_ADD(&sliceitem->fQIPERSlicesPerPlmnPerCellList.list, fqi_item);
- if (snssai) free(snssai);
-
- uint8_t *buf2 = (uint8_t*)"747";
-
- OCTET_STRING_t *plmnid = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- plmnid->buf = (uint8_t*)calloc(3,1);
- plmnid->size = 3;
- memcpy(plmnid->buf, buf2, plmnid->size);
-
- ServedPlmnPerCellListItem_t *percellitem1 =
- (ServedPlmnPerCellListItem_t*)calloc(1,sizeof(ServedPlmnPerCellListItem_t));
- percellitem1->pLMN_Identity = *plmnid;
- percellitem1->du_PM_5GC = (FGC_DU_PM_Container*)calloc(1,sizeof(FGC_DU_PM_Container));
- ASN_SEQUENCE_ADD(&percellitem1->du_PM_5GC->slicePerPlmnPerCellList.list, sliceitem);
-
- OCTET_STRING_t *plmnidstr = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- plmnidstr->buf = (uint8_t*)calloc(3,1);
- plmnidstr->size = 3;
- memcpy(plmnidstr->buf, buf2, plmnidstr->size);
-
- printf("enc2\n");
-
- NRCellIdentity_t *nrcellid = (NRCellIdentity_t*)calloc(1,sizeof(NRCellIdentity_t));
- uint8_t* buf3 = (uint8_t*)"12340";
- nrcellid->buf = (uint8_t*)calloc(1,5);
- memcpy(nrcellid->buf, buf3, 5);
- nrcellid->size = 5;
- nrcellid->bits_unused = 4;
-
- NRCGI *nrcgi = (NRCGI*)calloc(1,sizeof(NRCGI));
- nrcgi->pLMN_Identity = *plmnidstr;
- nrcgi->nRCellIdentity = *nrcellid;
- if (plmnidstr) free(plmnidstr);
- if (nrcellid) free(nrcellid);
-
- long dl_prbs = (long)100;
- long ul_prbs = (long)120;
-
- CellResourceReportListItem_t *listitem1 = (CellResourceReportListItem_t*)calloc(1,sizeof(CellResourceReportListItem_t));
- listitem1->nRCGI = *nrcgi;
- listitem1->dl_TotalofAvailablePRBs = &dl_prbs;
- listitem1->ul_TotalofAvailablePRBs = &ul_prbs;
- ASN_SEQUENCE_ADD(&listitem1->servedPlmnPerCellList.list, percellitem1);
- if (nrcgi) free(nrcgi);
-
-
- ODU_PF_Container_t *ducont = (ODU_PF_Container_t*)calloc(1,sizeof(ODU_PF_Container_t));
- ASN_STRUCT_RESET(asn_DEF_ODU_PF_Container, ducont);
- int ret = ASN_SEQUENCE_ADD(&ducont->cellResourceReportList.list, listitem1);
-
- PF_Container_PR pres1 = PF_Container_PR_oDU;
-
- PF_Container_t *pfcontainer = (PF_Container_t*)calloc(1, sizeof(PF_Container_t));
- ASN_STRUCT_RESET(asn_DEF_PF_Container, pfcontainer);
- pfcontainer->present = pres1;
- pfcontainer->choice.oDU = *ducont;
- if (ducont) free(ducont);
-
- PM_Containers_List_t *containers_list = (PM_Containers_List_t*)calloc(1, sizeof(PM_Containers_List_t));
- ASN_STRUCT_RESET(asn_DEF_PM_Containers_List, containers_list);
- containers_list->performanceContainer = pfcontainer;
-
- E2SM_KPM_IndicationMessage_Format1_t *format =
- (E2SM_KPM_IndicationMessage_Format1_t*)calloc(1, sizeof(E2SM_KPM_IndicationMessage_Format1_t));
- ASN_STRUCT_RESET(asn_DEF_E2SM_KPM_IndicationMessage_Format1, format);
-
- ret = ASN_SEQUENCE_ADD(&format->pm_Containers.list, containers_list);
-
- E2SM_KPM_IndicationMessage__indicationMessage_PR pres = E2SM_KPM_IndicationMessage__indicationMessage_PR_indicationMessage_Format1;
-
- indicationmessage->indicationMessage.present = pres;
+#include <unistd.h>
- indicationmessage->indicationMessage.choice.indicationMessage_Format1 = *format;
- if (format) free(format);
+#include <iostream>
+#include <vector>
- char error_buf[300] = {0, };
- size_t errlen = 0;
+#include "encode_kpm.hpp"
+#include "e2sim_defs.h"
+using namespace std;
- asn_check_constraints(&asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage, error_buf, &errlen);
- printf("error length %d\n", errlen);
- printf("error buf %s\n", error_buf);
+void encode_kpm_function_description(E2SM_KPM_RANfunction_Description_t* ranfunc_desc) {
+ uint8_t* short_name = (uint8_t*)"ORAN-E2SM-KPM";
+ uint8_t* func_desc = (uint8_t*)"KPM Monitor";
+ uint8_t* e2sm_odi = (uint8_t*)"OID123";
- xer_fprint(stderr, &asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage);
-
+ LOG_I("short_name: %s, func_desc: %s, e2sm_odi: %s", short_name, func_desc, e2sm_odi);
- uint8_t e2smbuffer[8192] = {0, };
- size_t e2smbuffer_size = 8192;
+ long inst = 1;
- uint8_t e2smbuffer2[8192] = {0, };
- size_t e2smbuffer_size2 = 8192;
+ ASN_STRUCT_RESET(asn_DEF_E2SM_KPM_RANfunction_Description, ranfunc_desc);
- asn_enc_rval_t er =
- asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_IndicationMessage,
- indicationmessage, e2smbuffer, e2smbuffer_size);
+ ranfunc_desc->ranFunction_Name.ranFunction_ShortName.size = strlen((char*)short_name);
+ ranfunc_desc->ranFunction_Name.ranFunction_ShortName.buf =
+ (uint8_t*)calloc(strlen((char*)short_name), sizeof(uint8_t));
+ memcpy(ranfunc_desc->ranFunction_Name.ranFunction_ShortName.buf, short_name,
+ ranfunc_desc->ranFunction_Name.ranFunction_ShortName.size);
+
+ ranfunc_desc->ranFunction_Name.ranFunction_Description.buf =
+ (uint8_t*)calloc(1, strlen((char*)func_desc));
+ memcpy(ranfunc_desc->ranFunction_Name.ranFunction_Description.buf, func_desc,
+ strlen((char*)func_desc));
+ ranfunc_desc->ranFunction_Name.ranFunction_Description.size = strlen((char*)func_desc);
+ ranfunc_desc->ranFunction_Name.ranFunction_Instance = &inst;
- fprintf(stderr, "er encded is %d\n", er.encoded);
- fprintf(stderr, "after encoding message\n");
+ ranfunc_desc->ranFunction_Name.ranFunction_E2SM_OID.buf =
+ (uint8_t*)calloc(1, strlen((char*)e2sm_odi));
+ memcpy(ranfunc_desc->ranFunction_Name.ranFunction_E2SM_OID.buf, e2sm_odi,
+ strlen((char*)e2sm_odi));
+ ranfunc_desc->ranFunction_Name.ranFunction_E2SM_OID.size = strlen((char*)e2sm_odi);
+ LOG_I("Initialize event trigger style list structure");
-}
+ RIC_EventTriggerStyle_Item_t* trigger_style =
+ (RIC_EventTriggerStyle_Item_t*)calloc(1, sizeof(RIC_EventTriggerStyle_Item_t));
+ trigger_style->ric_EventTriggerStyle_Type = 1;
+ uint8_t* style_name = (uint8_t*)"Periodic Report";
+ trigger_style->ric_EventTriggerStyle_Name.buf = (uint8_t*)calloc(1, strlen((char*)style_name));
+ memcpy(trigger_style->ric_EventTriggerStyle_Name.buf, style_name, strlen((char*)style_name));
+ trigger_style->ric_EventTriggerStyle_Name.size = strlen((char*)style_name);
+ trigger_style->ric_EventTriggerFormat_Type = 5;
-void encode_kpm_report_style5_parameterized(E2SM_KPM_IndicationMessage_t* indicationmessage,
- uint8_t *gnbcuupname_buf,
- int bytes_dl,
- int bytes_ul,
- uint8_t *sst_buf,
- uint8_t *sd_buf,
- uint8_t *plmnid_buf) {
-
- ASN_STRUCT_RESET(asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage);
+ ranfunc_desc->ric_EventTriggerStyle_List =
+ (E2SM_KPM_RANfunction_Description::
+ E2SM_KPM_RANfunction_Description__ric_EventTriggerStyle_List*)
+ calloc(1, sizeof(E2SM_KPM_RANfunction_Description::
+ E2SM_KPM_RANfunction_Description__ric_EventTriggerStyle_List));
+ int ret = ASN_SEQUENCE_ADD(&ranfunc_desc->ric_EventTriggerStyle_List->list, trigger_style);
- // uint8_t *buf = (uint8_t*)"GNBCUUP5";
- OCTET_STRING_t *gnbcuupname = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
- gnbcuupname->size = 8;
- gnbcuupname->buf = (uint8_t*)calloc(1,8);
- memcpy(gnbcuupname->buf, gnbcuupname_buf, gnbcuupname->size);
+ LOG_I("Initialize report style structure");
+ MeasurementInfo_Action_List_t* measInfo_Action_List =
+ (MeasurementInfo_Action_List_t*)calloc(1, sizeof(MeasurementInfo_Action_List_t));
+ uint8_t* measured_metrics[] = {(uint8_t*)"CQI", (uint8_t*)"RSRP", (uint8_t*)"RSRQ"};
- //We need to convert bytes_dl into array of uint8_t
+ for (int i = 0; i < 3; i++) {
+ uint8_t* metrics = measured_metrics[i];
+ MeasurementInfo_Action_Item_t* measItem =
+ (MeasurementInfo_Action_Item_t*)calloc(1, sizeof(MeasurementInfo_Action_Item_t));
+ measItem->measName.buf = (uint8_t*)calloc(1, strlen((char*)metrics));
+ memcpy(measItem->measName.buf, metrics, strlen((char*)metrics));
- int array_size_dl;
+ measItem->measName.size = strlen((char*)metrics);
- INTEGER_t *bytesdl = (INTEGER_t*)calloc(1, sizeof(INTEGER_t));
+ measItem->measID = (MeasurementTypeID_t*)calloc(1, sizeof(MeasurementTypeID_t));
+ *measItem->measID = i;
- if (bytes_dl <= 64) {
- array_size_dl = 1;
-
- uint8_t buffer[array_size_dl];
- buffer[0] = bytes_dl & 0xFF;
- bytesdl->buf = (uint8_t*)calloc(1,1);
- memcpy(bytesdl->buf,buffer,1);
- bytesdl->size = 1;
-
- } else if (bytes_dl <= 16384) {
- array_size_dl = 2;
-
- uint8_t buffer[array_size_dl];
- buffer[0] = (bytes_dl >> 8) & 0xFF;
- buffer[1] = bytes_dl & 0xFF;
- bytesdl->buf = (uint8_t*)calloc(2,1);
- memcpy(bytesdl->buf,buffer,2);
- bytesdl->size = 2;
-
- } else if (bytes_dl <= 4194304) {
- array_size_dl = 3;
-
- uint8_t buffer[array_size_dl];
- buffer[0] = (bytes_dl >> 16) & 0xFF;
- buffer[1] = (bytes_dl >> 8) & 0xFF;
- buffer[2] = bytes_dl & 0xFF;
- bytesdl->buf = (uint8_t*)calloc(3,1);
- memcpy(bytesdl->buf,buffer,3);
- bytesdl->size = 3;
-
- } else if (bytes_dl <= 1073741824) {
- array_size_dl = 4;
- uint8_t buffer[array_size_dl];
- buffer[0] = (bytes_dl >> 24) & 0xFF;
- buffer[1] = (bytes_dl >> 16) & 0xFF;
- buffer[2] = (bytes_dl >> 8) & 0xFF;
- buffer[3] = bytes_dl & 0xFF;
- bytesdl->buf = (uint8_t*)calloc(4,1);
- memcpy(bytesdl->buf,buffer,4);
- bytesdl->size = 4;
+ ASN_SEQUENCE_ADD(&measInfo_Action_List->list, measItem);
}
-
-
- //We need to convert bytes_ul into array of uint8_t
- INTEGER_t *bytesul = (INTEGER_t*)calloc(1, sizeof(INTEGER_t));
- int array_size_ul;
-
- if (bytes_ul <= 64) {
- array_size_ul = 1;
-
- uint8_t buffer[array_size_ul];
- buffer[0] = bytes_ul & 0xFF;
- bytesul->buf = (uint8_t*)calloc(1,1);
- memcpy(bytesul->buf,buffer,1);
- bytesul->size = 1;
-
- } else if (bytes_ul <= 16384) {
- array_size_ul = 2;
-
- uint8_t buffer[array_size_ul];
- buffer[0] = (bytes_ul >> 8) & 0xFF;
- buffer[1] = bytes_ul & 0xFF;
- bytesul->buf = (uint8_t*)calloc(2,1);
- memcpy(bytesul->buf,buffer,2);
- bytesul->size = 2;
-
- } else if (bytes_ul <= 4194304) {
- array_size_ul = 3;
-
- uint8_t buffer[array_size_ul];
- buffer[0] = (bytes_ul >> 16) & 0xFF;
- buffer[1] = (bytes_ul >> 8) & 0xFF;
- buffer[2] = bytes_ul & 0xFF;
- bytesul->buf = (uint8_t*)calloc(3,1);
- memcpy(bytesul->buf,buffer,3);
- bytesul->size = 3;
-
- } else if (bytes_ul <= 1073741824) {
- array_size_ul = 4;
- uint8_t buffer[array_size_ul];
- buffer[0] = (bytes_ul >> 24) & 0xFF;
- buffer[1] = (bytes_ul >> 16) & 0xFF;
- buffer[2] = (bytes_ul >> 8) & 0xFF;
- buffer[3] = bytes_ul & 0xFF;
- bytesul->buf = (uint8_t*)calloc(4,1);
- memcpy(bytesul->buf,buffer,4);
- bytesul->size = 4;
- }
-
- long fqi = 9;
- FQIPERSlicesPerPlmnListItem_t *fqilistitem = (FQIPERSlicesPerPlmnListItem_t*)calloc(1, sizeof(FQIPERSlicesPerPlmnListItem_t));
- ASN_STRUCT_RESET(asn_DEF_FQIPERSlicesPerPlmnListItem, fqilistitem);
- fqilistitem->fiveQI = fqi;
- fqilistitem->pDCPBytesDL = bytesdl;
- fqilistitem->pDCPBytesUL = bytesul;
+ RIC_ReportStyle_Item_t* report_style1 =
+ (RIC_ReportStyle_Item_t*)calloc(1, sizeof(RIC_ReportStyle_Item_t));
+ report_style1->ric_ReportStyle_Type = 1;
+ uint8_t* buf5 = (uint8_t*)"E2 Node Measurement";
+ report_style1->ric_ReportStyle_Name.buf = (uint8_t*)calloc(1, strlen((char*)buf5));
+ memcpy(report_style1->ric_ReportStyle_Name.buf, buf5, strlen((char*)buf5));
+ report_style1->ric_ReportStyle_Name.size = strlen((char*)buf5);
+ report_style1->ric_ActionFormat_Type = 1;
+ report_style1->ric_IndicationHeaderFormat_Type = 1;
+ report_style1->ric_IndicationMessageFormat_Type = 1;
+ report_style1->measInfo_Action_List = *measInfo_Action_List;
- uint8_t *buf1 = (uint8_t*)"4";
- uint8_t *bufz = (uint8_t*)"SD1";
-
- SNSSAI_t *snssai = (SNSSAI_t*)calloc(1, sizeof(SNSSAI_t));
- ASN_STRUCT_RESET(asn_DEF_SNSSAI,snssai);
- snssai->sST.buf = (uint8_t*)calloc(1,1);
- snssai->sST.size = 1;
- memcpy(snssai->sST.buf, sst_buf, 1);
- snssai->sD = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
- snssai->sD->buf = (uint8_t*)calloc(1,3);
- snssai->sD->size = 3;
- memcpy(snssai->sD->buf, sd_buf, 3);
+ RIC_ReportStyle_Item_t* report_style2 =
+ (RIC_ReportStyle_Item_t*)calloc(1, sizeof(RIC_ReportStyle_Item_t));
+ report_style2->ric_ReportStyle_Type = 2;
-
+ uint8_t* buf6 = (uint8_t*)"E2 Node Measurement for a single UE";
+ report_style2->ric_ReportStyle_Name.buf = (uint8_t*)calloc(1, strlen((char*)buf6));
+ memcpy(report_style2->ric_ReportStyle_Name.buf, buf6, strlen((char*)buf6));
+ report_style2->ric_ReportStyle_Name.size = strlen((char*)buf6);
+ report_style2->ric_ActionFormat_Type = 2;
+ report_style2->ric_IndicationHeaderFormat_Type = 1;
+ report_style2->ric_IndicationMessageFormat_Type = 1;
+ report_style2->measInfo_Action_List = *measInfo_Action_List;
- SliceToReportListItem_t *slicelistitem = (SliceToReportListItem_t*)calloc(1,sizeof(SliceToReportListItem_t));
- ASN_STRUCT_RESET(asn_DEF_SliceToReportListItem, slicelistitem);
- slicelistitem->sliceID = *snssai;
- int ret = ASN_SEQUENCE_ADD(&slicelistitem->fQIPERSlicesPerPlmnList.list, fqilistitem);
- if (snssai) free(snssai);
+ RIC_ReportStyle_Item_t* report_style3 =
+ (RIC_ReportStyle_Item_t*)calloc(1, sizeof(RIC_ReportStyle_Item_t));
+ report_style3->ric_ReportStyle_Type = 3;
- asn_codec_ctx_t *opt_cod;
+ uint8_t* buf7 = (uint8_t*)"Condition-based, UE-level E2 Node Measurement";
+ report_style3->ric_ReportStyle_Name.buf = (uint8_t*)calloc(1, strlen((char*)buf7));
+ memcpy(report_style3->ric_ReportStyle_Name.buf, buf7, strlen((char*)buf7));
+ report_style3->ric_ReportStyle_Name.size = strlen((char*)buf7);
+ report_style3->ric_ActionFormat_Type = 3;
+ report_style3->ric_IndicationHeaderFormat_Type = 1;
+ report_style3->ric_IndicationMessageFormat_Type = 2;
+ report_style3->measInfo_Action_List = *measInfo_Action_List;
- uint8_t e2smbuffera[8192] = {0, };
- size_t e2smbuffer_sizea = 8192;
+ RIC_ReportStyle_Item_t* report_style4 =
+ (RIC_ReportStyle_Item_t*)calloc(1, sizeof(RIC_ReportStyle_Item_t));
+ report_style4->ric_ReportStyle_Type = 4;
+ uint8_t* buf8 = (uint8_t*)"Common Condition-based, UE-level Measurement";
+ report_style4->ric_ReportStyle_Name.buf = (uint8_t*)calloc(1, strlen((char*)buf8));
+ memcpy(report_style4->ric_ReportStyle_Name.buf, buf8, strlen((char*)buf8));
+ report_style4->ric_ReportStyle_Name.size = strlen((char*)buf8);
+ report_style4->ric_ActionFormat_Type = 4;
+ report_style4->ric_IndicationHeaderFormat_Type = 1;
+ report_style4->ric_IndicationMessageFormat_Type = 3;
+ report_style4->measInfo_Action_List = *measInfo_Action_List;
- asn_enc_rval_t era =
- asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_SliceToReportListItem,
- slicelistitem, e2smbuffera, e2smbuffer_sizea);
- fprintf(stderr, "inner er encded is %d\n", era.encoded);
- fprintf(stderr, "after encoding message\n");
+ RIC_ReportStyle_Item_t* report_style5 =
+ (RIC_ReportStyle_Item_t*)calloc(1, sizeof(RIC_ReportStyle_Item_t));
+ report_style5->ric_ReportStyle_Type = 5;
+ uint8_t* buf9 = (uint8_t*)"E2 Node Measurement for multiple UEs";
+ report_style5->ric_ReportStyle_Name.buf = (uint8_t*)calloc(1, strlen((char*)buf9));
+ memcpy(report_style5->ric_ReportStyle_Name.buf, buf9, strlen((char*)buf9));
+ report_style5->ric_ReportStyle_Name.size = strlen((char*)buf9);
+ report_style5->ric_ActionFormat_Type = 5;
+ report_style5->ric_IndicationHeaderFormat_Type = 1;
+ report_style5->ric_IndicationMessageFormat_Type = 3;
+ report_style5->measInfo_Action_List = *measInfo_Action_List;
- FGC_CUUP_PM_Format_t *pm_format = (FGC_CUUP_PM_Format_t*)calloc(1,sizeof(FGC_CUUP_PM_Format_t));
- ASN_STRUCT_RESET(asn_DEF_FGC_CUUP_PM_Format, pm_format);
- ret = ASN_SEQUENCE_ADD(&pm_format->sliceToReportList.list, slicelistitem);
+ ranfunc_desc->ric_ReportStyle_List =
+ (E2SM_KPM_RANfunction_Description::E2SM_KPM_RANfunction_Description__ric_ReportStyle_List*)
+ calloc(1, sizeof(E2SM_KPM_RANfunction_Description::
+ E2SM_KPM_RANfunction_Description__ric_ReportStyle_List));
- uint8_t *buf2 = (uint8_t*)"747";
- // std::string pl = "PLMNID7";
- // std::vector<uint8_t> plvec(pl.begin(), pl.end());
- // uint8_t *buf2 = &plvec[0];
-
- OCTET_STRING_t *plmnid = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- plmnid->buf = (uint8_t*)calloc(3,1);
- plmnid->size = 3;
- memcpy(plmnid->buf, plmnid_buf, plmnid->size);
+ ASN_SEQUENCE_ADD(&ranfunc_desc->ric_ReportStyle_List->list, report_style1);
+ ASN_SEQUENCE_ADD(&ranfunc_desc->ric_ReportStyle_List->list, report_style2);
+ ASN_SEQUENCE_ADD(&ranfunc_desc->ric_ReportStyle_List->list, report_style3);
+ ASN_SEQUENCE_ADD(&ranfunc_desc->ric_ReportStyle_List->list, report_style4);
+ ASN_SEQUENCE_ADD(&ranfunc_desc->ric_ReportStyle_List->list, report_style5);
+ // xer_fprint(stderr, &asn_DEF_E2SM_KPM_RANfunction_Description, ranfunc_desc);
+}
- PlmnID_List_t *plmnidlist = (PlmnID_List_t*)calloc(1,sizeof(PlmnID_List_t));
- ASN_STRUCT_RESET(asn_DEF_PlmnID_List, plmnidlist);
- plmnidlist->pLMN_Identity = *plmnid;
- plmnidlist->cu_UP_PM_5GC = pm_format;
- if (plmnid) free(plmnid);
+void kpm_report_indication_header_initialized(E2SM_KPM_IndicationHeader_t* ihead,
+ uint8_t* plmnid_buf, uint8_t* sst_buf,
+ uint8_t* sd_buf, long fqival, long qcival,
+ uint8_t* nrcellid_buf, uint8_t* gnbid_buf,
+ int gnbid_unused, uint8_t* cuupid_buf,
+ uint8_t* duid_buf, uint8_t* cuupname_buf) {
+ LOG_I("Start initializing mocked indication header");
+ E2SM_KPM_IndicationHeader_Format1_t* ind_header =
+ (E2SM_KPM_IndicationHeader_Format1_t*)calloc(1, sizeof(E2SM_KPM_IndicationHeader_Format1_t));
+
+ ASN_STRUCT_RESET(asn_DEF_E2SM_KPM_IndicationMessage_Format1, ind_header);
+
+ uint8_t* buf2 = (uint8_t*)"ORANSim";
+ ind_header->senderName = (PrintableString_t*)calloc(1, sizeof(PrintableString_t));
+ ind_header->senderName->buf = (uint8_t*)calloc(1, strlen((char*)buf2));
+ memcpy(ind_header->senderName->buf, buf2, strlen((char*)buf2));
+ ind_header->senderName->size = strlen((char*)buf2);
+
+ uint8_t* buf3 = (uint8_t*)"simulator";
+ ind_header->senderType = (PrintableString_t*)calloc(1, sizeof(PrintableString_t));
+ ind_header->senderType->buf = (uint8_t*)calloc(1, strlen((char*)buf3));
+ memcpy(ind_header->senderType->buf, buf3, strlen((char*)buf3));
+ ind_header->senderType->size = strlen((char*)buf3);
+
+ uint8_t* buf4 = (uint8_t*)"ORAN-SC";
+ ind_header->vendorName = (PrintableString_t*)calloc(1, sizeof(PrintableString_t));
+ ind_header->vendorName->buf = (uint8_t*)calloc(1, strlen((char*)buf4));
+ memcpy(ind_header->vendorName->buf, buf4, strlen((char*)buf4));
+ ind_header->vendorName->size = strlen((char*)buf4);
+
+ uint8_t* buf = (uint8_t*)"20200613";
+ TimeStamp_t* ts = (TimeStamp_t*)calloc(1, sizeof(TimeStamp_t));
+ ts->buf = (uint8_t*)calloc(strlen((char*)buf), 1);
+ ts->size = strlen((char*)buf);
+ memcpy(ts->buf, buf, ts->size);
- CUUPMeasurement_Container_t *meas_cont = (CUUPMeasurement_Container_t*)calloc(1, sizeof(CUUPMeasurement_Container_t));
- ASN_STRUCT_RESET(asn_DEF_CUUPMeasurement_Container, meas_cont);
- ret = ASN_SEQUENCE_ADD(&meas_cont->plmnList.list, plmnidlist);
+ ind_header->colletStartTime = *ts;
+ if (ts) free(ts);
+ uint8_t* buf5 = (uint8_t*)"1.0";
+ ind_header->fileFormatversion = (PrintableString_t*)calloc(1, sizeof(PrintableString_t));
+ ind_header->fileFormatversion->buf = (uint8_t*)calloc(1, strlen((char*)buf5));
+ memcpy(ind_header->fileFormatversion->buf, buf5, strlen((char*)buf5));
+ ind_header->fileFormatversion->size = strlen((char*)buf5);
-
-
- PF_ContainerListItem_t *listitem1 = (PF_ContainerListItem_t*)calloc(1, sizeof(PF_ContainerListItem_t));
- ASN_STRUCT_RESET(asn_DEF_PF_ContainerListItem, listitem1);
- listitem1->interface_type = 2;
- listitem1->o_CU_UP_PM_Container = *meas_cont;
- if (meas_cont) free(meas_cont);
+ ihead->indicationHeader_formats.present =
+ E2SM_KPM_IndicationHeader__indicationHeader_formats_PR_indicationHeader_Format1;
+ ihead->indicationHeader_formats.choice.indicationHeader_Format1 = ind_header;
- OCUUP_PF_Container_t *cuupcont = (OCUUP_PF_Container_t*)calloc(1,sizeof(OCUUP_PF_Container_t));
- ASN_STRUCT_RESET(asn_DEF_OCUUP_PF_Container, cuupcont);
- cuupcont->gNB_CU_UP_Name = gnbcuupname;
- ret = ASN_SEQUENCE_ADD(&cuupcont->pf_ContainerList.list, listitem1);
-
- PF_Container_PR pres1 = PF_Container_PR_oCU_UP;
+ // xer_fprint(stderr, &asn_DEF_E2SM_KPM_IndicationHeader, ihead);
+}
- PF_Container_t *pfcontainer = (PF_Container_t*)calloc(1, sizeof(PF_Container_t));
- ASN_STRUCT_RESET(asn_DEF_PF_Container, pfcontainer);
- pfcontainer->present = pres1;
- pfcontainer->choice.oCU_UP = *cuupcont;
- if (cuupcont) free(cuupcont);
+void ue_meas_kpm_report_indication_message_initialized(
+ E2SM_KPM_IndicationMessage_t* indicationmessage, uint8_t* nrcellid_buf, uint8_t* crnti_buf,
+ const uint8_t* serving_buf, const uint8_t* neighbor_buf) {
+ GranularityPeriod_t period = 1;
+ MeasurementData_t* measData = (MeasurementData_t*)calloc(1, sizeof(MeasurementData_t));
+ MeasurementDataItem_t* measDataItem =
+ (MeasurementDataItem_t*)calloc(1, sizeof(MeasurementDataItem_t));
+ MeasurementRecord_t* measDataItem_record =
+ (MeasurementRecord_t*)calloc(1, sizeof(MeasurementRecord_t));
+ MeasurementRecordItem_t* measDataRecordItem =
+ (MeasurementRecordItem_t*)calloc(1, sizeof(MeasurementRecordItem_t));
+
+ unsigned long val = 1;
+ measDataRecordItem->present = MeasurementRecordItem_PR_integer;
+ measDataRecordItem->choice.integer = val;
+
+ ASN_SEQUENCE_ADD(&measDataItem_record->list, measDataRecordItem);
+
+ measDataItem->measRecord = *measDataItem_record;
+ long incomplete = 0;
+ measDataItem->incompleteFlag = (long*)calloc(1, sizeof(long));
+ *measDataItem->incompleteFlag = incomplete;
+ ASN_SEQUENCE_ADD(&measData->list, measDataItem);
+
+ E2SM_KPM_IndicationMessage_Format1_t* format = (E2SM_KPM_IndicationMessage_Format1_t*)calloc(
+ 1, sizeof(E2SM_KPM_IndicationMessage_Format1_t));
+ format->granulPeriod = (GranularityPeriod_t*)calloc(1, sizeof(GranularityPeriod_t));
+ *format->granulPeriod = period;
+ format->measData = *measData;
+
+ MeasurementInfoList_t* measList =
+ (MeasurementInfoList_t*)calloc(1, sizeof(MeasurementInfoList_t));
+ MeasurementInfoItem_t* measItem =
+ (MeasurementInfoItem_t*)calloc(1, sizeof(MeasurementInfoItem_t));
+ LabelInfoList_t* labelList = (LabelInfoList_t*)calloc(1, sizeof(LabelInfoList_t));
+ LabelInfoItem_t* labelItem = (LabelInfoItem_t*)calloc(1, sizeof(LabelInfoItem_t));
+ MeasurementLabel_t* measLabel = (MeasurementLabel_t*)calloc(1, sizeof(MeasurementLabel_t));
+
+ uint8_t* plmnid_buf = (uint8_t*)"747";
+ uint8_t* sst_buf = (uint8_t*)"1";
+ uint8_t* sd_buf = (uint8_t*)"100";
+
+ S_NSSAI_t* snssai = (S_NSSAI_t*)calloc(1, sizeof(S_NSSAI_t));
+ snssai->sST.buf = (uint8_t*)calloc(strlen((char*)sst_buf), sizeof(uint8_t));
+ snssai->sST.size = strlen((char*)sst_buf);
+ memcpy(snssai->sST.buf, sst_buf, strlen((char*)sst_buf));
+
+ snssai->sD = (SD_t*)calloc(1, sizeof(SD_t));
+ snssai->sD->buf = (uint8_t*)calloc(strlen((char*)sd_buf), sizeof(uint8_t));
+ snssai->sD->size = strlen((char*)sd_buf);
+ memcpy(snssai->sD->buf, sd_buf, strlen((char*)sd_buf));
+
+ int plmnid_size = strlen((char*)plmnid_buf);
+ PLMNIdentity_t* plmnidstr = (PLMNIdentity_t*)calloc(1, sizeof(PLMNIdentity_t));
+ plmnidstr->buf = (uint8_t*)calloc(plmnid_size, 1);
+ plmnidstr->size = plmnid_size;
+ memcpy(plmnidstr->buf, plmnid_buf, plmnidstr->size);
- PM_Containers_List_t *containers_list = (PM_Containers_List_t*)calloc(1, sizeof(PM_Containers_List_t));
- ASN_STRUCT_RESET(asn_DEF_PM_Containers_List, containers_list);
- containers_list->performanceContainer = pfcontainer;
+ measLabel->plmnID = plmnidstr;
+ measLabel->sliceID = snssai;
- E2SM_KPM_IndicationMessage_Format1_t *format =
- (E2SM_KPM_IndicationMessage_Format1_t*)calloc(1, sizeof(E2SM_KPM_IndicationMessage_Format1_t));
- ASN_STRUCT_RESET(asn_DEF_E2SM_KPM_IndicationMessage_Format1, format);
+ labelItem->measLabel = *measLabel;
+ ASN_SEQUENCE_ADD(&labelList->list, labelItem);
+ measItem->labelInfoList = *labelList;
+ if (labelList) free(labelList);
+ MeasurementType_t measType;
+ measType.present = MeasurementType_PR_measID;
+ measType.choice.measID = 1;
+ measItem->measType = measType;
+ ASN_SEQUENCE_ADD(&measList->list, measItem);
- ret = ASN_SEQUENCE_ADD(&format->pm_Containers.list, containers_list);
-
- E2SM_KPM_IndicationMessage__indicationMessage_PR pres = E2SM_KPM_IndicationMessage__indicationMessage_PR_indicationMessage_Format1;
+ format->measInfoList = measList;
- indicationmessage->indicationMessage.present = pres;
+ E2SM_KPM_IndicationMessage__indicationMessage_formats_PR pres =
+ E2SM_KPM_IndicationMessage__indicationMessage_formats_PR_indicationMessage_Format1;
- indicationmessage->indicationMessage.choice.indicationMessage_Format1 = *format;
- if (format) free(format);
+ indicationmessage->indicationMessage_formats.present = pres;
+ indicationmessage->indicationMessage_formats.choice.indicationMessage_Format1 = format;
- char error_buf[300] = {0, };
+ char error_buf[300] = {
+ 0,
+ };
size_t errlen = 0;
- asn_check_constraints(&asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage, error_buf, &errlen);
- printf("error length %d\n", errlen);
- printf("error buf %s\n", error_buf);
-
- xer_fprint(stderr, &asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage);
-
-
- uint8_t e2smbuffer[8192] = {0, };
- size_t e2smbuffer_size = 8192;
-
- uint8_t e2smbuffer2[8192] = {0, };
- size_t e2smbuffer_size2 = 8192;
-
- asn_enc_rval_t er =
- asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_IndicationMessage,
- indicationmessage, e2smbuffer, e2smbuffer_size);
-
- fprintf(stderr, "er encded is %d\n", er.encoded);
- fprintf(stderr, "after encoding message\n");
+ int ret = asn_check_constraints(&asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage, error_buf,
+ &errlen);
+ if (ret) {
+ LOG_I("Constraint validation of indication message failed: %s", error_buf);
+ }
+ // xer_fprint(stderr, &asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage);
}
-void encode_kpm_report_style5(E2SM_KPM_IndicationMessage_t* indicationmessage) {
-
- ASN_STRUCT_RESET(asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage);
-
-
- uint8_t *buf = (uint8_t*)"GNBCUUP5";
- OCTET_STRING_t *gnbcuupname = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
- gnbcuupname->size = 8;
- gnbcuupname->buf = (uint8_t*)calloc(1,8);
- memcpy(gnbcuupname->buf, buf, gnbcuupname->size);
-
-
- INTEGER_t *bytesdl = (INTEGER_t*)calloc(1, sizeof(INTEGER_t));
- uint8_t buffer[1];
- buffer[0]= 40000;
- bytesdl->buf = (uint8_t*)calloc(1,1);
- memcpy(bytesdl->buf, buffer,1);
- bytesdl->size = 1;
-
- INTEGER_t *bytesul = (INTEGER_t*)calloc(1, sizeof(INTEGER_t));
- uint8_t buffer1[1];
- buffer1[0] = 50000;
- bytesul->buf = (uint8_t*)calloc(1,1);
- memcpy(bytesul->buf, buffer1, 1);
- bytesul->size = 1;
-
- FQIPERSlicesPerPlmnListItem_t *fqilistitem = (FQIPERSlicesPerPlmnListItem_t*)calloc(1, sizeof(FQIPERSlicesPerPlmnListItem_t));
- ASN_STRUCT_RESET(asn_DEF_FQIPERSlicesPerPlmnListItem, fqilistitem);
- fqilistitem->fiveQI = 9;
- fqilistitem->pDCPBytesDL = bytesdl;
- fqilistitem->pDCPBytesUL = bytesul;
-
-
- uint8_t *buf1 = (uint8_t*)"4";
- uint8_t *bufz = (uint8_t*)"SD1";
-
- SNSSAI_t *snssai = (SNSSAI_t*)calloc(1, sizeof(SNSSAI_t));
- ASN_STRUCT_RESET(asn_DEF_SNSSAI,snssai);
- snssai->sST.buf = (uint8_t*)calloc(1,1);
- snssai->sST.size = 1;
- memcpy(snssai->sST.buf, buf1, 1);
- snssai->sD = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
- snssai->sD->buf = (uint8_t*)calloc(1,3);
- snssai->sD->size = 3;
- memcpy(snssai->sD->buf, bufz, 3);
-
-
-
- SliceToReportListItem_t *slicelistitem = (SliceToReportListItem_t*)calloc(1,sizeof(SliceToReportListItem_t));
- ASN_STRUCT_RESET(asn_DEF_SliceToReportListItem, slicelistitem);
- slicelistitem->sliceID = *snssai;
- int ret = ASN_SEQUENCE_ADD(&slicelistitem->fQIPERSlicesPerPlmnList.list, fqilistitem);
- if (snssai) free(snssai);
-
- asn_codec_ctx_t *opt_cod;
-
-
- uint8_t e2smbuffera[8192] = {0, };
- size_t e2smbuffer_sizea = 8192;
-
+void cell_meas_kpm_report_indication_message_style_1_initialized(
+ E2SM_KPM_IndicationMessage_t* indicationmessage, long fiveqi, long dl_prb_usage,
+ long ul_prb_usage, uint8_t* nrcellid_buf, long* dl_prbs, long* ul_prbs) {
+ LOG_I("Preparing indication message for cell measurement report");
+
+ asn_codec_ctx_t* opt_cod;
+
+ GranularityPeriod_t period = 1;
+ MeasurementData_t* measData = (MeasurementData_t*)calloc(1, sizeof(MeasurementData_t));
+ MeasurementDataItem_t* measDataItem =
+ (MeasurementDataItem_t*)calloc(1, sizeof(MeasurementDataItem_t));
+ MeasurementRecord_t* measDataItem_record =
+ (MeasurementRecord_t*)calloc(1, sizeof(MeasurementRecord_t));
+ MeasurementRecordItem_t* measDataRecordItem =
+ (MeasurementRecordItem_t*)calloc(1, sizeof(MeasurementRecordItem_t));
+
+ measDataRecordItem->present = MeasurementRecordItem_PR_integer;
+ measDataRecordItem->choice.integer = 1;
+
+ ASN_SEQUENCE_ADD(&measDataItem_record->list, measDataRecordItem);
+
+ measDataItem->measRecord = *measDataItem_record;
+ measDataItem->incompleteFlag = (long*)calloc(1, sizeof(long));
+ *measDataItem->incompleteFlag = 0;
+ ASN_SEQUENCE_ADD(&measData->list, measDataItem);
+
+ E2SM_KPM_IndicationMessage_Format1_t* format = (E2SM_KPM_IndicationMessage_Format1_t*)calloc(
+ 1, sizeof(E2SM_KPM_IndicationMessage_Format1_t));
+ format->granulPeriod = (GranularityPeriod_t*)calloc(1, sizeof(GranularityPeriod_t));
+ *format->granulPeriod = period;
+ format->measData = *measData;
+
+ MeasurementInfoList_t* measList =
+ (MeasurementInfoList_t*)calloc(1, sizeof(MeasurementInfoList_t));
+ MeasurementInfoItem_t* measItem =
+ (MeasurementInfoItem_t*)calloc(1, sizeof(MeasurementInfoItem_t));
+ LabelInfoList_t* labelList = (LabelInfoList_t*)calloc(1, sizeof(LabelInfoList_t));
+ LabelInfoItem_t* labelItem = (LabelInfoItem_t*)calloc(1, sizeof(LabelInfoItem_t));
+ MeasurementLabel_t* measLabel = (MeasurementLabel_t*)calloc(1, sizeof(MeasurementLabel_t));
+
+ uint8_t* plmnid_buf = (uint8_t*)"747";
+ uint8_t* sst_buf = (uint8_t*)"1";
+ uint8_t* sd_buf = (uint8_t*)"100";
+
+ S_NSSAI_t* snssai = (S_NSSAI_t*)calloc(1, sizeof(S_NSSAI_t));
+ snssai->sST.buf = (uint8_t*)calloc(strlen((char*)sst_buf), sizeof(uint8_t));
+ snssai->sST.size = strlen((char*)sst_buf);
+ memcpy(snssai->sST.buf, sst_buf, strlen((char*)sst_buf));
+
+ snssai->sD = (SD_t*)calloc(1, sizeof(SD_t));
+ snssai->sD->buf = (uint8_t*)calloc(strlen((char*)sd_buf), sizeof(uint8_t));
+ snssai->sD->size = strlen((char*)sd_buf);
+ memcpy(snssai->sD->buf, sd_buf, strlen((char*)sd_buf));
+
+ int plmnid_size = strlen((char*)plmnid_buf);
+ PLMNIdentity_t* plmnidstr = (PLMNIdentity_t*)calloc(1, sizeof(PLMNIdentity_t));
+ plmnidstr->buf = (uint8_t*)calloc(plmnid_size, 1);
+ plmnidstr->size = plmnid_size;
+ memcpy(plmnidstr->buf, plmnid_buf, plmnidstr->size);
+ measLabel->plmnID = plmnidstr;
+ measLabel->sliceID = snssai;
- asn_enc_rval_t era =
- asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_SliceToReportListItem,
- slicelistitem, e2smbuffera, e2smbuffer_sizea);
- fprintf(stderr, "inner er encded is %d\n", era.encoded);
- fprintf(stderr, "after encoding message\n");
+ labelItem->measLabel = *measLabel;
+ ASN_SEQUENCE_ADD(&labelList->list, labelItem);
+ measItem->labelInfoList = *labelList;
+ if (labelList) free(labelList);
+ MeasurementType_t measType;
+ measType.present = MeasurementType_PR_measID;
+ measType.choice.measID = 1;
+ measItem->measType = measType;
+ ASN_SEQUENCE_ADD(&measList->list, measItem);
+ format->measInfoList = measList;
+ E2SM_KPM_IndicationMessage__indicationMessage_formats_PR pres =
+ E2SM_KPM_IndicationMessage__indicationMessage_formats_PR_indicationMessage_Format1;
- FGC_CUUP_PM_Format_t *pm_format = (FGC_CUUP_PM_Format_t*)calloc(1,sizeof(FGC_CUUP_PM_Format_t));
- ASN_STRUCT_RESET(asn_DEF_FGC_CUUP_PM_Format, pm_format);
- ret = ASN_SEQUENCE_ADD(&pm_format->sliceToReportList.list, slicelistitem);
+ indicationmessage->indicationMessage_formats.present = pres;
+ indicationmessage->indicationMessage_formats.choice.indicationMessage_Format1 = format;
- uint8_t *buf2 = (uint8_t*)"747";
- // std::string pl = "PLMNID7";
- // std::vector<uint8_t> plvec(pl.begin(), pl.end());
- // uint8_t *buf2 = &plvec[0];
-
- OCTET_STRING_t *plmnid = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- plmnid->buf = (uint8_t*)calloc(3,1);
- plmnid->size = 3;
- memcpy(plmnid->buf, buf2, plmnid->size);
+ char error_buf[300] = {
+ 0,
+ };
+ size_t errlen = 0;
+ int ret = asn_check_constraints(&asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage, error_buf,
+ &errlen);
- PlmnID_List_t *plmnidlist = (PlmnID_List_t*)calloc(1,sizeof(PlmnID_List_t));
- ASN_STRUCT_RESET(asn_DEF_PlmnID_List, plmnidlist);
- plmnidlist->pLMN_Identity = *plmnid;
- plmnidlist->cu_UP_PM_5GC = pm_format;
+ if (ret) {
+ LOG_I("Constraint validation of indication message failed: %s\n", error_buf);
+ }
+ // xer_fprint(stderr, &asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage);
+}
- CUUPMeasurement_Container_t *meas_cont = (CUUPMeasurement_Container_t*)calloc(1, sizeof(CUUPMeasurement_Container_t));
- ASN_STRUCT_RESET(asn_DEF_CUUPMeasurement_Container, meas_cont);
- ret = ASN_SEQUENCE_ADD(&meas_cont->plmnList.list, plmnidlist);
+void encode_kpm_report_style1(E2SM_KPM_IndicationMessage_t* indicationmessage) {
+ long fiveqi = 8;
+ long dl_prb_usage = 50;
+ long ul_prb_usage = 70;
+ asn_codec_ctx_t* opt_cod;
-
-
- PF_ContainerListItem_t *listitem1 = (PF_ContainerListItem_t*)calloc(1, sizeof(PF_ContainerListItem_t));
- ASN_STRUCT_RESET(asn_DEF_PF_ContainerListItem, listitem1);
- listitem1->interface_type = 2;
- listitem1->o_CU_UP_PM_Container = *meas_cont;
- if (meas_cont) free(meas_cont);
+ GranularityPeriod_t period = 1;
+ MeasurementData_t measData;
+ MeasurementDataItem_t measDataItem;
+ MeasurementRecord_t measDataItem_record;
+ MeasurementRecordItem_t measDataRecordItem;
- OCUUP_PF_Container_t *cuupcont = (OCUUP_PF_Container_t*)calloc(1,sizeof(OCUUP_PF_Container_t));
- ASN_STRUCT_RESET(asn_DEF_OCUUP_PF_Container, cuupcont);
- cuupcont->gNB_CU_UP_Name = gnbcuupname;
- ret = ASN_SEQUENCE_ADD(&cuupcont->pf_ContainerList.list, listitem1);
-
- PF_Container_PR pres1 = PF_Container_PR_oCU_UP;
+ measDataRecordItem.present = MeasurementRecordItem_PR_real;
+ measDataRecordItem.choice.real = 1.5;
- PF_Container_t *pfcontainer = (PF_Container_t*)calloc(1, sizeof(PF_Container_t));
- ASN_STRUCT_RESET(asn_DEF_PF_Container, pfcontainer);
- pfcontainer->present = pres1;
- pfcontainer->choice.oCU_UP = *cuupcont;
- if (cuupcont) free(cuupcont);
+ ASN_SEQUENCE_ADD(&measDataItem_record.list, &measDataRecordItem);
- PM_Containers_List_t *containers_list = (PM_Containers_List_t*)calloc(1, sizeof(PM_Containers_List_t));
- ASN_STRUCT_RESET(asn_DEF_PM_Containers_List, containers_list);
- containers_list->performanceContainer = pfcontainer;
+ measDataItem.measRecord = measDataItem_record;
+ ASN_SEQUENCE_ADD(&measData.list, &measDataItem);
- E2SM_KPM_IndicationMessage_Format1_t *format =
- (E2SM_KPM_IndicationMessage_Format1_t*)calloc(1, sizeof(E2SM_KPM_IndicationMessage_Format1_t));
+ E2SM_KPM_IndicationMessage_Format1_t* format = (E2SM_KPM_IndicationMessage_Format1_t*)calloc(
+ 1, sizeof(E2SM_KPM_IndicationMessage_Format1_t));
ASN_STRUCT_RESET(asn_DEF_E2SM_KPM_IndicationMessage_Format1, format);
- ret = ASN_SEQUENCE_ADD(&format->pm_Containers.list, containers_list);
-
- E2SM_KPM_IndicationMessage__indicationMessage_PR pres = E2SM_KPM_IndicationMessage__indicationMessage_PR_indicationMessage_Format1;
+ format->granulPeriod = .
+ format->measData = measData;
+
+ E2SM_KPM_IndicationMessage__indicationMessage_formats_PR pres =
+ E2SM_KPM_IndicationMessage__indicationMessage_formats_PR_indicationMessage_Format1;
- indicationmessage->indicationMessage.present = pres;
+ indicationmessage->indicationMessage_formats.present = pres;
- indicationmessage->indicationMessage.choice.indicationMessage_Format1 = *format;
+ indicationmessage->indicationMessage_formats.choice.indicationMessage_Format1 = format;
if (format) free(format);
- char error_buf[300] = {0, };
+ char error_buf[300] = {
+ 0,
+ };
size_t errlen = 0;
- asn_check_constraints(&asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage, error_buf, &errlen);
- printf("error length %d\n", errlen);
- printf("error buf %s\n", error_buf);
+ int ret = asn_check_constraints(&asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage, error_buf,
+ &errlen);
- xer_fprint(stderr, &asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage);
-
+ if (ret) {
+ LOG_I("Constraint validation of indication message failed: %s\n", error_buf);
+ }
- uint8_t e2smbuffer[8192] = {0, };
+ uint8_t e2smbuffer[8192] = {
+ 0,
+ };
size_t e2smbuffer_size = 8192;
- uint8_t e2smbuffer2[8192] = {0, };
- size_t e2smbuffer_size2 = 8192;
-
asn_enc_rval_t er =
- asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_IndicationMessage,
- indicationmessage, e2smbuffer, e2smbuffer_size);
-
- fprintf(stderr, "er encded is %d\n", er.encoded);
- fprintf(stderr, "after encoding message\n");
+ asn_encode_to_buffer(opt_cod, ATS_ALIGNED_BASIC_PER, &asn_DEF_E2SM_KPM_IndicationMessage,
+ indicationmessage, e2smbuffer, e2smbuffer_size);
+ if (er.encoded == -1) {
+ LOG_I("Failed to serialize message. Detail: %s.\n", asn_DEF_E2SM_KPM_IndicationMessage.name);
+ } else if (er.encoded > e2smbuffer_size) {
+ LOG_I("Buffer of size %zu is too small for %s, need %zu\n", e2smbuffer_size, asn_DEF_E2SM_KPM_IndicationMessage.name, er.encoded);
+ }
}
-
void encode_kpm(E2SM_KPM_IndicationMessage_t* indicationmessage) {
-
/*
ASN_STRUCT_RESET(asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage);
//std::string gn = "GNBCUUP5";
memcpy(bytesul->buf, buffer1, 1);
bytesul->size = 1;
- FQIPERSlicesPerPlmnListItem_t *fqilistitem = (FQIPERSlicesPerPlmnListItem_t*)calloc(1, sizeof(FQIPERSlicesPerPlmnListItem_t));
- ASN_STRUCT_RESET(asn_DEF_FQIPERSlicesPerPlmnListItem, fqilistitem);
- fqilistitem->fiveQI = 9;
- fqilistitem->pDCPBytesDL = bytesdl;
+ FQIPERSlicesPerPlmnListItem_t *fqilistitem = (FQIPERSlicesPerPlmnListItem_t*)calloc(1,
+ sizeof(FQIPERSlicesPerPlmnListItem_t)); ASN_STRUCT_RESET(asn_DEF_FQIPERSlicesPerPlmnListItem,
+ fqilistitem); fqilistitem->fiveQI = 9; fqilistitem->pDCPBytesDL = bytesdl;
fqilistitem->pDCPBytesUL = bytesul;
// std::string sl = "SLICE4";
// std::vector<uint8_t> slvec(sl.begin(), sl.end());
// uint8_t *buf1 = &slvec[0];
- uint8_t *buf1 = (uint8_t*)"4";
+ uint8_t *buf1 = (uint8_t*)"4";
OCTET_STRING_t *sst = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
sst->size = 6;
sst->buf = (uint8_t*)calloc(1,6);
sds->buf = (uint8_t*)calloc(1,3);
memcpy(sds->buf, bufz, sds->size);
-
+
SNSSAI_t *snssai = (SNSSAI_t*)calloc(1, sizeof(SNSSAI_t));
ASN_STRUCT_RESET(asn_DEF_SNSSAI,snssai);
snssai->sST.buf = (uint8_t*)calloc(1,1);
snssai->sD->size = 3;
memcpy(snssai->sD->buf, bufz, 3);
-
- SliceToReportListItem_t *slicelistitem = (SliceToReportListItem_t*)calloc(1,sizeof(SliceToReportListItem_t));
+
+ SliceToReportListItem_t *slicelistitem =
+ (SliceToReportListItem_t*)calloc(1,sizeof(SliceToReportListItem_t));
ASN_STRUCT_RESET(asn_DEF_SliceToReportListItem, slicelistitem);
slicelistitem->sliceID = *snssai;
int ret = ASN_SEQUENCE_ADD(&slicelistitem->fQIPERSlicesPerPlmnList.list, fqilistitem);
- asn_codec_ctx_t *opt_cod;
+ asn_codec_ctx_t *opt_cod;
uint8_t e2smbuffera[8192];
asn_enc_rval_t era =
asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_SliceToReportListItem,
- slicelistitem, e2smbuffera, e2smbuffer_sizea);
+ ATS_ALIGNED_BASIC_PER,
+ &asn_DEF_SliceToReportListItem,
+ slicelistitem, e2smbuffera, e2smbuffer_sizea);
fprintf(stderr, "inner er encded is %d\n", era.encoded);
- fprintf(stderr, "after encoding message\n");
+ fprintf(stderr, "after encoding message");
// std::string pl = "PLMNID7";
// std::vector<uint8_t> plvec(pl.begin(), pl.end());
// uint8_t *buf2 = &plvec[0];
-
+
OCTET_STRING_t *plmnid = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
plmnid->buf = (uint8_t*)calloc(3,1);
plmnid->size = 3;
plmnidlist->pLMN_Identity = *plmnid;
plmnidlist->cu_UP_PM_5GC = pm_format;
- CUUPMeasurement_Container_t *meas_cont = (CUUPMeasurement_Container_t*)calloc(1, sizeof(CUUPMeasurement_Container_t));
- ASN_STRUCT_RESET(asn_DEF_CUUPMeasurement_Container, meas_cont);
- ret = ASN_SEQUENCE_ADD(&meas_cont->plmnList.list, plmnidlist);
+ CUUPMeasurement_Container_t *meas_cont = (CUUPMeasurement_Container_t*)calloc(1,
+ sizeof(CUUPMeasurement_Container_t)); ASN_STRUCT_RESET(asn_DEF_CUUPMeasurement_Container,
+ meas_cont); ret = ASN_SEQUENCE_ADD(&meas_cont->plmnList.list, plmnidlist);
+
+
-
-
- PF_ContainerListItem_t *listitem1 = (PF_ContainerListItem_t*)calloc(1, sizeof(PF_ContainerListItem_t));
- ASN_STRUCT_RESET(asn_DEF_PF_ContainerListItem, listitem1);
+ PF_ContainerListItem_t *listitem1 = (PF_ContainerListItem_t*)calloc(1,
+ sizeof(PF_ContainerListItem_t)); ASN_STRUCT_RESET(asn_DEF_PF_ContainerListItem, listitem1);
listitem1->interface_type = 2;
listitem1->o_CU_UP_PM_Container = *meas_cont;
ASN_STRUCT_RESET(asn_DEF_OCUUP_PF_Container, cuupcont);
cuupcont->gNB_CU_UP_Name = gnbcuupname;
ret = ASN_SEQUENCE_ADD(&cuupcont->pf_ContainerList.list, listitem1);
-
+
PF_Container_PR pres1 = PF_Container_PR_oCU_UP;
PF_Container_t *pfcontainer = (PF_Container_t*)calloc(1, sizeof(PF_Container_t));
pfcontainer->present = pres1;
pfcontainer->choice.oCU_UP = *cuupcont;
- PM_Containers_List_t *containers_list = (PM_Containers_List_t*)calloc(1, sizeof(PM_Containers_List_t));
- ASN_STRUCT_RESET(asn_DEF_PM_Containers_List, containers_list);
+ PM_Containers_List_t *containers_list = (PM_Containers_List_t*)calloc(1,
+ sizeof(PM_Containers_List_t)); ASN_STRUCT_RESET(asn_DEF_PM_Containers_List, containers_list);
containers_list->performanceContainer = pfcontainer;
E2SM_KPM_IndicationMessage_Format1_t *format =
ASN_STRUCT_RESET(asn_DEF_E2SM_KPM_IndicationMessage_Format1, format);
ret = ASN_SEQUENCE_ADD(&format->pm_Containers.list, containers_list);
-
+
E2SM_KPM_IndicationMessage_PR pres = E2SM_KPM_IndicationMessage_PR_indicationMessage_Format1;
indicationmessage->present = pres;
printf("error buf %s\n", error_buf);
xer_fprint(stderr, &asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage);
-
+
uint8_t e2smbuffer[8192];
size_t e2smbuffer_size = 8192;
uint8_t e2smbuffer2[8192];
- size_t e2smbuffer_size2 = 8192;
+ size_t e2smbuffer_size2 = 8192;
asn_enc_rval_t er =
asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_IndicationMessage,
- indicationmessage, e2smbuffer, e2smbuffer_size);
+ ATS_ALIGNED_BASIC_PER,
+ &asn_DEF_E2SM_KPM_IndicationMessage,
+ indicationmessage, e2smbuffer, e2smbuffer_size);
fprintf(stderr, "er encded is %d\n", er.encoded);
- fprintf(stderr, "after encoding message\n");
+ fprintf(stderr, "after encoding message");
*/
}
memcpy(bytesul->buf, buffer1, 1);
bytesul->size = 1;
- FQIPERSlicesPerPlmnListItem_t *fqilistitem = (FQIPERSlicesPerPlmnListItem_t*)calloc(1, sizeof(FQIPERSlicesPerPlmnListItem_t));
- ASN_STRUCT_RESET(asn_DEF_FQIPERSlicesPerPlmnListItem, fqilistitem);
- fqilistitem->fiveQI = 9;
- fqilistitem->pDCPBytesDL = bytesdl;
- fqilistitem->pDCPBytesUL = bytesul;
+ FQIPERSlicesPerPlmnListItem_t *fqilistitem = (FQIPERSlicesPerPlmnListItem_t*)calloc(1,
+sizeof(FQIPERSlicesPerPlmnListItem_t)); ASN_STRUCT_RESET(asn_DEF_FQIPERSlicesPerPlmnListItem,
+fqilistitem); fqilistitem->fiveQI = 9; fqilistitem->pDCPBytesDL = bytesdl; fqilistitem->pDCPBytesUL
+= bytesul;
std::string sl = "SLICE4";
std::vector<uint8_t> slvec(sl.begin(), sl.end());
// uint8_t *buf1 = &slvec[0];
- uint8_t *buf1 = (uint8_t*)"SLICE4";
+ uint8_t *buf1 = (uint8_t*)"SLICE4";
OCTET_STRING_t *sst = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
sst->size = 6;
sst->buf = (uint8_t*)calloc(1,6);
sds->buf = (uint8_t*)calloc(1,3);
memcpy(sds->buf, bufz, sds->size);
-
+
SNSSAI_t *snssai = (SNSSAI_t*)calloc(1, sizeof(SNSSAI_t));
ASN_STRUCT_RESET(asn_DEF_SNSSAI,snssai);
snssai->sST.buf = (uint8_t*)calloc(6,1);
snssai->sD->size = 3;
memcpy(snssai->sD->buf, bufz, 3);
-
- SliceToReportListItem_t *slicelistitem = (SliceToReportListItem_t*)calloc(1,sizeof(SliceToReportListItem_t));
+
+ SliceToReportListItem_t *slicelistitem =
+(SliceToReportListItem_t*)calloc(1,sizeof(SliceToReportListItem_t));
ASN_STRUCT_RESET(asn_DEF_SliceToReportListItem, slicelistitem);
slicelistitem->sliceID = *snssai;
int ret = ASN_SEQUENCE_ADD(&slicelistitem->fQIPERSlicesPerPlmnList.list, fqilistitem);
uint8_t e2smbuffera[8192];
- size_t e2smbuffer_sizea = 8192;
+ size_t e2smbuffer_sizea = 8192;
auto era =
asn_encode_to_buffer(nullptr,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_SliceToReportListItem,
- slicelistitem, e2smbuffera, e2smbuffer_sizea);
+ ATS_ALIGNED_BASIC_PER,
+ &asn_DEF_SliceToReportListItem,
+ slicelistitem, e2smbuffera, e2smbuffer_sizea);
fprintf(stderr, "inner er encded is %d\n", era.encoded);
- fprintf(stderr, "after encoding message\n");
+ fprintf(stderr, "after encoding message");
FGC_CUUP_PM_Format_t *pm_format = (FGC_CUUP_PM_Format_t*)calloc(1,sizeof(FGC_CUUP_PM_Format_t));
ASN_STRUCT_RESET(asn_DEF_FGC_CUUP_PM_Format, pm_format);
std::string pl = "PLMNID7";
std::vector<uint8_t> plvec(pl.begin(), pl.end());
uint8_t *buf2 = &plvec[0];
-
+
OCTET_STRING_t *plmnid = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
plmnid->buf = (uint8_t*)calloc(1,7);
- plmnid->size = 7;
+ plmnid->size = 7;
memcpy(plmnid->buf, buf2, plmnid->size);
plmnidlist->pLMN_Identity = *plmnid;
plmnidlist->cu_UP_PM_5GC = pm_format;
- CUUPMeasurement_Container_t *meas_cont = (CUUPMeasurement_Container_t*)calloc(1, sizeof(CUUPMeasurement_Container_t));
- ASN_STRUCT_RESET(asn_DEF_CUUPMeasurement_Container, meas_cont);
- ret = ASN_SEQUENCE_ADD(&meas_cont->plmnList.list, plmnidlist);
+ CUUPMeasurement_Container_t *meas_cont = (CUUPMeasurement_Container_t*)calloc(1,
+sizeof(CUUPMeasurement_Container_t)); ASN_STRUCT_RESET(asn_DEF_CUUPMeasurement_Container,
+meas_cont); ret = ASN_SEQUENCE_ADD(&meas_cont->plmnList.list, plmnidlist);
+
-
-
- PF_ContainerListItem_t *listitem1 = (PF_ContainerListItem_t*)calloc(1, sizeof(PF_ContainerListItem_t));
- ASN_STRUCT_RESET(asn_DEF_PF_ContainerListItem, listitem1);
+
+ PF_ContainerListItem_t *listitem1 = (PF_ContainerListItem_t*)calloc(1,
+sizeof(PF_ContainerListItem_t)); ASN_STRUCT_RESET(asn_DEF_PF_ContainerListItem, listitem1);
listitem1->interface_type = 2;
listitem1->o_CU_UP_PM_Container = *meas_cont;
ASN_STRUCT_RESET(asn_DEF_OCUUP_PF_Container, cuupcont);
cuupcont->gNB_CU_UP_Name = gnbcuupname;
ret = ASN_SEQUENCE_ADD(&cuupcont->pf_ContainerList.list, listitem1);
-
+
PF_Container_PR pres1 = PF_Container_PR_oCU_UP;
PF_Container_t *pfcontainer = (PF_Container_t*)calloc(1, sizeof(PF_Container_t));
pfcontainer->present = pres1;
pfcontainer->choice.oCU_UP = *cuupcont;
- PM_Containers_List_t *containers_list = (PM_Containers_List_t*)calloc(1, sizeof(PM_Containers_List_t));
- ASN_STRUCT_RESET(asn_DEF_PM_Containers_List, containers_list);
+ PM_Containers_List_t *containers_list = (PM_Containers_List_t*)calloc(1,
+sizeof(PM_Containers_List_t)); ASN_STRUCT_RESET(asn_DEF_PM_Containers_List, containers_list);
containers_list->performanceContainer = pfcontainer;
E2SM_KPM_IndicationMessage_Format1_t *format =
ASN_STRUCT_RESET(asn_DEF_E2SM_KPM_IndicationMessage_Format1, format);
ret = ASN_SEQUENCE_ADD(&format->pm_Containers.list, containers_list);
-
+
E2SM_KPM_IndicationMessage_PR pres = E2SM_KPM_IndicationMessage_PR_indicationMessage_Format1;
indicationmessage->present = pres;
asn_check_constraints(&asn_DEF_E2SM_KPM_IndicationMessage, indicationmessage, error_buf, &errlen);
printf("error length %d\n", errlen);
printf("error buf %s\n", error_buf);
-
+
uint8_t e2smbuffer[8192];
size_t e2smbuffer_size = 8192;
uint8_t e2smbuffer2[8192];
- size_t e2smbuffer_size2 = 8192;
+ size_t e2smbuffer_size2 = 8192;
auto er =
asn_encode_to_buffer(nullptr,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_IndicationMessage,
- indicationmessage, e2smbuffer, e2smbuffer_size);
+ ATS_ALIGNED_BASIC_PER,
+ &asn_DEF_E2SM_KPM_IndicationMessage,
+ indicationmessage, e2smbuffer, e2smbuffer_size);
fprintf(stderr, "er encded is %d\n", er.encoded);
- fprintf(stderr, "after encoding message\n");
+ fprintf(stderr, "after encoding message");
+
-
}
-*/
+*/
\ No newline at end of file
Code Review / sim / e2-interface.git / blobdiff