#include <nlohmann/json.hpp>
#include <thread>
-
+#include <chrono>
using json = nlohmann::json;
fprintf(stderr, "JSON Test\n");
+
+ asn_codec_ctx_t *opt_cod;
+
+ E2SM_KPM_RANfunction_Description_t *ranfunc_desc =
+ (E2SM_KPM_RANfunction_Description_t*)calloc(1,sizeof(E2SM_KPM_RANfunction_Description_t));
+ encode_kpm_function_description(ranfunc_desc);
+
+ uint8_t e2smbuffer[8192];
+ size_t e2smbuffer_size = 8192;
+
+ asn_enc_rval_t er =
+ asn_encode_to_buffer(opt_cod,
+ ATS_ALIGNED_BASIC_PER,
+ &asn_DEF_E2SM_KPM_RANfunction_Description,
+ ranfunc_desc, e2smbuffer, e2smbuffer_size);
+
+ fprintf(stderr, "er encded is %d\n", er.encoded);
+ fprintf(stderr, "after encoding message\n");
+ fprintf(stderr, "here is encoded message %s\n", e2smbuffer);
+
+ uint8_t *ranfuncdesc = (uint8_t*)calloc(1,er.encoded);
+ memcpy(ranfuncdesc, e2smbuffer, er.encoded);
+
+ printf("this is the char array %s\n", (char*)ranfuncdesc);
+
+ OCTET_STRING_t *ranfunc_ostr = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
+ ranfunc_ostr->buf = (uint8_t*)calloc(1,er.encoded);
+ ranfunc_ostr->size = er.encoded;
+ memcpy(ranfunc_ostr->buf,e2smbuffer,er.encoded);
+
+ printf("!!!lenth of ranfuncdesc is %d\n", strlen((char*)ranfuncdesc));
+ printf("value of this index is %d\n", ranfuncdesc[0]);
+ printf("value of this index is %d\n", ranfuncdesc[1]);
+ printf("value of this index is %d\n", ranfuncdesc[2]);
+ printf("value of this index is %d\n", ranfuncdesc[3]);
+ printf("value of this index is %d\n", ranfuncdesc[4]);
+ printf("value of this index is %d\n", ranfuncdesc[5]);
+ printf("value of this index is %d\n", ranfuncdesc[6]);
+ printf("value of this index is %d\n", ranfuncdesc[10]);
+ printf("value of this index is %d\n", ranfuncdesc[15]);
+ printf("value of this index is %d\n", ranfuncdesc[100]);
+ printf("value of this index is %d\n", ranfuncdesc[101]);
+
+ e2sim.register_e2sm(0,ranfunc_ostr);
+ e2sim.register_subscription_callback(0,&callback_kpm_subscription_request);
+
+ e2sim.run_loop(argc, argv);
+
+}
+
+void run_report_loop(long requestorId, long instanceId, long ranFunctionId, long actionId) {
+
std::ifstream input("/playpen/src/reports.json");
bool x = input.good();
long seqNum = 1;
std::string str;
-
while ( getline(input, str) ) {
size_t e2sm_message_buf_size_cucp_ue = 8192;
asn_codec_ctx_t *opt_cod;
-
- long requestorId = 9;
- long instanceId = 8;
- long ranFunctionId = 2;
- long actionId = 4;
+
asn_enc_rval_t er_message_cucp_ue = asn_encode_to_buffer(opt_cod,
ATS_ALIGNED_BASIC_PER,
E2SM_KPM_IndicationHeader_t* ind_header_cucp_ue =
(E2SM_KPM_IndicationHeader_t*)calloc(1,sizeof(E2SM_KPM_IndicationHeader_t));
encode_e2sm_kpm_indication_header(ind_header_cucp_ue);
+ fprintf(stderr, "Now printing xer outside of function call\n");
+ xer_fprint(stderr, &asn_DEF_E2SM_KPM_IndicationHeader, ind_header_cucp_ue);
uint8_t e2sm_header_buf_cucp_ue[8192];
size_t e2sm_header_buf_size_cucp_ue = 8192;
ATS_ALIGNED_BASIC_PER,
&asn_DEF_E2SM_KPM_IndicationHeader,
ind_header_cucp_ue, e2sm_header_buf_cucp_ue, e2sm_header_buf_size_cucp_ue);
+
+ fprintf(stderr, "er encded is %d\n", er_header_cucp_ue.encoded);
+ fprintf(stderr, "error buf is %s\n", (char*)e2sm_header_buf_cucp_ue);
+ fprintf(stderr, "after encoding header\n");
E2AP_PDU *pdu_cucp_ue = (E2AP_PDU*)calloc(1,sizeof(E2AP_PDU));
er_header_cucp_ue.encoded, e2sm_message_buf_cucp_ue,
er_message_cucp_ue.encoded);
- // e2sim.encode_and_send_sctp_data(pdu_cucp_ue);
+
+ e2sim.encode_and_send_sctp_data(pdu_cucp_ue);
+
+ seqNum++;
+
+ std::this_thread::sleep_for (std::chrono::seconds(2));
//Creating UE-level RAN-Container CUUP message
asn_codec_ctx_t *opt_cod2;
- long requestorId2 = 9;
- long instanceId2 = 8;
- long ranFunctionId2 = 2;
- long actionId2 = 4;
asn_enc_rval_t er_message_cuup_ue = asn_encode_to_buffer(opt_cod2,
ATS_ALIGNED_BASIC_PER,
E2AP_PDU *pdu_cuup_ue = (E2AP_PDU*)calloc(1,sizeof(E2AP_PDU));
- encoding::generate_e2apv1_indication_request_parameterized(pdu_cuup_ue, requestorId2,
- instanceId2, ranFunctionId2,
- actionId2, seqNum, e2sm_header_buf_cuup_ue,
+ encoding::generate_e2apv1_indication_request_parameterized(pdu_cuup_ue, requestorId,
+ instanceId, ranFunctionId,
+ actionId, seqNum, e2sm_header_buf_cuup_ue,
er_header_cuup_ue.encoded,
e2sm_message_buf_cuup_ue, er_message_cuup_ue.encoded);
+
+ e2sim.encode_and_send_sctp_data(pdu_cuup_ue);
+
+ seqNum++;
+
+ std::this_thread::sleep_for (std::chrono::seconds(2));
//Creating UE-level RAN-Container DU message
asn_codec_ctx_t *opt_cod3;
- long requestorId3 = 9;
- long instanceId3 = 8;
- long ranFunctionId3 = 2;
- long actionId3 = 4;
asn_enc_rval_t er_message_du_ue = asn_encode_to_buffer(opt_cod3,
ATS_ALIGNED_BASIC_PER,
E2AP_PDU *pdu_du_ue = (E2AP_PDU*)calloc(1,sizeof(E2AP_PDU));
- encoding::generate_e2apv1_indication_request_parameterized(pdu_du_ue, requestorId3,
- instanceId3, ranFunctionId3,
- actionId3, seqNum,
+ encoding::generate_e2apv1_indication_request_parameterized(pdu_du_ue, requestorId,
+ instanceId, ranFunctionId,
+ actionId, seqNum,
e2sm_header_buf_du_ue, er_header_du_ue.encoded,
e2sm_message_buf_du_ue, er_message_du_ue.encoded);
+
+ e2sim.encode_and_send_sctp_data(pdu_du_ue);
+
+ seqNum++;
+
+ std::this_thread::sleep_for (std::chrono::seconds(2));
fprintf(stderr, "done with ue meas report\n");
}
} else if (first_key.compare("cellMeasReport") == 0) {
- fprintf(stderr, "it is equal to cell meas report\n");
+ fprintf(stderr, "it is equal to cell meas report\n");
+
+ int numMeasReports = (all_ues_json["/cellMeasReport/cellMeasReportList"_json_pointer]).size();
- int numMeasReports = (all_ues_json["/cellMeasReport/cellMeasReportList"_json_pointer]).size();
-
for (int i = 0; i < numMeasReports; i++) {
int nextCellId;
prb_ul = all_ues_json[p3].get<int>();
fprintf(stderr, "Avail PRB UL %d\n", prb_ul);
- uint8_t *buf = (uint8_t*)"GNBCUUP5";
-
+ uint8_t *buf = (uint8_t*)"GNBCUUP5";
+
uint8_t *sst_buf = (uint8_t*)"1";
uint8_t *sd_buf = (uint8_t*)"100";
uint8_t *plmnid_buf = (uint8_t*)"747";
-
//Encoding Style 5 Message Body
fprintf(stderr, "Encoding Style 5 Message body\n");
- asn_codec_ctx_t *opt_cod;
+ asn_codec_ctx_t *opt_cod;
E2SM_KPM_IndicationMessage_t *ind_msg_style5 =
(E2SM_KPM_IndicationMessage_t*)calloc(1,sizeof(E2SM_KPM_IndicationMessage_t));
fprintf(stderr, "er encded is %d\n", er_message_style5.encoded);
fprintf(stderr, "after encoding message\n");
- //Encode header
- // encode_kpm_indication_header();
-
int seqNum0 = 1;
- long requestorId = 9;
- long instanceId = 8;
- long ranFunctionId = 2;
- long actionId = 4;
E2SM_KPM_IndicationHeader_t* ind_header_style5 =
(E2SM_KPM_IndicationHeader_t*)calloc(1,sizeof(E2SM_KPM_IndicationHeader_t));
actionId, seqNum0, e2sm_header_buf_style5,
er_header_style5.encoded, e2sm_message_buf_style5,
er_message_style5.encoded);
+
+ e2sim.encode_and_send_sctp_data(pdu_style5);
+
+ seqNum++;
+
+ std::this_thread::sleep_for (std::chrono::seconds(2));
- // e2sim.encode_and_send_sctp_data(pdu2);
//Encoding Style 1 Message Body
ATS_ALIGNED_BASIC_PER,
&asn_DEF_E2SM_KPM_IndicationHeader,
ind_header_style1,
- e2sm_header_buf_style1, e2sm_header_buf_size_style1);
+ e2sm_header_buf_style1, e2sm_header_buf_size_style1);
encoding::generate_e2apv1_indication_request_parameterized(pdu_style1, requestorId,
instanceId, ranFunctionId,
actionId, seqNum, e2sm_header_buf_style1,
er_header_style1.encoded,
e2sm_message_buf_style1, er_message_style1.encoded);
-
- // e2sim.encode_and_send_sctp_data(pdu);
-
-
+ e2sim.encode_and_send_sctp_data(pdu_style1);
+ seqNum++;
+ std::this_thread::sleep_for (std::chrono::seconds(2));
+
}
}
}
}
-
- asn_codec_ctx_t *opt_cod;
-
- E2SM_KPM_RANfunction_Description_t *ranfunc_desc =
- (E2SM_KPM_RANfunction_Description_t*)calloc(1,sizeof(E2SM_KPM_RANfunction_Description_t));
- encode_kpm_function_description(ranfunc_desc);
-
- uint8_t e2smbuffer[8192];
- size_t e2smbuffer_size = 8192;
-
- asn_enc_rval_t er =
- asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_RANfunction_Description,
- ranfunc_desc, e2smbuffer, e2smbuffer_size);
-
- fprintf(stderr, "er encded is %d\n", er.encoded);
- fprintf(stderr, "after encoding message\n");
- fprintf(stderr, "here is encoded message %s\n", e2smbuffer);
-
- uint8_t *ranfuncdesc = (uint8_t*)calloc(1,er.encoded);
- memcpy(ranfuncdesc, e2smbuffer, er.encoded);
-
- printf("this is the char array %s\n", (char*)ranfuncdesc);
-
- OCTET_STRING_t *ranfunc_ostr = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
- ranfunc_ostr->buf = (uint8_t*)calloc(1,er.encoded);
- ranfunc_ostr->size = er.encoded;
- memcpy(ranfunc_ostr->buf,e2smbuffer,er.encoded);
-
- printf("!!!lenth of ranfuncdesc is %d\n", strlen((char*)ranfuncdesc));
- printf("value of this index is %d\n", ranfuncdesc[0]);
- printf("value of this index is %d\n", ranfuncdesc[1]);
- printf("value of this index is %d\n", ranfuncdesc[2]);
- printf("value of this index is %d\n", ranfuncdesc[3]);
- printf("value of this index is %d\n", ranfuncdesc[4]);
- printf("value of this index is %d\n", ranfuncdesc[5]);
- printf("value of this index is %d\n", ranfuncdesc[6]);
- printf("value of this index is %d\n", ranfuncdesc[10]);
- printf("value of this index is %d\n", ranfuncdesc[15]);
- printf("value of this index is %d\n", ranfuncdesc[100]);
- printf("value of this index is %d\n", ranfuncdesc[101]);
-
- e2sim.register_e2sm(0,ranfunc_ostr);
- e2sim.register_subscription_callback(0,&callback_kpm_subscription_request);
-
- e2sim.run_loop(argc, argv);
-
-}
-
-
-
-void run_report_loop(long requestorId, long instanceId, long ranFunctionId, long actionId) {
-
- //Process simulation file
-
- ifstream simfile;
- string line;
-
- long seqNum = 1;
-
- simfile.open("simulation.txt", ios::in);
-
- // cout << "step1" << endl;
-
- std::ifstream ue_stream("/playpen/src/ueMeasReport.txt");
- std::ifstream cell_stream("/playpen/src/cellMeasReport.txt");
-
- json all_ues_json;
-
- ue_stream >> all_ues_json;
-
- json all_cells_json;
-
- cell_stream >> all_cells_json;
-
- asn_codec_ctx_t *opt_cod;
-
- // cout << "UE RF Measurements" << endl;
- // cout << "******************" << endl;
-
- int numMeasReports = (all_ues_json["/ueMeasReport/ueMeasReportList"_json_pointer]).size();
-
- for (int i = 0; i < numMeasReports; i++) {
- int nextCellId;
- int nextRsrp;
- int nextRsrq;
- int nextRssinr;
- // cout << "UE number " + i << endl;
- // cout << "**********" << endl;
- json::json_pointer p1(std::string("/ueMeasReport/ueMeasReportList/") + std::to_string(i) +"/nrCellIdentity");
- nextCellId = all_ues_json[p1].get<int>();
- // cout << "Serving Cell " << nextCellId << endl;
-
- json::json_pointer p2(std::string("/ueMeasReport/ueMeasReportList/") + std::to_string(i) +"/servingCellRfReport/rsrp");
- nextRsrp = all_ues_json[p2].get<int>();
- // cout << " RSRP " << nextRsrp << endl;
- json::json_pointer p3(std::string("/ueMeasReport/ueMeasReportList/") + std::to_string(i) +"/servingCellRfReport/rsrq");
- nextRsrq = all_ues_json[p3].get<int>();
- // cout << " RSRQ " << nextRsrq << endl;
- json::json_pointer p4(std::string("/ueMeasReport/ueMeasReportList/") + std::to_string(i) +"/servingCellRfReport/rssinr");
- nextRssinr = all_ues_json[p4].get<int>();
- // cout << " RSSINR " << nextRssinr << endl;
-
- json::json_pointer p5(std::string("/ueMeasReport/ueMeasReportList/") + std::to_string(i) +"/neighbourCellList");
-
- int numNeighborCells = (all_ues_json[p5]).size();
-
-
- //REPORT Message 3 -- Encode and send OCUCP user-level report
-
- E2SM_KPM_IndicationMessage_t *ind_msg3 =
- (E2SM_KPM_IndicationMessage_t*)calloc(1,sizeof(E2SM_KPM_IndicationMessage_t));
- E2AP_PDU *pdu3 = (E2AP_PDU*)calloc(1,sizeof(E2AP_PDU));
-
- uint8_t *crnti_buf = (uint8_t*)calloc(1,2);
-
- if (nextCellId == 0) {
- uint8_t *buf2 = (uint8_t*)"12";
- memcpy(crnti_buf, buf2, 2);
- } else if (nextCellId == 1) {
- uint8_t *buf2 = (uint8_t*)"22";
- memcpy(crnti_buf, buf2, 2);
- }
-
- std::string serving_str = "{\"rsrp\": " + std::to_string(nextRsrp) + ", \"rsrq\": " +
- std::to_string(nextRsrq) + ", \"rssinr\": " + std::to_string(nextRssinr) + "}";
- const uint8_t *serving_buf = reinterpret_cast<const uint8_t*>(serving_str.c_str());
-
- std::string neighbor_str = "[";
-
- int nextNbCell;
- int nextNbRsrp;
- int nextNbRsrq;
- int nextNbRssinr;
-
- for (int j = 0; j < numNeighborCells; j++) {
- json::json_pointer p8(std::string("/ueMeasReport/ueMeasReportList/") + std::to_string(i) +"/neighbourCellList/" + std::to_string(j) + "/nbCellIdentity");
- nextNbCell = all_ues_json[p8].get<int>();
- //cout << "Neighbor Cell " << all_ues_json[p8] << endl;
- json::json_pointer p9(std::string("/ueMeasReport/ueMeasReportList/") + std::to_string(i)
- +"/neighbourCellList/" + std::to_string(j) + "/nbCellRfReport/rsrp");
- nextNbRsrp = all_ues_json[p9].get<int>();
- //cout << " RSRP " << nextNbRsrp << endl;
-
- json::json_pointer p10(std::string("/ueMeasReport/ueMeasReportList/") + std::to_string(i)
- +"/neighbourCellList/" + std::to_string(j) + "/nbCellRfReport/rsrq");
- nextNbRsrq = all_ues_json[p10].get<int>();
- //cout << " RSRQ " << nextNbRsrq << endl;
-
- json::json_pointer p11(std::string("/ueMeasReport/ueMeasReportList/") + std::to_string(i)
- +"/neighbourCellList/" + std::to_string(j) + "/nbCellRfReport/rssinr");
- nextNbRssinr = all_ues_json[p11].get<int>();
- //cout << " RSSINR " << nextNbRssinr << endl;
-
- if (j != 0) {
- neighbor_str += ",";
-
- }
-
- neighbor_str += "{\"CID\" : \"" + std::to_string(nextNbCell) + "\", \"Cell-RF\" : \"{\"rsrp\": " + std::to_string(nextNbRsrp) +
- ", \"rsrq\": " + std::to_string(nextNbRsrq) + ", \"rssinr\": " + std::to_string(nextNbRssinr) + "}}";
-
- }
-
- neighbor_str += "]";
-
- const uint8_t *neighbor_buf = reinterpret_cast<const uint8_t*>(neighbor_str.c_str());
-
- // printf("Neighbor string\n%s", neighbor_buf);
-
- uint8_t *plmnid_buf = (uint8_t*)"747";
- uint8_t *nrcellid_buf = (uint8_t*)"12340";
-
- /*
- encode_kpm_report_rancontainer_cucp_parameterized(ind_msg3, plmnid_buf, nrcellid_buf, crnti_buf, serving_buf, neighbor_buf);
-
- uint8_t e2smbuffer3[8192];
- size_t e2smbuffer_size3 = 8192;
-
-
- asn_enc_rval_t er3 = asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_IndicationMessage,
- ind_msg3, e2smbuffer3, e2smbuffer_size3);
-
- fprintf(stderr, "er encded is %d\n", er3.encoded);
- fprintf(stderr, "after encoding message\n");
- uint8_t *e2smheader_buf3 = (uint8_t*)"";
-
- generate_e2apv1_indication_request_parameterized(pdu3, requestorId,
- instanceId, ranFunctionId,
- actionId, seqNum, e2smheader_buf3, 0, e2smbuffer3, er3.encoded);
-
- e2sim.encode_and_send_sctp_data(pdu3);
- */
-
- seqNum++;
-
- }
-
-
- // cout << "Cell Measurements" << endl;
- // cout << "******************" << endl;
-
- int numCellMeasReports = (all_cells_json["/cellMeasReport/cellMeasReportList"_json_pointer]).size();
-
- uint8_t *sst_buf = (uint8_t*)"1";
- uint8_t *sd_buf = (uint8_t*)"100";
- uint8_t *plmnid_buf = (uint8_t*)"747";
-
- for (int i = 0; i < numCellMeasReports; i++) {
-
- int nextCellId;
-
-
- /*
- int nextPdcpBytesDL;
- int nextPdcpBytesUL;
- int nextPRBBytesDL;
- int nextPRBBytesUL;
-
- json::json_pointer p1(std::string("/cellMeasReport/cellMeasReportList/") + std::to_string(i) +"/nrCellIdentity");
- nextCellId = all_cells_json[p1].get<int>();
- // cout << std::string("Cell number ") << nextCellId << endl;
-
- // cout << "**********" << endl;
-
- json::json_pointer p2(std::string("/cellMeasReport/cellMeasReportList/") + std::to_string(i) +"/pdcpByteMeasReport/pdcpBytesDl");
- nextPdcpBytesDL = all_cells_json[p2].get<int>();
- // cout << std::string(" PDCP Bytes DL ") << nextPdcpBytesDL << endl;
-
- json::json_pointer p3(std::string("/cellMeasReport/cellMeasReportList/") + std::to_string(i) +"/pdcpByteMeasReport/pdcpBytesUl");
- nextPdcpBytesUL = all_cells_json[p3].get<int>();
- // cout << std::string(" PDCP Bytes UL ") << nextPdcpBytesUL << endl;
-
- uint8_t *buf = (uint8_t*)"GNBCUUP5";
-
- int bytes_dl = nextPdcpBytesDL;
- //int bytes_dl = 1250;
-
- int bytes_ul = nextPdcpBytesUL;
- //int bytes_ul = 1450;
-
- // int bytes_dl = 3905;
- // int bytes_ul = 1609321;
-
- E2SM_KPM_IndicationMessage_t *ind_msg2 =
- (E2SM_KPM_IndicationMessage_t*)calloc(1,sizeof(E2SM_KPM_IndicationMessage_t));
- E2AP_PDU *pdu2 = (E2AP_PDU*)calloc(1,sizeof(E2AP_PDU));
-
- encode_kpm_report_style5_parameterized(ind_msg2 , buf, bytes_dl, bytes_ul, sst_buf, sd_buf, plmnid_buf);
-
- uint8_t e2smbuffer2[8192];
- size_t e2smbuffer_size2 = 8192;
-
- asn_enc_rval_t er2 = asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_IndicationMessage,
- ind_msg2, e2smbuffer2, e2smbuffer_size2);
-
- fprintf(stderr, "er encded is %d\n", er2.encoded);
- fprintf(stderr, "after encoding message\n");
-
- //Encode header
- // encode_kpm_indication_header();
-
- // int seqNum0 = 1;
-
- // fprintf(stderr, "i is %d\n", i);
-
- // encoding::generate_e2apv1_indication_request_parameterized(pdu2, requestorId,
- // instanceId, ranFunctionId,
- // actionId, seqNum0, e2sm_header_buffer, er4.encoded, e2smbuffer2, er2.encoded);
-
- // e2sim.encode_and_send_sctp_data(pdu2);
-
-
- seqNum++;
-
-
-
- json::json_pointer p4(std::string("/cellMeasReport/cellMeasReportList/") + std::to_string(i) +"/prbMeasReport/availPrbDl");
- nextPRBBytesDL = all_cells_json[p4].get<int>();
- // cout << std::string(" PRB Bytes DL ") << all_cells_json[p4] << endl;
-
- json::json_pointer p5(std::string("/cellMeasReport/cellMeasReportList/") + std::to_string(i) +"/prbMeasReport/availPrbUl");
- nextPRBBytesUL = all_cells_json[p5].get<int>();
- // cout << std::string(" PRB Bytes UL ") << all_cells_json[p5] << endl;
-
-
- //REPORT Message 1 -- Encode and send ODU cell-level report
-
- E2SM_KPM_IndicationMessage_t *ind_msg1 =
- (E2SM_KPM_IndicationMessage_t*)calloc(1,sizeof(E2SM_KPM_IndicationMessage_t));
- E2AP_PDU *pdu = (E2AP_PDU*)calloc(1,sizeof(E2AP_PDU));
-
- long fiveqi = 7;
-
- uint8_t *nrcellid_buf = (uint8_t*)"12340";
- long dl_prbs = nextPRBBytesDL;
- long ul_prbs = nextPRBBytesUL;
-
-
- encode_kpm_report_style1_parameterized(ind_msg1, fiveqi, dl_prbs, ul_prbs, sst_buf, sd_buf, plmnid_buf, nrcellid_buf, &dl_prbs, &ul_prbs);
-
- uint8_t e2smbuffer[8192];
- size_t e2smbuffer_size = 8192;
-
- asn_enc_rval_t er = asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_IndicationMessage,
- ind_msg1, e2smbuffer, e2smbuffer_size);
-
- fprintf(stderr, "er encded is %d\n", er.encoded);
- fprintf(stderr, "after encoding message\n");
- uint8_t *e2smheader_buf = (uint8_t*)"";
-
- uint8_t *cpid_buf = (uint8_t*)"CPID";
-
- fprintf(stderr, "About to encode Indication\n");
-
-// generate_e2apv1_indication_request_parameterized(pdu, requestorId,
-// instanceId, ranFunctionId,
-// actionId, seqNum, e2smheader_buf, 0, e2smbuffer, er.encoded);
-
-// e2sim.encode_and_send_sctp_data(pdu);
- */
- seqNum++;
-
- }
-
-
-
- /*
- if (simfile.is_open()) {
-
- while (getline(simfile, line)) {
- cout << line << "\n";
-
- //REPORT Message 1 -- Encode and send ODU cell-level report
-
- E2SM_KPM_IndicationMessage_t *ind_msg1 =
- (E2SM_KPM_IndicationMessage_t*)calloc(1,sizeof(E2SM_KPM_IndicationMessage_t));
- E2AP_PDU *pdu = (E2AP_PDU*)calloc(1,sizeof(E2AP_PDU));
-
- long fiveqi = 7;
- uint8_t *sst_buf = (uint8_t*)"1";
- uint8_t *sd_buf = (uint8_t*)"100";
- uint8_t *plmnid_buf = (uint8_t*)"747";
- uint8_t *nrcellid_buf = (uint8_t*)"12340";
- long dl_prbs = 100;
- long ul_prbs = 50;
-
- encode_kpm_report_style1_parameterized(ind_msg1, fiveqi, dl_prbs, ul_prbs, sst_buf, sd_buf, plmnid_buf, nrcellid_buf, &dl_prbs, &ul_prbs);
-
- uint8_t e2smbuffer[8192];
- size_t e2smbuffer_size = 8192;
- asn_codec_ctx_t *opt_cod;
-
- asn_enc_rval_t er = asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_IndicationMessage,
- ind_msg1, e2smbuffer, e2smbuffer_size);
-
- fprintf(stderr, "er encded is %d\n", er.encoded);
- fprintf(stderr, "after encoding message\n");
- uint8_t *e2smheader_buf = (uint8_t*)"header";
-
- uint8_t *cpid_buf = (uint8_t*)"CPID";
-
- fprintf(stderr, "About to encode Indication\n");
- generate_e2apv1_indication_request_parameterized(pdu, requestorId,
- instanceId, ranFunctionId,
- actionId, seqNum, e2smheader_buf, 6, e2smbuffer, er.encoded);
-
- encode_and_send_sctp_data(pdu, socket_fd);
-
- seqNum++;
-
- //REPORT Message 2 -- Encode and send OCUUP cell-level report
-
- uint8_t *buf = (uint8_t*)"GNBCUUP5";
-
- int bytes_dl = 40000;
- int bytes_ul = 50000;
-
- E2SM_KPM_IndicationMessage_t *ind_msg2 =
- (E2SM_KPM_IndicationMessage_t*)calloc(1,sizeof(E2SM_KPM_IndicationMessage_t));
- E2AP_PDU *pdu2 = (E2AP_PDU*)calloc(1,sizeof(E2AP_PDU));
-
- encode_kpm_report_style5_parameterized(ind_msg2 , buf, bytes_dl, bytes_ul, sst_buf, sd_buf, plmnid_buf);
-
- uint8_t e2smbuffer2[8192];
- size_t e2smbuffer_size2 = 8192;
-
-
- asn_enc_rval_t er2 = asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_IndicationMessage,
- ind_msg2, e2smbuffer2, e2smbuffer_size2);
-
- fprintf(stderr, "er encded is %d\n", er2.encoded);
- fprintf(stderr, "after encoding message\n");
- uint8_t *e2smheader_buf2 = (uint8_t*)"header";
-
- generate_e2apv1_indication_request_parameterized(pdu2, requestorId,
- instanceId, ranFunctionId,
- actionId, seqNum, e2smheader_buf2, 6, e2smbuffer2, er2.encoded);
-
- encode_and_send_sctp_data(pdu2, socket_fd);
-
- seqNum++;
-
- //REPORT Message 3 -- Encode and send OCUCP user-level report
-
- E2SM_KPM_IndicationMessage_t *ind_msg3 =
- (E2SM_KPM_IndicationMessage_t*)calloc(1,sizeof(E2SM_KPM_IndicationMessage_t));
- E2AP_PDU *pdu3 = (E2AP_PDU*)calloc(1,sizeof(E2AP_PDU));
-
- uint8_t *crnti_buf = (uint8_t*)"12";
- // uint8_t *serving_buf = (uint8_t*)"RSRP10";
- //uint8_t *neighbor_buf = (uint8_t*)"-10,-15";
- int rsrpServ = 10;
- int rsrqServ = 0;
- int rssinrServ = 0;
-
- std::string serving_str = "{\"rsrp\": " + std::to_string(rsrpServ) + ", \"rsrq\": " +
- std::to_string(rsrqServ) + ", \"rssinr\": " + std::to_string(rssinrServ) + "}";
- const uint8_t *serving_buf = reinterpret_cast<const uint8_t*>(serving_str.c_str());
-
-
- neighbor_cell_entry n_entries[3];
- n_entries[0] = {"123", 10, 0, 0};
- n_entries[1] = {"456", 10, 0, 0};
- n_entries[2] = {"789", 10, 0, 0};
-
- std::string neighbor_str = "[";
-
- for (int i=0; i < sizeof(n_entries)/sizeof(n_entries[0]); i++) {
-
- if (i != 0) {
- neighbor_str += ",";
- }
- neighbor_str += "{\"CID\" : \"" + std::string(n_entries[i].cellid) + "\", \"Cell-RF\" : \"{\"rsrp\": " + std::to_string(n_entries[i].rsrp) +
- ", \"rsrq\": " + std::to_string(n_entries[i].rsrq) + ", \"rssinr\": " + std::to_string(n_entries[i].rsrp) + "}}";
- }
-
- neighbor_str += "]";
-
- const uint8_t *neighbor_buf = reinterpret_cast<const uint8_t*>(neighbor_str.c_str());
-
- printf("Neighbor string\n%s", neighbor_buf);
-
- encode_kpm_report_rancontainer_cucp_parameterized(ind_msg3, plmnid_buf, nrcellid_buf, crnti_buf, serving_buf, neighbor_buf);
-
- uint8_t e2smbuffer3[8192];
- size_t e2smbuffer_size3 = 8192;
-
- asn_enc_rval_t er3 = asn_encode_to_buffer(opt_cod,
- ATS_ALIGNED_BASIC_PER,
- &asn_DEF_E2SM_KPM_IndicationMessage,
- ind_msg3, e2smbuffer3, e2smbuffer_size3);
-
- fprintf(stderr, "er encded is %d\n", er3.encoded);
- fprintf(stderr, "after encoding message\n");
- uint8_t *e2smheader_buf3 = (uint8_t*)"header";
-
- generate_e2apv1_indication_request_parameterized(pdu3, requestorId,
- instanceId, ranFunctionId,
- actionId, seqNum, e2smheader_buf3, 6, e2smbuffer3, er3.encoded);
-
- encode_and_send_sctp_data(pdu3, socket_fd);
-
- seqNum++;
-
- //Encode and send OCUUP user-level report
-
-
-
- //Encode and send ODU user-level report
-
-
-
-
- }
-
- simfile.close();
-
- }
- */
-
}
// std::thread loop_thread;
- long funcId = 1;
+ long funcId = 0;
run_report_loop(reqRequestorId, reqInstanceId, funcId, reqActionId);
Code Review / sim / e2-interface.git / blobdiff