- case RIC_X2_SETUP_REQ: {
- if (connectToCUandSetUp(rmrMessageBuffer, message, epoll_fd, sctpMap, &lspan) != 0) {
- mdclog_write(MDCLOG_ERR, "ERROR in connectToCUandSetUp on RIC_X2_SETUP_REQ");
- message.message.messageType = rmrMessageBuffer.sendMessage->mtype = RIC_SCTP_CONNECTION_FAILURE;
- message.message.direction = 'N';
- message.message.asnLength = rmrMessageBuffer.sendMessage->len =
- snprintf((char *)rmrMessageBuffer.sendMessage->payload,
- 256,
- "ERROR in connectToCUandSetUp on RIC_X2_SETUP_REQ");
- rmrMessageBuffer.sendMessage->state = 0;
- message.message.asndata = rmrMessageBuffer.sendMessage->payload;
-
- if (mdclog_level_get() >= MDCLOG_DEBUG) {
- mdclog_write(MDCLOG_DEBUG, "start writing to rmr buffer");
- }
- rmr_bytes2xact(rmrMessageBuffer.sendMessage, rmrMessageBuffer.rcvMessage->xaction, RMR_MAX_XID);
- rmr_str2meid(rmrMessageBuffer.sendMessage, (unsigned char *)message.message.enodbName);
-
- sendRmrMessage(rmrMessageBuffer, message, &lspan);
-#ifdef __TRACING__
- lspan->Finish();
-#endif
- return -3;
- }
- break;
- }
- case RIC_ENDC_X2_SETUP_REQ: {
- if (connectToCUandSetUp(rmrMessageBuffer, message, epoll_fd, sctpMap, &lspan) != 0) {
- mdclog_write(MDCLOG_ERR, "ERROR in connectToCUandSetUp on RIC_ENDC_X2_SETUP_REQ");
- message.message.messageType = rmrMessageBuffer.sendMessage->mtype = RIC_SCTP_CONNECTION_FAILURE;
- message.message.direction = 'N';
- message.message.asnLength = rmrMessageBuffer.sendMessage->len =
- snprintf((char *)rmrMessageBuffer.sendMessage->payload, 256,
- "ERROR in connectToCUandSetUp on RIC_ENDC_X2_SETUP_REQ");
- rmrMessageBuffer.sendMessage->state = 0;
- message.message.asndata = rmrMessageBuffer.sendMessage->payload;
-
- if (mdclog_level_get() >= MDCLOG_DEBUG) {
- mdclog_write(MDCLOG_DEBUG, "start writing to rmr buffer");
- }
-
- rmr_bytes2xact(rmrMessageBuffer.sendMessage, rmrMessageBuffer.rcvMessage->xaction, RMR_MAX_XID);
- rmr_str2meid(rmrMessageBuffer.sendMessage, (unsigned char *) message.message.enodbName);
-
- sendRmrMessage(rmrMessageBuffer, message, &lspan);
-#ifdef __TRACING__
- lspan->Finish();
-#endif
- return -3;
- }
- break;
- }
- case RIC_ENDC_CONF_UPDATE: {
- if (sendDirectionalSctpMsg(rmrMessageBuffer, message, 0, sctpMap, &lspan) != 0) {
- mdclog_write(MDCLOG_ERR, "Failed to send RIC_ENDC_CONF_UPDATE");
-#ifdef __TRACING__
- lspan->Finish();
-#endif
- return -4;
- }
- break;
- }
- case RIC_ENDC_CONF_UPDATE_ACK: {
- if (sendDirectionalSctpMsg(rmrMessageBuffer, message, 0, sctpMap, &lspan) != 0) {
- mdclog_write(MDCLOG_ERR, "Failed to send RIC_ENDC_CONF_UPDATE_ACK");
-#ifdef __TRACING__
- lspan->Finish();
-#endif
- return -4;
- }
- break;
- }
- case RIC_ENDC_CONF_UPDATE_FAILURE: {
- if (sendDirectionalSctpMsg(rmrMessageBuffer, message, 0, sctpMap, &lspan) != 0) {
- mdclog_write(MDCLOG_ERR, "Failed to send RIC_ENDC_CONF_UPDATE_FAILURE");
-#ifdef __TRACING__
- lspan->Finish();
-#endif
-
- return -4;
- }
- break;
- }
- case RIC_ENB_CONF_UPDATE: {
- if (sendDirectionalSctpMsg(rmrMessageBuffer, message, 0, sctpMap, &lspan) != 0) {
- mdclog_write(MDCLOG_ERR, "Failed to send RIC_ENDC_CONF_UPDATE");
-#ifdef __TRACING__
- lspan->Finish();
-#endif
- return -4;
- }
- break;
- }
- case RIC_ENB_CONF_UPDATE_ACK: {
- if (sendDirectionalSctpMsg(rmrMessageBuffer, message, 0, sctpMap, &lspan) != 0) {
- mdclog_write(MDCLOG_ERR, "Failed to send RIC_ENB_CONF_UPDATE_ACK");
-#ifdef __TRACING__
- lspan->Finish();
-#endif
- return -4;
+// case RIC_X2_SETUP_REQ: {
+// if (connectToCUandSetUp(rmrMessageBuffer, message, epoll_fd, sctpMap) != 0) {
+// mdclog_write(MDCLOG_ERR, "ERROR in connectToCUandSetUp on RIC_X2_SETUP_REQ");
+// message.message.messageType = rmrMessageBuffer.sendMessage->mtype = RIC_SCTP_CONNECTION_FAILURE;
+// message.message.direction = 'N';
+// message.message.asnLength = rmrMessageBuffer.sendMessage->len =
+// snprintf((char *)rmrMessageBuffer.sendMessage->payload,
+// 256,
+// "ERROR in connectToCUandSetUp on RIC_X2_SETUP_REQ");
+// rmrMessageBuffer.sendMessage->state = 0;
+// message.message.asndata = rmrMessageBuffer.sendMessage->payload;
+//
+// if (mdclog_level_get() >= MDCLOG_DEBUG) {
+// mdclog_write(MDCLOG_DEBUG, "start writing to rmr buffer");
+// }
+// rmr_bytes2xact(rmrMessageBuffer.sendMessage, rmrMessageBuffer.rcvMessage->xaction, RMR_MAX_XID);
+// rmr_str2meid(rmrMessageBuffer.sendMessage, (unsigned char *)message.message.enodbName);
+//
+// sendRmrMessage(rmrMessageBuffer, message);
+// return -3;
+// }
+// break;
+// }
+// case RIC_ENDC_X2_SETUP_REQ: {
+// if (connectToCUandSetUp(rmrMessageBuffer, message, epoll_fd, sctpMap) != 0) {
+// mdclog_write(MDCLOG_ERR, "ERROR in connectToCUandSetUp on RIC_ENDC_X2_SETUP_REQ");
+// message.message.messageType = rmrMessageBuffer.sendMessage->mtype = RIC_SCTP_CONNECTION_FAILURE;
+// message.message.direction = 'N';
+// message.message.asnLength = rmrMessageBuffer.sendMessage->len =
+// snprintf((char *)rmrMessageBuffer.sendMessage->payload, 256,
+// "ERROR in connectToCUandSetUp on RIC_ENDC_X2_SETUP_REQ");
+// rmrMessageBuffer.sendMessage->state = 0;
+// message.message.asndata = rmrMessageBuffer.sendMessage->payload;
+//
+// if (mdclog_level_get() >= MDCLOG_DEBUG) {
+// mdclog_write(MDCLOG_DEBUG, "start writing to rmr buffer");
+// }
+//
+// rmr_bytes2xact(rmrMessageBuffer.sendMessage, rmrMessageBuffer.rcvMessage->xaction, RMR_MAX_XID);
+// rmr_str2meid(rmrMessageBuffer.sendMessage, (unsigned char *) message.message.enodbName);
+//
+// sendRmrMessage(rmrMessageBuffer, message);
+// return -3;
+// }
+// break;
+// }
+// case RIC_ENDC_CONF_UPDATE: {
+// if (sendDirectionalSctpMsg(rmrMessageBuffer, message, 0, sctpMap) != 0) {
+// mdclog_write(MDCLOG_ERR, "Failed to send RIC_ENDC_CONF_UPDATE");
+// return -4;
+// }
+// break;
+// }
+// case RIC_ENDC_CONF_UPDATE_ACK: {
+// if (sendDirectionalSctpMsg(rmrMessageBuffer, message, 0, sctpMap) != 0) {
+// mdclog_write(MDCLOG_ERR, "Failed to send RIC_ENDC_CONF_UPDATE_ACK");
+// return -4;
+// }
+// break;
+// }
+// case RIC_ENDC_CONF_UPDATE_FAILURE: {
+// if (sendDirectionalSctpMsg(rmrMessageBuffer, message, 0, sctpMap) != 0) {
+// mdclog_write(MDCLOG_ERR, "Failed to send RIC_ENDC_CONF_UPDATE_FAILURE");
+// return -4;
+// }
+// break;
+// }
+// case RIC_ENB_CONF_UPDATE: {
+// if (sendDirectionalSctpMsg(rmrMessageBuffer, message, 0, sctpMap) != 0) {
+// mdclog_write(MDCLOG_ERR, "Failed to send RIC_ENDC_CONF_UPDATE");
+// return -4;
+// }
+// break;
+// }
+// case RIC_ENB_CONF_UPDATE_ACK: {
+// if (sendDirectionalSctpMsg(rmrMessageBuffer, message, 0, sctpMap) != 0) {
+// mdclog_write(MDCLOG_ERR, "Failed to send RIC_ENB_CONF_UPDATE_ACK");
+// return -4;
+// }
+// break;
+// }
+// case RIC_ENB_CONF_UPDATE_FAILURE: {
+// if (sendDirectionalSctpMsg(rmrMessageBuffer, message, 0, sctpMap) != 0) {
+// mdclog_write(MDCLOG_ERR, "Failed to send RIC_ENB_CONF_UPDATE_FAILURE");
+// return -4;
+// }
+// break;
+// }
+// case RIC_RES_STATUS_REQ: {
+// if (sendDirectionalSctpMsg(rmrMessageBuffer, message, 0, sctpMap) != 0) {
+// mdclog_write(MDCLOG_ERR, "Failed to send RIC_RES_STATUS_REQ");
+// return -6;
+// }
+// break;
+// }
+
+ case RIC_E2_SETUP_RESP : {
+ if (sendDirectionalSctpMsg(rmrMessageBuffer, message, 0, sctpMap) != 0) {
+ mdclog_write(MDCLOG_ERR, "Failed to send RIC_E2_SETUP_RESP");
+ return -6;