X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=simulators%2Fe2sim%2Fsrc%2FE2AP%2Fe2ap_message_handler.cpp;h=d8f5e6bed976c7e026ad275a8c7d0b35dffb7428;hb=refs%2Fchanges%2F52%2F1252%2F3;hp=d51194938cd10d2ea8268b50b759d2d1dc63fbf5;hpb=c5fa07bcd8cbd614bcd813cac698385b789bcfcb;p=it%2Ftest.git diff --git a/simulators/e2sim/src/E2AP/e2ap_message_handler.cpp b/simulators/e2sim/src/E2AP/e2ap_message_handler.cpp index d511949..d8f5e6b 100644 --- a/simulators/e2sim/src/E2AP/e2ap_message_handler.cpp +++ b/simulators/e2sim/src/E2AP/e2ap_message_handler.cpp @@ -17,37 +17,38 @@ # * ******************************************************************************/ #include "e2ap_message_handler.hpp" +#include void e2ap_handle_sctp_data(int &socket_fd, sctp_buffer_t &data) { //decode the data into E2AP-PDU - e2ap_pdu_t* pdu = new_e2ap_pdu(); + E2AP_PDU_t* pdu = new E2AP_PDU_t(); - e2ap_decode_pdu(pdu, data.buffer, data.len); + e2ap_asn1c_decode_pdu(pdu, data.buffer, data.len); - e2ap_print_pdu(pdu); + e2ap_asn1c_print_pdu(pdu); - int index = e2ap_get_index(pdu); - int procedureCode = e2ap_get_procedureCode(pdu); + int procedureCode = e2ap_asn1c_get_procedureCode(pdu); + int index = (int)pdu->present; - LOG_I("[E2AP] Unpacked E2AP-PDU: index = %d, procedureCode = %d\n", index, procedureCode); + LOG_D("[E2AP] Unpacked E2AP-PDU: index = %d, procedureCode = %d\n", + index, procedureCode); switch(procedureCode) { - case 6: //X2Setup + case ProcedureCode_id_x2Setup: //X2Setup = 6 switch(index) { - case 1: //initiatingMessage - LOG_D("[E2AP] Received X2-SETUP-REQUEST"); + case E2AP_PDU_PR_initiatingMessage: //initiatingMessage + LOG_I("[E2AP] Received X2-SETUP-REQUEST"); e2ap_handle_X2SetupRequest(pdu, socket_fd); break; - case 2: //successfulOutcome - LOG_D("[E2AP] Received X2-SETUP-RESPONSE"); - //e2ap_handle_X2SetupResponse(pdu, socket_fd); + case E2AP_PDU_PR_successfulOutcome: //successfulOutcome + LOG_I("[E2AP] Received X2-SETUP-RESPONSE"); break; - case 3: + case E2AP_PDU_PR_unsuccessfulOutcome: break; default: @@ -56,21 +57,22 @@ void e2ap_handle_sctp_data(int &socket_fd, sctp_buffer_t &data) } break; - case 36: //ENDCX2Setup + case ProcedureCode_id_endcX2Setup: //ENDCX2Setup = 36 switch(index) { - case 1: //initiatingMessage - LOG_D("[E2AP] Received ENDC-X2-SETUP-REQUEST"); + case E2AP_PDU_PR_initiatingMessage: //initiatingMessage + LOG_I("[E2AP] Received ENDC-X2-SETUP-REQUEST"); e2ap_handle_ENDCX2SetupRequest(pdu, socket_fd); break; - case 2: //successfulOutcome - LOG_D("[E2AP] Received ENDC-X2-SETUP-RESPONSE"); - //x2ap_handle_X2SetupResponse(pdu, socket_fd); + case E2AP_PDU_PR_successfulOutcome: //successfulOutcome + LOG_I("[E2AP] Received ENDC-X2-SETUP-RESPONSE"); + //no handler yet break; - case 3: - LOG_D("[E2AP] Received ENDC-X2-SETUP-FAILURE"); + case E2AP_PDU_PR_unsuccessfulOutcome: + LOG_I("[E2AP] Received ENDC-X2-SETUP-FAILURE"); + //no handler yet break; default: @@ -79,25 +81,60 @@ void e2ap_handle_sctp_data(int &socket_fd, sctp_buffer_t &data) } break; - case 201: //RIC SUBSCRIPTION + case ProcedureCode_id_reset: //reset = 7 switch(index) { - case 1: //initiatingMessage - LOG_D("[E2AP] Received RIC-SUBSCRIPTION-REQUEST"); - e2ap_handle_RICSubscriptionRequest(pdu, socket_fd); + case E2AP_PDU_PR_initiatingMessage: + LOG_I("[E2AP] Received RESET-REQUEST"); break; - case 2: - LOG_D("[E2AP] Received RIC-SUBSCRIPTION-RESPONSE"); + case E2AP_PDU_PR_successfulOutcome: break; - case 3: - LOG_D("[E2AP] Received RIC-SUBSCRIPTION-FAILURE"); + case E2AP_PDU_PR_unsuccessfulOutcome: break; default: - LOG_E("[E2AP] Invalid message index=%d in E2AP-PDU", index); - break; + LOG_E("[E2AP] Invalid message index=%d in E2AP-PDU", index); + break; + } + break; + + case ProcedureCode_id_ricSubscription: //RIC SUBSCRIPTION = 201 + switch(index) + { + case E2AP_PDU_PR_initiatingMessage: //initiatingMessage + LOG_I("[E2AP] Received RIC-SUBSCRIPTION-REQUEST"); + //e2ap_handle_RICSubscriptionRequest(pdu, socket_fd); + e2ap_handle_RICSubscriptionRequest_securityDemo(pdu, socket_fd); + break; + + case E2AP_PDU_PR_successfulOutcome: + LOG_I("[E2AP] Received RIC-SUBSCRIPTION-RESPONSE"); + break; + + case E2AP_PDU_PR_unsuccessfulOutcome: + LOG_I("[E2AP] Received RIC-SUBSCRIPTION-FAILURE"); + break; + + default: + LOG_E("[E2AP] Invalid message index=%d in E2AP-PDU", index); + break; + } + break; + + case ProcedureCode_id_ricIndication: // 205 + switch(index) + { + case E2AP_PDU_PR_initiatingMessage: //initiatingMessage + LOG_I("[E2AP] Received RIC-INDICATION"); + // e2ap_handle_RICSubscriptionRequest(pdu, socket_fd); + break; + + default: + LOG_E("[E2AP] Invalid message index=%d in E2AP-PDU %d", index, + (int)ProcedureCode_id_ricIndication); + break; } break; @@ -107,55 +144,49 @@ void e2ap_handle_sctp_data(int &socket_fd, sctp_buffer_t &data) } } -void e2ap_handle_X2SetupRequest(e2ap_pdu_t* pdu, int &socket_fd) +/* +Simply send back X2SetupResponse +Todo: add more handling options (failure, duplicated request, etc.) +*/ +void e2ap_handle_X2SetupRequest(E2AP_PDU_t* pdu, int &socket_fd) { - /* - Simply send back X2SetupResponse - Todo: add more handling options (failure, duplicated request, etc.) - */ + E2AP_PDU_t* res_pdu = e2ap_xml_to_pdu("E2AP_X2SetupResponse.xml"); - e2ap_pdu_t* res_pdu = new_e2ap_pdu(); - eNB_config cfg; + LOG_D("[E2AP] Created X2-SETUP-RESPONSE"); - e2ap_create_X2SetupResponse(res_pdu, cfg); - LOG_D("[E2AP] Created X2-SETUP-RESPONSE") + e2ap_asn1c_print_pdu(res_pdu); - e2ap_print_pdu(res_pdu); + uint8_t *buf; + sctp_buffer_t data; - //encode response pdu into buffer - sctp_buffer_t res_data; - e2ap_encode_pdu(res_pdu, res_data.buffer, sizeof(res_data.buffer), res_data.len); + data.len = e2ap_asn1c_encode_pdu(res_pdu, &buf); + memcpy(data.buffer, buf, data.len); //send response data over sctp - if(sctp_send_data(socket_fd, res_data) > 0) { + if(sctp_send_data(socket_fd, data) > 0) { LOG_I("[SCTP] Sent X2-SETUP-RESPONSE"); } else { LOG_E("[SCTP] Unable to send X2-SETUP-RESPONSE to peer"); } } -void e2ap_handle_X2SetupResponse(e2ap_pdu_t* pdu, int &socket_fd) -{ - ; -} - -void e2ap_handle_ENDCX2SetupRequest(e2ap_pdu_t* pdu, int &socket_fd) +/* +Simply send back ENDCX2SetupResponse +Todo: add more handling options (failure, duplicated request, etc.) +*/ +void e2ap_handle_ENDCX2SetupRequest(E2AP_PDU_t* pdu, int &socket_fd) { - /* - Simply send back ENDCX2SetupResponse - Todo: add more handling options (failure, duplicated request, etc.) - */ + E2AP_PDU_t* res_pdu = e2ap_xml_to_pdu("E2AP_ENDCX2SetupResponse.xml"); - e2ap_pdu_t* res_pdu = new_e2ap_pdu(); - gNB_config gnb_cfg; - - e2ap_create_ENDCX2SetupResponse(res_pdu, gnb_cfg); LOG_D("[E2AP] Created ENDC-X2-SETUP-RESPONSE"); - e2ap_print_pdu(res_pdu); + e2ap_asn1c_print_pdu(res_pdu); + uint8_t *buf; sctp_buffer_t data; - e2ap_encode_pdu(res_pdu, data.buffer, sizeof(data.buffer), data.len); + + data.len = e2ap_asn1c_encode_pdu(res_pdu, &buf); + memcpy(data.buffer, buf, data.len); //send response data over sctp if(sctp_send_data(socket_fd, data) > 0) { @@ -165,76 +196,159 @@ void e2ap_handle_ENDCX2SetupRequest(e2ap_pdu_t* pdu, int &socket_fd) } } -void e2ap_handle_RICSubscriptionRequest(e2ap_pdu_t* pdu, int &socket_fd) +/* +Simply send back hard-coded RICSubscriptionResponse +Todo: add more handling options (failure, duplicated request, etc.) +*/ +void e2ap_handle_RICSubscriptionRequest(E2AP_PDU_t* pdu, int &socket_fd) { - RICsubscription_params_t params; - e2ap_parse_RICsubscriptionRequest(pdu, params); + E2AP_PDU_t* res_pdu = e2ap_xml_to_pdu("E2AP_RICsubscriptionResponse.xml"); - /* Example handling logic - - Accept if request id is even-numbered -> send back response - in this case, accept every other actions + LOG_D("[E2AP] Created RIC-SUBSCRIPTION-RESPONSE"); - - Reject if request id is odd-numbered -> send back failure - */ + e2ap_asn1c_print_pdu(res_pdu); - e2ap_pdu_t* res_pdu = new_e2ap_pdu(); - bool is_failure = false; + uint8_t *buf; + sctp_buffer_t data; - if(params.request_id % 2 == 0) - { - for(size_t i = 0; i < params.actionList.size(); i++) - { - if(i%2 == 0){ - params.actionList[i].isAdmitted = true; - } else { - params.actionList[i].isAdmitted = false; - params.actionList[i].notAdmitted_cause = RICcause_radioNetwork; - params.actionList[i].notAdmitted_subCause = 5; - } - } + data.len = e2ap_asn1c_encode_pdu(res_pdu, &buf); + memcpy(data.buffer, buf, data.len); - e2ap_create_RICsubscriptionResponse(res_pdu, params); - LOG_I("[E2AP] Created RIC-SUBSCRIPTION-RESPONSE"); + //send response data over sctp + if(sctp_send_data(socket_fd, data) > 0) { + LOG_I("[SCTP] Sent RIC-SUBSCRIPTION-RESPONSE"); + } else { + LOG_E("[SCTP] Unable to send RIC-SUBSCRIPTION-RESPONSE to peer"); } - else - { - is_failure = true; +} - for(size_t i = 0; i < params.actionList.size(); i++) - { - params.actionList[i].isAdmitted = false; - params.actionList[i].notAdmitted_cause = RICcause_radioNetwork; - params.actionList[i].notAdmitted_subCause = 5; - } +void e2ap_handle_RICSubscriptionRequest_securityDemo(E2AP_PDU_t* pdu, int &socket_fd) +{ + E2AP_PDU_t* res_pdu = e2ap_xml_to_pdu("E2AP_RICsubscriptionResponse.xml"); - e2ap_create_RICsubscriptionFailure(res_pdu, params); - LOG_I("[E2AP] Created RIC-SUBSCRIPTION-FAILURE"); - } + LOG_D("[E2AP] Created RIC-SUBSCRIPTION-RESPONSE"); - e2ap_print_pdu(res_pdu); + e2ap_asn1c_print_pdu(res_pdu); - //Encode into buffer + uint8_t *buf; sctp_buffer_t data; - e2ap_encode_pdu(res_pdu, data.buffer, sizeof(data.buffer), data.len); + + data.len = e2ap_asn1c_encode_pdu(res_pdu, &buf); + memcpy(data.buffer, buf, data.len); //send response data over sctp - if(sctp_send_data(socket_fd, data) > 0) - { - if(is_failure) { - LOG_I("[SCTP] Sent RIC-SUBSCRIPTION-FAILURE"); - } - else { - LOG_I("[SCTP] Sent RIC-SUBSCRIPTION-RESPONSE"); - } + if(sctp_send_data(socket_fd, data) > 0) { + LOG_I("[SCTP] Sent RIC-SUBSCRIPTION-RESPONSE"); + } else { + LOG_E("[SCTP] Unable to send RIC-SUBSCRIPTION-RESPONSE to peer"); } - else - { - if(is_failure) { - LOG_I("[SCTP] Unable to send RIC-SUBSCRIPTION-FAILURE"); + + //Start sending RIC Indication + int count1 = 0, count2 = 0; + + E2AP_PDU_t* indication_type1 = e2ap_xml_to_pdu("E2AP_RICindication_type1.xml"); + E2AP_PDU_t* indication_type2 = e2ap_xml_to_pdu("E2AP_RICindication_type2.xml"); + + uint8_t *buf1, *buf2; + sctp_buffer_t data1, data2; + data1.len = e2ap_asn1c_encode_pdu(indication_type1, &buf1); + memcpy(data1.buffer, buf1, data1.len); + + data2.len = e2ap_asn1c_encode_pdu(indication_type2, &buf2); + memcpy(data2.buffer, buf2, data2.len); + + while(1){ + sleep(1); + //type1 + if(sctp_send_data(socket_fd, data1) > 0) { + count1++; + LOG_I("[SCTP] Sent RIC-INDICATION SgNBAdditionRequest Type 1, count1 = %d", count1); + } else { + LOG_E("[SCTP] Unable to send RIC-INDICATION to peer"); } - else { - LOG_E("[SCTP] Unable to send RIC-SUBSCRIPTION-RESPONSE"); + + sleep(1); + //type2 + if(sctp_send_data(socket_fd, data2) > 0) { + count2++; + LOG_I("[SCTP] Sent RIC-INDICATION SgNBAdditionRequest Type 2, count2 = %d", count2); + } else { + LOG_E("[SCTP] Unable to send RIC-INDICATION to peer"); } - } + } //end while } + +// void e2ap_handle_RICSubscriptionRequest_old(e2ap_pdu_t* pdu, int &socket_fd) +// { +// RICsubscription_params_t params; +// e2ap_parse_RICsubscriptionRequest(pdu, params); +// +// /* Example handling logic +// - Accept if request id is even-numbered -> send back response +// in this case, accept every other actions +// +// - Reject if request id is odd-numbered -> send back failure +// */ +// +// e2ap_pdu_t* res_pdu = new_e2ap_pdu(); +// bool is_failure = false; +// +// if(params.request_id % 2 == 0) +// { +// for(size_t i = 0; i < params.actionList.size(); i++) +// { +// if(i%2 == 0){ +// params.actionList[i].isAdmitted = true; +// } else { +// params.actionList[i].isAdmitted = false; +// params.actionList[i].notAdmitted_cause = RICcause_radioNetwork; +// params.actionList[i].notAdmitted_subCause = 5; +// } +// } +// +// e2ap_create_RICsubscriptionResponse(res_pdu, params); +// LOG_I("[E2AP] Created RIC-SUBSCRIPTION-RESPONSE"); +// } +// else +// { +// is_failure = true; +// +// for(size_t i = 0; i < params.actionList.size(); i++) +// { +// params.actionList[i].isAdmitted = false; +// params.actionList[i].notAdmitted_cause = RICcause_radioNetwork; +// params.actionList[i].notAdmitted_subCause = 5; +// } +// +// e2ap_create_RICsubscriptionFailure(res_pdu, params); +// LOG_I("[E2AP] Created RIC-SUBSCRIPTION-FAILURE"); +// } +// +// e2ap_print_pdu(res_pdu); +// +// //Encode into buffer +// sctp_buffer_t data; +// e2ap_encode_pdu(res_pdu, data.buffer, sizeof(data.buffer), data.len); +// +// //send response data over sctp +// if(sctp_send_data(socket_fd, data) > 0) +// { +// if(is_failure) { +// LOG_I("[SCTP] Sent RIC-SUBSCRIPTION-FAILURE"); +// } +// else { +// LOG_I("[SCTP] Sent RIC-SUBSCRIPTION-RESPONSE"); +// } +// } +// else +// { +// if(is_failure) { +// LOG_I("[SCTP] Unable to send RIC-SUBSCRIPTION-FAILURE"); +// } +// else { +// LOG_E("[SCTP] Unable to send RIC-SUBSCRIPTION-RESPONSE"); +// } +// } +// +// }