//We need to convert bytes_dl into array of uint8_t
+
+ int array_size_dl;
+
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;
+ 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;
+ }
+
//We need to convert bytes_ul into array of uint8_t
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;
+
+ 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;
+ }
+
FQIPERSlicesPerPlmnListItem_t *fqilistitem = (FQIPERSlicesPerPlmnListItem_t*)calloc(1, sizeof(FQIPERSlicesPerPlmnListItem_t));
ASN_STRUCT_RESET(asn_DEF_FQIPERSlicesPerPlmnListItem, fqilistitem);
#include <vector>
-#include "OCUCP-PF-Container.h"
-#include "OCTET_STRING.h"
-#include "asn_application.h"
-#include "E2SM-KPM-IndicationMessage.h"
-#include "FQIPERSlicesPerPlmnListItem.h"
-#include "E2SM-KPM-RANfunction-Description.h"
-#include "Timestamp.h"
-#include "E2AP-PDU.h"
+
+extern "C" {
+ #include "OCUCP-PF-Container.h"
+ #include "OCTET_STRING.h"
+ #include "asn_application.h"
+ #include "E2SM-KPM-IndicationMessage.h"
+ #include "FQIPERSlicesPerPlmnListItem.h"
+ #include "E2SM-KPM-RANfunction-Description.h"
+ #include "Timestamp.h"
+ #include "E2AP-PDU.h"
+ #include "RICsubscriptionRequest.h"
+ #include "RICsubscriptionResponse.h"
+ #include "RICactionType.h"
+ #include "ProtocolIE-Field.h"
+ #include "ProtocolIE-SingleContainer.h"
+ #include "InitiatingMessage.h"
+}
+
#include "encode_kpm.hpp"
+
#include "encode_e2apv1.hpp"
+
+#include <nlohmann/json.hpp>
+#include <thread>
+
+
+
+
#include "e2sim.hpp"
+using json = nlohmann::json;
+
using namespace std;
struct neighbor_cell_entry {
simfile.open("simulation.txt", ios::in);
+ cout << "step1" << endl;
+
+ std::ifstream ue_stream("ueMeasReport.txt");
+ std::ifstream cell_stream("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*)"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++;
+
+ }
+
+
+ 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_ul = nextPdcpBytesUL;
+
+ // 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");
+ 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++;
+
+
+
+ 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*)"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++;
+
+ }
+
+
+ /*
if (simfile.is_open()) {
while (getline(simfile, line)) {
simfile.close();
}
+ */
}
Code Review / sim / e2-interface.git / commitdiff