+TEST(sctp, TEST8) {
+ E2AP_PDU_t pdu;
+ Sctp_Map_t *sctpMap = new Sctp_Map_t();
+ ReportingMessages_t message;
+ RmrMessagesBuffer_t rmrMessageBuffer;
+ sctp_params_t sctp_ut_params;
+
+ pdu.present = E2AP_PDU_PR_successfulOutcome;
+ pdu.choice.successfulOutcome = (SuccessfulOutcome*) malloc(sizeof(SuccessfulOutcome));
+ memset( (void*)pdu.choice.successfulOutcome, 0, sizeof(pdu.choice.successfulOutcome));
+ memset( (void*)&message, 0, sizeof(message));
+ memset( (void*)&rmrMessageBuffer, 0, sizeof(rmrMessageBuffer));
+
+ message.peerInfo = peerInfo;
+ message.peerInfo->sctpParams = &sctp_ut_params;
+ snprintf(message.message.enodbName, strlen("Nokia_enb "), "%s", (char*)"Nokia_enb");
+
+ sctp_ut_params.myIP = "1.2.3.4";
+ sctp_ut_params.rmrPort = 38000;
+ snprintf(sctp_ut_params.rmrAddress, sizeof(sctp_ut_params.rmrAddress), "%d", (int) (sctp_ut_params.rmrPort));
+
+ rmrMessageBuffer.rmrCtx = rmr_init(sctp_ut_params.rmrAddress, RECEIVE_XAPP_BUFFER_SIZE, RMRFL_NONE);
+ rmrMessageBuffer.sendMessage = (rmr_mbuf_t*) malloc(sizeof(rmr_mbuf_t));
+ rmrMessageBuffer.sendMessage->header = (uta_mhdr_t*) malloc(sizeof(uta_mhdr_t));
+ rmrMessageBuffer.sendMessage->len = strlen("Saying Hello from Ramji ");
+ rmrMessageBuffer.sendMessage->payload = (unsigned char*)strdup("Saying Hello from Ramji");
+
+ /* Sending E2AP_PDU_PR_successfulOutcome and procedure code as: ProcedureCode_id_Reset */
+ create_asnSuccessfulMsg_Procedure_Reset(&pdu, sctpMap, message, rmrMessageBuffer);
+ /* Sending E2AP_PDU_PR_successfulOutcome and procedure code as: ProcedureCode_id_RICcontrol */
+ create_asnSuccessfulMsg_Procedure_RICcontrol(&pdu, sctpMap, message, rmrMessageBuffer);
+ /* Sending E2AP_PDU_PR_successfulOutcome and procedure code as: ProcedureCode_id_RICsubscription */
+ create_asnSuccessfulMsg_Procedure_RICsubscription(&pdu, sctpMap, message, rmrMessageBuffer);
+ /* Sending E2AP_PDU_PR_successfulOutcome and procedure code as: ProcedureCode_id_RICsubscriptionDelete */
+ create_asnSuccessfulMsg_Procedure_RICsubscriptionDelete(&pdu, sctpMap, message, rmrMessageBuffer);
+ /* For Procedure's Default case. */
+ pdu.choice.successfulOutcome->procedureCode = ((ProcedureCode_t)100);
+ asnSuccessfulMsg(&pdu, sctpMap, message, rmrMessageBuffer);
+
+ /*Put some usleep... */
+ // usleep(2);
+ if(pdu.choice.successfulOutcome)
+ free(pdu.choice.successfulOutcome);
+ if(rmrMessageBuffer.sendMessage->header)
+ free(rmrMessageBuffer.sendMessage->header);
+ if(rmrMessageBuffer.sendMessage)
+ free(rmrMessageBuffer.sendMessage);
+}
+
+/* TEST9 Begin: */
+void create_asnUnSuccsesfulMsg_Procedure_RICcontrol(E2AP_PDU_t *pdu, Sctp_Map_t *sctpMap, ReportingMessages_t &message, RmrMessagesBuffer_t &rmrMessageBuffer) {
+
+ pdu->choice.unsuccessfulOutcome->value.choice.RICcontrolFailure.protocolIEs.list.array = (RICcontrolFailure_IEs_t**) malloc(1*sizeof(RICcontrolFailure_IEs_t*));
+ pdu->choice.unsuccessfulOutcome->value.choice.RICcontrolFailure.protocolIEs.list.count = 1;
+ pdu->choice.unsuccessfulOutcome->value.choice.RICcontrolFailure.protocolIEs.list.size = sizeof(RICcontrolFailure_IEs_t);
+ pdu->choice.unsuccessfulOutcome->value.choice.RICcontrolFailure.protocolIEs.list.array[0] = (RICcontrolFailure_IEs_t*) malloc(sizeof(RICcontrolFailure_IEs_t));
+ RICcontrolFailure_IEs_t *ie = pdu->choice.unsuccessfulOutcome->value.choice.RICcontrolFailure.protocolIEs.list.array[0];
+
+ ie->id = ProtocolIE_ID_id_RICrequestID;
+ ie->value.present = RICcontrolFailure_IEs__value_PR_RICrequestID;
+ /* Sending E2AP_PDU_PR_unsuccessfulOutcome and procedure code as: ProcedureCode_id_RICcontrol */
+ pdu->choice.unsuccessfulOutcome->procedureCode = ProcedureCode_id_RICcontrol;
+ asnUnSuccsesfulMsg(pdu, sctpMap, message, rmrMessageBuffer);
+}
+
+void create_asnUnSuccsesfulMsg_Procedure_RICsubscription(E2AP_PDU_t *pdu, Sctp_Map_t *sctpMap, ReportingMessages_t &message, RmrMessagesBuffer_t &rmrMessageBuffer) {
+
+ /* Sending E2AP_PDU_PR_unsuccessfulOutcome and procedure code as: ProcedureCode_id_RICsubscription */
+ pdu->choice.unsuccessfulOutcome->procedureCode = ProcedureCode_id_RICsubscription;
+ asnUnSuccsesfulMsg(pdu, sctpMap, message, rmrMessageBuffer);
+}
+
+void create_asnUnSuccsesfulMsg_Procedure_RICsubscriptionDelete(E2AP_PDU_t *pdu, Sctp_Map_t *sctpMap, ReportingMessages_t &message, RmrMessagesBuffer_t &rmrMessageBuffer) {
+
+ /* Sending E2AP_PDU_PR_unsuccessfulOutcome and procedure code as: ProcedureCode_id_RICsubscriptionDelete */
+ pdu->choice.unsuccessfulOutcome->procedureCode = ProcedureCode_id_RICsubscriptionDelete;
+ asnUnSuccsesfulMsg(pdu, sctpMap, message, rmrMessageBuffer);
+}
+
+TEST(sctp, TEST9) {
+ E2AP_PDU_t pdu;
+ Sctp_Map_t *sctpMap = new Sctp_Map_t();
+ ReportingMessages_t message;
+ RmrMessagesBuffer_t rmrMessageBuffer;
+ sctp_params_t sctp_ut_params;
+
+ pdu.present = E2AP_PDU_PR_unsuccessfulOutcome;
+ pdu.choice.unsuccessfulOutcome = (UnsuccessfulOutcome*) malloc(sizeof(UnsuccessfulOutcome));
+ memset( (void*)pdu.choice.unsuccessfulOutcome, 0, sizeof(pdu.choice.unsuccessfulOutcome));
+ memset( (void*)&message, 0, sizeof(message));
+ memset( (void*)&rmrMessageBuffer, 0, sizeof(rmrMessageBuffer));
+
+ message.peerInfo = peerInfo;
+ message.peerInfo->sctpParams = &sctp_ut_params;
+ snprintf(message.message.enodbName, strlen("Nokia_enb "), "%s", (char*)"Nokia_enb");
+
+ sctp_ut_params.myIP = "1.2.3.4";
+ sctp_ut_params.rmrPort = 38000;
+ snprintf(sctp_ut_params.rmrAddress, sizeof(sctp_ut_params.rmrAddress), "%d", (int) (sctp_ut_params.rmrPort));
+
+ rmrMessageBuffer.rmrCtx = rmr_init(sctp_ut_params.rmrAddress, RECEIVE_XAPP_BUFFER_SIZE, RMRFL_NONE);
+ rmrMessageBuffer.sendMessage = (rmr_mbuf_t*) malloc(sizeof(rmr_mbuf_t));
+ rmrMessageBuffer.sendMessage->header = (uta_mhdr_t*) malloc(sizeof(uta_mhdr_t));
+ rmrMessageBuffer.sendMessage->len = strlen("Saying Hello from Ramji ");
+ rmrMessageBuffer.sendMessage->payload = (unsigned char*)strdup("Saying Hello from Ramji");
+
+ /* Sending E2AP_PDU_PR_unsuccessfulOutcome and procedure code as: ProcedureCode_id_RICcontrol */
+ create_asnUnSuccsesfulMsg_Procedure_RICcontrol(&pdu, sctpMap, message, rmrMessageBuffer);
+ /* Sending E2AP_PDU_PR_unsuccessfulOutcome and procedure code as: ProcedureCode_id_RICsubscription */
+ create_asnUnSuccsesfulMsg_Procedure_RICsubscription(&pdu, sctpMap, message, rmrMessageBuffer);
+ /* Sending E2AP_PDU_PR_unsuccessfulOutcome and procedure code as: ProcedureCode_id_RICsubscriptionDelete */
+ create_asnUnSuccsesfulMsg_Procedure_RICsubscriptionDelete(&pdu, sctpMap, message, rmrMessageBuffer);
+ /* For Procedure's Default case. */
+ pdu.choice.unsuccessfulOutcome->procedureCode = ((ProcedureCode_t)100);
+ asnUnSuccsesfulMsg(&pdu, sctpMap, message, rmrMessageBuffer);
+
+ if(pdu.choice.unsuccessfulOutcome)
+ free(pdu.choice.unsuccessfulOutcome);
+ if(rmrMessageBuffer.sendMessage->header)
+ free(rmrMessageBuffer.sendMessage->header);
+ if(rmrMessageBuffer.sendMessage)
+ free(rmrMessageBuffer.sendMessage);
+}
+
+TEST(sctp, TEST10) {
+ int epoll_fd = epoll_create1(0);
+ ConnectedCU_t cu;
+ ConnectedCU_t* peerinfo = &cu;
+ Sctp_Map_t m1;
+ Sctp_Map_t *m = &m1;
+ addToEpoll(epoll_fd, peerinfo, 2, m, (char*)"enodeb1", 0);
+}
+
+TEST(sctp, TEST11) {
+ sctp_params_t sctpParams;
+ int argc = 5;
+ char **argv = (char**) malloc(argc * sizeof(char*));
+ argv[0] = "./e2";
+ argv[1] = "-p";
+ argv[2] = "/opt/e2/RIC-E2-TERMINATION/config/";
+ argv[3] = "-f";
+ argv[4] = "config.conf";
+
+ auto result = parse(argc, argv, sctpParams);
+ sctpParams.podName.assign("E2TermAlpha_pod");
+ buildConfiguration(sctpParams);
+ sctpParams.epoll_fd = epoll_create1(0);
+ // getRmrContext(sctpParams);
+ buildInotify(sctpParams);
+ buildListeningPort(sctpParams);
+ sctpParams.sctpMap = new mapWrapper();
+ listener(&sctpParams);
+}
+
+TEST(sctp, TEST12) {
+ ReportingMessages_t reporting_msg;
+ Sctp_Map_t *sctpMap = new Sctp_Map_t();
+ sendSctpMsg(peerInfo, reporting_msg, sctpMap);
+}
+
+/*TEST(sctp, TEST13) {
+ E2AP_PDU_t pdu;
+ Sctp_Map_t *sctpMap = new Sctp_Map_t();
+ ReportingMessages_t message;
+ RmrMessagesBuffer_t rmrMessageBuffer;
+ sctp_params_t sctp_ut_params;
+
+ pdu.present = E2AP_PDU_PR_successfulOutcome;
+ pdu.choice.successfulOutcome = (SuccessfulOutcome*) malloc(sizeof(SuccessfulOutcome));
+ memset( (void*)pdu.choice.successfulOutcome, 0, sizeof(pdu.choice.successfulOutcome));
+ memset( (void*)&message, 0, sizeof(message));
+ memset( (void*)&rmrMessageBuffer, 0, sizeof(rmrMessageBuffer));
+
+ message.peerInfo = peerInfo;
+ message.peerInfo->sctpParams = &sctp_ut_params;
+ snprintf(message.message.enodbName, strlen("Nokia_enb "), "%s", (char*)"Nokia_enb");
+
+ sctp_ut_params.myIP = "1.2.3.4";
+ sctp_ut_params.rmrPort = 38000;
+ snprintf(sctp_ut_params.rmrAddress, sizeof(sctp_ut_params.rmrAddress), "%d", (int) (sctp_ut_params.rmrPort));
+ rmrMessageBuffer.rcvMessage = rmr_rcv_msg(rmrMessageBuffer.rmrCtx, rmrMessageBuffer.rcvMessage);
+ rmr_get_meid(rmrMessageBuffer.rcvMessage, (unsigned char *)message.message.enodbName);
+ message.peerInfo = (ConnectedCU_t *) sctpMap->find(message.message.enodbName);
+ pdu.choice.successfulOutcome->procedureCode = ProcedureCode_id_E2setup;
+ receiveXappMessages(sctp_ut_params.sctpMap, rmrMessageBuffer, message.message.time);
+}*/