Change-Id: Iba49333c89b7de663e135d78afbf3dbbe26800f1
Signed-off-by: aa7133@att.com <aa7133@att.com>
// break;
// }
// case E2AP_PDU_PR_successfulOutcome: { //successful outcome
// break;
// }
// case E2AP_PDU_PR_successfulOutcome: { //successful outcome
- // asnSuccsesfulMsg(pdu, message, sctpMap, rmrMessageBuffer);
+ // asnSuccessfulMsg(pdu, message, sctpMap, rmrMessageBuffer);
// break;
// }
// case E2AP_PDU_PR_unsuccessfulOutcome: { //Unsuccessful Outcome
// break;
// }
// case E2AP_PDU_PR_unsuccessfulOutcome: { //Unsuccessful Outcome
# The Jenkins job requires a tag to build the Docker image.
# Global-JJB script assumes this file is in the repo root.
# The Jenkins job requires a tag to build the Docker image.
# Global-JJB script assumes this file is in the repo root.
return seconds_t(std::chrono::high_resolution_clock::now() - start_time).count();
}
return seconds_t(std::chrono::high_resolution_clock::now() - start_time).count();
}
-double approx_CPU_MHz(unsigned sleeptime) {
+double approx_CPU_MHz(unsigned sleepTime) {
using namespace std::chrono_literals;
uint32_t aux = 0;
uint64_t cycles_start = rdtscp(aux);
double time_start = age();
using namespace std::chrono_literals;
uint32_t aux = 0;
uint64_t cycles_start = rdtscp(aux);
double time_start = age();
- std::this_thread::sleep_for(sleeptime * 1ms);
+ std::this_thread::sleep_for(sleepTime * 1ms);
uint64_t elapsed_cycles = rdtscp(aux) - cycles_start;
double elapsed_time = age() - time_start;
return elapsed_cycles / elapsed_time;
uint64_t elapsed_cycles = rdtscp(aux) - cycles_start;
double elapsed_time = age() - time_start;
return elapsed_cycles / elapsed_time;
- struct sockaddr_in6 servaddr {};
- servaddr.sin6_family = AF_INET6;
- servaddr.sin6_addr = in6addr_any;
- servaddr.sin6_port = htons(sctpParams.sctpPort);
- if (bind(sctpParams.listenFD, (SA *)&servaddr, sizeof(servaddr)) < 0 ) {
+ struct sockaddr_in6 serverAddress {};
+ serverAddress.sin6_family = AF_INET6;
+ serverAddress.sin6_addr = in6addr_any;
+ serverAddress.sin6_port = htons(sctpParams.sctpPort);
+ if (bind(sctpParams.listenFD, (SA *)&serverAddress, sizeof(serverAddress)) < 0 ) {
mdclog_write(MDCLOG_ERR, "Error binding port %d. %s", sctpParams.sctpPort, strerror(errno));
return -1;
}
mdclog_write(MDCLOG_ERR, "Error binding port %d. %s", sctpParams.sctpPort, strerror(errno));
return -1;
}
return -1;
}
if (mdclog_level_get() >= MDCLOG_DEBUG) {
return -1;
}
if (mdclog_level_get() >= MDCLOG_DEBUG) {
- struct sockaddr_in6 cliaddr {};
- socklen_t len = sizeof(cliaddr);
- getsockname(sctpParams.listenFD, (SA *)&cliaddr, &len);
+ struct sockaddr_in6 clientAddress {};
+ socklen_t len = sizeof(clientAddress);
+ getsockname(sctpParams.listenFD, (SA *)&clientAddress, &len);
- inet_ntop(AF_INET6, &cliaddr.sin6_addr, buff, sizeof(buff));
- mdclog_write(MDCLOG_DEBUG, "My address: %s, port %d\n", buff, htons(cliaddr.sin6_port));
+ inet_ntop(AF_INET6, &clientAddress.sin6_addr, buff, sizeof(buff));
+ mdclog_write(MDCLOG_DEBUG, "My address: %s, port %d\n", buff, htons(clientAddress.sin6_port));
}
if (listen(sctpParams.listenFD, SOMAXCONN) < 0) {
}
if (listen(sctpParams.listenFD, SOMAXCONN) < 0) {
}
int rmrPort = conf.getIntValue("nano");
if (rmrPort == -1) {
}
int rmrPort = conf.getIntValue("nano");
if (rmrPort == -1) {
- mdclog_write(MDCLOG_ERR, "illigal RMR port ");
+ mdclog_write(MDCLOG_ERR, "illegal RMR port ");
return -1;
}
sctpParams.rmrPort = (uint16_t)rmrPort;
return -1;
}
sctpParams.rmrPort = (uint16_t)rmrPort;
auto tmpStr = conf.getStringValue("loglevel");
if (tmpStr.length() == 0) {
auto tmpStr = conf.getStringValue("loglevel");
if (tmpStr.length() == 0) {
- mdclog_write(MDCLOG_ERR, "illigal loglevel. Set loglevel to MDCLOG_INFO");
+ mdclog_write(MDCLOG_ERR, "illegal loglevel. Set loglevel to MDCLOG_INFO");
tmpStr = "info";
}
transform(tmpStr.begin(), tmpStr.end(), tmpStr.begin(), ::tolower);
tmpStr = "info";
}
transform(tmpStr.begin(), tmpStr.end(), tmpStr.begin(), ::tolower);
} else if ((tmpStr.compare("error")) == 0) {
sctpParams.logLevel = MDCLOG_ERR;
} else {
} else if ((tmpStr.compare("error")) == 0) {
sctpParams.logLevel = MDCLOG_ERR;
} else {
- mdclog_write(MDCLOG_ERR, "illigal loglevel = %s. Set loglevel to MDCLOG_INFO", tmpStr.c_str());
+ mdclog_write(MDCLOG_ERR, "illegal loglevel = %s. Set loglevel to MDCLOG_INFO", tmpStr.c_str());
sctpParams.logLevel = MDCLOG_INFO;
}
mdclog_level_set(sctpParams.logLevel);
tmpStr = conf.getStringValue("volume");
if (tmpStr.length() == 0) {
sctpParams.logLevel = MDCLOG_INFO;
}
mdclog_level_set(sctpParams.logLevel);
tmpStr = conf.getStringValue("volume");
if (tmpStr.length() == 0) {
- mdclog_write(MDCLOG_ERR, "illigal volume.");
+ mdclog_write(MDCLOG_ERR, "illegal volume.");
sctpParams.myIP = conf.getStringValue("local-ip");
if (sctpParams.myIP.length() == 0) {
sctpParams.myIP = conf.getStringValue("local-ip");
if (sctpParams.myIP.length() == 0) {
- mdclog_write(MDCLOG_ERR, "illigal local-ip.");
+ mdclog_write(MDCLOG_ERR, "illegal local-ip.");
return -1;
}
int sctpPort = conf.getIntValue("sctp-port");
if (sctpPort == -1) {
return -1;
}
int sctpPort = conf.getIntValue("sctp-port");
if (sctpPort == -1) {
- mdclog_write(MDCLOG_ERR, "illigal SCTP port ");
+ mdclog_write(MDCLOG_ERR, "illegal SCTP port ");
return -1;
}
sctpParams.sctpPort = (uint16_t)sctpPort;
sctpParams.fqdn = conf.getStringValue("external-fqdn");
if (sctpParams.fqdn.length() == 0) {
return -1;
}
sctpParams.sctpPort = (uint16_t)sctpPort;
sctpParams.fqdn = conf.getStringValue("external-fqdn");
if (sctpParams.fqdn.length() == 0) {
- mdclog_write(MDCLOG_ERR, "illigal external-fqdn");
+ mdclog_write(MDCLOG_ERR, "illegal external-fqdn");
return -1;
}
std::string pod = conf.getStringValue("pod_name");
if (pod.length() == 0) {
return -1;
}
std::string pod = conf.getStringValue("pod_name");
if (pod.length() == 0) {
- mdclog_write(MDCLOG_ERR, "illigal pod_name in config file");
+ mdclog_write(MDCLOG_ERR, "illegal pod_name in config file");
return -1;
}
auto *podName = getenv(pod.c_str());
if (podName == nullptr) {
return -1;
}
auto *podName = getenv(pod.c_str());
if (podName == nullptr) {
- mdclog_write(MDCLOG_ERR, "illigal pod_name or environment varible not exists : %s", pod.c_str());
+ mdclog_write(MDCLOG_ERR, "illegal pod_name or environment varible not exists : %s", pod.c_str());
return -1;
} else {
sctpParams.podName.assign(podName);
if (sctpParams.podName.length() == 0) {
return -1;
} else {
sctpParams.podName.assign(podName);
if (sctpParams.podName.length() == 0) {
- mdclog_write(MDCLOG_ERR, "illigal pod_name");
+ mdclog_write(MDCLOG_ERR, "illegal pod_name");
//auto registry = std::make_shared<Registry>();
sctpParams.prometheusRegistry = std::make_shared<Registry>();
//auto registry = std::make_shared<Registry>();
sctpParams.prometheusRegistry = std::make_shared<Registry>();
- //sctpParams.promtheusFamily = new Family<Counter>("E2T", "E2T message counter", {{"E", sctpParams.podName}});
+ //sctpParams.prometheusFamily = new Family<Counter>("E2T", "E2T message counter", {{"E", sctpParams.podName}});
startPrometheus(sctpParams);
startPrometheus(sctpParams);
} else if (msg->state == 0) {
rmr_free_msg(msg);
if (mdclog_level_get() >= MDCLOG_INFO) {
} else if (msg->state == 0) {
rmr_free_msg(msg);
if (mdclog_level_get() >= MDCLOG_INFO) {
- mdclog_write(MDCLOG_INFO, "E2_TERM_INIT succsesfuly sent ");
+ mdclog_write(MDCLOG_INFO, "E2_TERM_INIT successfully sent ");
ReportingMessages_t message {};
ReportingMessages_t message {};
-// for (int i = 0; i < MAX_RMR_BUFF_ARRY; i++) {
+// for (int i = 0; i < MAX_RMR_BUFF_ARRAY; i++) {
// rmrMessageBuffer.rcvBufferedMessages[i] = rmr_alloc_msg(rmrMessageBuffer.rmrCtx, RECEIVE_XAPP_BUFFER_SIZE);
// rmrMessageBuffer.sendBufferedMessages[i] = rmr_alloc_msg(rmrMessageBuffer.rmrCtx, RECEIVE_XAPP_BUFFER_SIZE);
// }
// rmrMessageBuffer.rcvBufferedMessages[i] = rmr_alloc_msg(rmrMessageBuffer.rmrCtx, RECEIVE_XAPP_BUFFER_SIZE);
// rmrMessageBuffer.sendBufferedMessages[i] = rmr_alloc_msg(rmrMessageBuffer.rmrCtx, RECEIVE_XAPP_BUFFER_SIZE);
// }
in_len = sizeof(in_addr);
auto *peerInfo = (ConnectedCU_t *)calloc(1, sizeof(ConnectedCU_t));
in_len = sizeof(in_addr);
auto *peerInfo = (ConnectedCU_t *)calloc(1, sizeof(ConnectedCU_t));
+ if(peerInfo == nullptr){
mdclog_write(MDCLOG_ERR, "calloc failed");
break;
}
mdclog_write(MDCLOG_ERR, "calloc failed");
break;
}
auto tmpStr = conf.getStringValue("loglevel");
if (tmpStr.length() == 0) {
auto tmpStr = conf.getStringValue("loglevel");
if (tmpStr.length() == 0) {
- mdclog_write(MDCLOG_ERR, "illigal loglevel. Set loglevel to MDCLOG_INFO");
+ mdclog_write(MDCLOG_ERR, "illegal loglevel. Set loglevel to MDCLOG_INFO");
tmpStr = "info";
}
transform(tmpStr.begin(), tmpStr.end(), tmpStr.begin(), ::tolower);
tmpStr = "info";
}
transform(tmpStr.begin(), tmpStr.end(), tmpStr.begin(), ::tolower);
mdclog_write(MDCLOG_INFO, "Log level set to MDCLOG_ERR");
sctpParams->logLevel = MDCLOG_ERR;
} else {
mdclog_write(MDCLOG_INFO, "Log level set to MDCLOG_ERR");
sctpParams->logLevel = MDCLOG_ERR;
} else {
- mdclog_write(MDCLOG_ERR, "illigal loglevel = %s. Set loglevel to MDCLOG_INFO", tmpStr.c_str());
+ mdclog_write(MDCLOG_ERR, "illegal loglevel = %s. Set loglevel to MDCLOG_INFO", tmpStr.c_str());
sctpParams->logLevel = MDCLOG_INFO;
}
mdclog_level_set(sctpParams->logLevel);
sctpParams->logLevel = MDCLOG_INFO;
}
mdclog_level_set(sctpParams->logLevel);
tmpStr = conf.getStringValue("trace");
if (tmpStr.length() == 0) {
tmpStr = conf.getStringValue("trace");
if (tmpStr.length() == 0) {
- mdclog_write(MDCLOG_ERR, "illigal trace. Set trace to stop");
+ mdclog_write(MDCLOG_ERR, "illegal trace. Set trace to stop");
- * @param fd file discriptor
+ * @param fd file descriptor
* @param data the asn data to send
* @param len length of the data
* @param enodbName the enodbName as in the map for printing purpose
* @param m map host information
* @param mtype message number
* @param data the asn data to send
* @param len length of the data
* @param enodbName the enodbName as in the map for printing purpose
* @param m map host information
* @param mtype message number
- * @return 0 success, anegative number on fail
+ * @return 0 success, a negative number on fail
*/
int sendSctpMsg(ConnectedCU_t *peerInfo, ReportingMessages_t &message, Sctp_Map_t *m) {
auto loglevel = mdclog_level_get();
*/
int sendSctpMsg(ConnectedCU_t *peerInfo, ReportingMessages_t &message, Sctp_Map_t *m) {
auto loglevel = mdclog_level_get();
message.peerInfo = (ConnectedCU_t *)events->data.ptr;
struct timespec start{0, 0};
message.peerInfo = (ConnectedCU_t *)events->data.ptr;
struct timespec start{0, 0};
- struct timespec decodestart{0, 0};
+ struct timespec decodeStart{0, 0};
struct timespec end{0, 0};
E2AP_PDU_t *pdu = nullptr;
struct timespec end{0, 0};
E2AP_PDU_t *pdu = nullptr;
message.peerInfo->enodbName, end.tv_sec - start.tv_sec, end.tv_nsec - start.tv_nsec);
mdclog_write(MDCLOG_DEBUG, "PDU buffer length = %ld, data = : %s", message.message.asnLength,
printBuffer);
message.peerInfo->enodbName, end.tv_sec - start.tv_sec, end.tv_nsec - start.tv_nsec);
mdclog_write(MDCLOG_DEBUG, "PDU buffer length = %ld, data = : %s", message.message.asnLength,
printBuffer);
- clock_gettime(CLOCK_MONOTONIC, &decodestart);
+ clock_gettime(CLOCK_MONOTONIC, &decodeStart);
}
auto rval = asn_decode(nullptr, ATS_ALIGNED_BASIC_PER, &asn_DEF_E2AP_PDU, (void **) &pdu,
}
auto rval = asn_decode(nullptr, ATS_ALIGNED_BASIC_PER, &asn_DEF_E2AP_PDU, (void **) &pdu,
if (loglevel >= MDCLOG_DEBUG) {
clock_gettime(CLOCK_MONOTONIC, &end);
mdclog_write(MDCLOG_DEBUG, "After Encoding E2AP PDU for : %s, Read time is : %ld seconds, %ld nanoseconds",
if (loglevel >= MDCLOG_DEBUG) {
clock_gettime(CLOCK_MONOTONIC, &end);
mdclog_write(MDCLOG_DEBUG, "After Encoding E2AP PDU for : %s, Read time is : %ld seconds, %ld nanoseconds",
- message.peerInfo->enodbName, end.tv_sec - decodestart.tv_sec, end.tv_nsec - decodestart.tv_nsec);
+ message.peerInfo->enodbName, end.tv_sec - decodeStart.tv_sec, end.tv_nsec - decodeStart.tv_nsec);
char *printBuffer;
size_t size;
FILE *stream = open_memstream(&printBuffer, &size);
asn_fprint(stream, &asn_DEF_E2AP_PDU, pdu);
mdclog_write(MDCLOG_DEBUG, "Encoding E2AP PDU past : %s", printBuffer);
char *printBuffer;
size_t size;
FILE *stream = open_memstream(&printBuffer, &size);
asn_fprint(stream, &asn_DEF_E2AP_PDU, pdu);
mdclog_write(MDCLOG_DEBUG, "Encoding E2AP PDU past : %s", printBuffer);
- clock_gettime(CLOCK_MONOTONIC, &decodestart);
+ clock_gettime(CLOCK_MONOTONIC, &decodeStart);
}
switch (pdu->present) {
}
switch (pdu->present) {
break;
}
case E2AP_PDU_PR_successfulOutcome: { //successful outcome
break;
}
case E2AP_PDU_PR_successfulOutcome: { //successful outcome
- asnSuccsesfulMsg(pdu, sctpMap, message, rmrMessageBuffer);
+ asnSuccessfulMsg(pdu, sctpMap, message, rmrMessageBuffer);
break;
}
case E2AP_PDU_PR_unsuccessfulOutcome: { //Unsuccessful Outcome
break;
}
case E2AP_PDU_PR_unsuccessfulOutcome: { //Unsuccessful Outcome
clock_gettime(CLOCK_MONOTONIC, &end);
mdclog_write(MDCLOG_DEBUG,
"After processing message and sent to rmr for : %s, Read time is : %ld seconds, %ld nanoseconds",
clock_gettime(CLOCK_MONOTONIC, &end);
mdclog_write(MDCLOG_DEBUG,
"After processing message and sent to rmr for : %s, Read time is : %ld seconds, %ld nanoseconds",
- message.peerInfo->enodbName, end.tv_sec - decodestart.tv_sec, end.tv_nsec - decodestart.tv_nsec);
+ message.peerInfo->enodbName, end.tv_sec - decodeStart.tv_sec, end.tv_nsec - decodeStart.tv_nsec);
}
numOfMessages++;
if (pdu != nullptr) {
}
numOfMessages++;
if (pdu != nullptr) {
-static void buildAndsendSetupRequest(ReportingMessages_t &message,
+static void buildAndSendSetupRequest(ReportingMessages_t &message,
RmrMessagesBuffer_t &rmrMessageBuffer,
E2AP_PDU_t *pdu/*,
string const &messageName,
RmrMessagesBuffer_t &rmrMessageBuffer,
E2AP_PDU_t *pdu/*,
string const &messageName,
-void buildPrometheuslist(ConnectedCU_t *peerInfo, Family<Counter> *prometheusFamily) {
+void buildPrometheusList(ConnectedCU_t *peerInfo, Family<Counter> *prometheusFamily) {
peerInfo->counters[IN_INITI][MSG_COUNTER][(ProcedureCode_id_E2setup)] = &prometheusFamily->Add({{peerInfo->enodbName, "IN"}, {"SetupRequest", "Messages"}});
peerInfo->counters[IN_INITI][BYTES_COUNTER][(ProcedureCode_id_E2setup)] = &prometheusFamily->Add({{peerInfo->enodbName, "IN"}, {"SetupRequest", "Bytes"}});
peerInfo->counters[IN_INITI][MSG_COUNTER][(ProcedureCode_id_E2setup)] = &prometheusFamily->Add({{peerInfo->enodbName, "IN"}, {"SetupRequest", "Messages"}});
peerInfo->counters[IN_INITI][BYTES_COUNTER][(ProcedureCode_id_E2setup)] = &prometheusFamily->Add({{peerInfo->enodbName, "IN"}, {"SetupRequest", "Bytes"}});
if (ie->value.present == E2setupRequestIEs__value_PR_GlobalE2node_ID) {
if (buildRanName(message.peerInfo->enodbName, ie) < 0) {
mdclog_write(MDCLOG_ERR, "Bad param in E2setupRequestIEs GlobalE2node_ID.\n");
if (ie->value.present == E2setupRequestIEs__value_PR_GlobalE2node_ID) {
if (buildRanName(message.peerInfo->enodbName, ie) < 0) {
mdclog_write(MDCLOG_ERR, "Bad param in E2setupRequestIEs GlobalE2node_ID.\n");
- // no mesage will be sent
+ // no message will be sent
- buildPrometheuslist(message.peerInfo, message.peerInfo->sctpParams->prometheusFamily);
+ buildPrometheusList(message.peerInfo, message.peerInfo->sctpParams->prometheusFamily);
string messageName("E2setupRequest");
string ieName("E2setupRequestIEs");
message.message.messageType = RIC_E2_SETUP_REQ;
message.peerInfo->counters[IN_INITI][MSG_COUNTER][ProcedureCode_id_E2setup]->Increment();
message.peerInfo->counters[IN_INITI][BYTES_COUNTER][ProcedureCode_id_E2setup]->Increment((double)message.message.asnLength);
string messageName("E2setupRequest");
string ieName("E2setupRequestIEs");
message.message.messageType = RIC_E2_SETUP_REQ;
message.peerInfo->counters[IN_INITI][MSG_COUNTER][ProcedureCode_id_E2setup]->Increment();
message.peerInfo->counters[IN_INITI][BYTES_COUNTER][ProcedureCode_id_E2setup]->Increment((double)message.message.asnLength);
- buildAndsendSetupRequest(message, rmrMessageBuffer, pdu);
+ buildAndSendSetupRequest(message, rmrMessageBuffer, pdu);
break;
}
case ProcedureCode_id_RICserviceUpdate: {
break;
}
case ProcedureCode_id_RICserviceUpdate: {
message.peerInfo->counters[IN_INITI][MSG_COUNTER][ProcedureCode_id_RICserviceUpdate]->Increment();
message.peerInfo->counters[IN_INITI][BYTES_COUNTER][ProcedureCode_id_RICserviceUpdate]->Increment((double)message.message.asnLength);
message.peerInfo->counters[IN_INITI][MSG_COUNTER][ProcedureCode_id_RICserviceUpdate]->Increment();
message.peerInfo->counters[IN_INITI][BYTES_COUNTER][ProcedureCode_id_RICserviceUpdate]->Increment((double)message.message.asnLength);
- buildAndsendSetupRequest(message, rmrMessageBuffer, pdu);
+ buildAndSendSetupRequest(message, rmrMessageBuffer, pdu);
break;
}
case ProcedureCode_id_ErrorIndication: {
break;
}
case ProcedureCode_id_ErrorIndication: {
sendRmrMessage(rmrMessageBuffer, message);
messageSent = true;
} else {
sendRmrMessage(rmrMessageBuffer, message);
messageSent = true;
} else {
- mdclog_write(MDCLOG_ERR, "RIC request id missing illigal request");
+ mdclog_write(MDCLOG_ERR, "RIC request id missing illegal request");
* @param message
* @param rmrMessageBuffer
*/
* @param message
* @param rmrMessageBuffer
*/
-void asnSuccsesfulMsg(E2AP_PDU_t *pdu,
+void asnSuccessfulMsg(E2AP_PDU_t *pdu,
Sctp_Map_t *sctpMap,
ReportingMessages_t &message,
RmrMessagesBuffer_t &rmrMessageBuffer) {
Sctp_Map_t *sctpMap,
ReportingMessages_t &message,
RmrMessagesBuffer_t &rmrMessageBuffer) {
sendRmrMessage(rmrMessageBuffer, message);
messageSent = true;
} else {
sendRmrMessage(rmrMessageBuffer, message);
messageSent = true;
} else {
- mdclog_write(MDCLOG_ERR, "RIC request id missing illigal request");
+ mdclog_write(MDCLOG_ERR, "RIC request id missing illegal request");
sendRmrMessage(rmrMessageBuffer, message);
messageSent = true;
} else {
sendRmrMessage(rmrMessageBuffer, message);
messageSent = true;
} else {
- mdclog_write(MDCLOG_ERR, "RIC request id missing illigal request");
+ mdclog_write(MDCLOG_ERR, "RIC request id missing illegal request");
}
auto rval = asn_decode(nullptr, ATS_BASIC_XER, &asn_DEF_E2AP_PDU, (void **) &pdu,
rmrMessageBuffer.rcvMessage->payload, rmrMessageBuffer.rcvMessage->len);
}
auto rval = asn_decode(nullptr, ATS_BASIC_XER, &asn_DEF_E2AP_PDU, (void **) &pdu,
rmrMessageBuffer.rcvMessage->payload, rmrMessageBuffer.rcvMessage->len);
+ if (mdclog_level_get() >= MDCLOG_DEBUG) {
+ mdclog_write(MDCLOG_DEBUG, "%s After decoding the XML to PDU", __func__ );
+ }
if (rval.code != RC_OK) {
mdclog_write(MDCLOG_ERR, "Error %d Decoding (unpack) setup response from E2MGR : %s",
rval.code,
if (rval.code != RC_OK) {
mdclog_write(MDCLOG_ERR, "Error %d Decoding (unpack) setup response from E2MGR : %s",
rval.code,
int buff_size = RECEIVE_XAPP_BUFFER_SIZE;
auto er = asn_encode_to_buffer(nullptr, ATS_ALIGNED_BASIC_PER, &asn_DEF_E2AP_PDU, pdu,
rmrMessageBuffer.rcvMessage->payload, buff_size);
int buff_size = RECEIVE_XAPP_BUFFER_SIZE;
auto er = asn_encode_to_buffer(nullptr, ATS_ALIGNED_BASIC_PER, &asn_DEF_E2AP_PDU, pdu,
rmrMessageBuffer.rcvMessage->payload, buff_size);
+ if (mdclog_level_get() >= MDCLOG_DEBUG) {
+ mdclog_write(MDCLOG_DEBUG, "%s After encoding PDU to PER", __func__ );
+ }
if (er.encoded == -1) {
mdclog_write(MDCLOG_ERR, "encoding of %s failed, %s", asn_DEF_E2AP_PDU.name, strerror(errno));
return -1;
if (er.encoded == -1) {
mdclog_write(MDCLOG_ERR, "encoding of %s failed, %s", asn_DEF_E2AP_PDU.name, strerror(errno));
return -1;
// }
rmrMessageBuffer.rcvMessage = rmr_rcv_msg(rmrMessageBuffer.rmrCtx, rmrMessageBuffer.rcvMessage);
if (rmrMessageBuffer.rcvMessage == nullptr) {
// }
rmrMessageBuffer.rcvMessage = rmr_rcv_msg(rmrMessageBuffer.rmrCtx, rmrMessageBuffer.rcvMessage);
if (rmrMessageBuffer.rcvMessage == nullptr) {
- mdclog_write(MDCLOG_ERR, "RMR Receving message with null pointer, Realloc rmr mesage buffer");
+ mdclog_write(MDCLOG_ERR, "RMR Receiving message with null pointer, Reallocated rmr message buffer");
rmrMessageBuffer.rcvMessage = rmr_alloc_msg(rmrMessageBuffer.rmrCtx, RECEIVE_XAPP_BUFFER_SIZE);
return -2;
}
rmrMessageBuffer.rcvMessage = rmr_alloc_msg(rmrMessageBuffer.rmrCtx, RECEIVE_XAPP_BUFFER_SIZE);
return -2;
}
// get message payload
//auto msgData = msg->payload;
if (rmrMessageBuffer.rcvMessage->state != 0) {
// get message payload
//auto msgData = msg->payload;
if (rmrMessageBuffer.rcvMessage->state != 0) {
- mdclog_write(MDCLOG_ERR, "RMR Receving message with stat = %d", rmrMessageBuffer.rcvMessage->state);
+ mdclog_write(MDCLOG_ERR, "RMR Receiving message with stat = %d", rmrMessageBuffer.rcvMessage->state);
return -1;
}
rmr_get_meid(rmrMessageBuffer.rcvMessage, (unsigned char *)message.message.enodbName);
return -1;
}
rmr_get_meid(rmrMessageBuffer.rcvMessage, (unsigned char *)message.message.enodbName);
- mdclog_write(MDCLOG_WARN, "Message Type : %d is not seported", rmrMessageBuffer.rcvMessage->mtype);
+ mdclog_write(MDCLOG_WARN, "Message Type : %d is not supported", rmrMessageBuffer.rcvMessage->mtype);
message.message.asndata = rmrMessageBuffer.rcvMessage->payload;
message.message.asnLength = rmrMessageBuffer.rcvMessage->len;
message.message.time.tv_nsec = ts.tv_nsec;
message.message.asndata = rmrMessageBuffer.rcvMessage->payload;
message.message.asnLength = rmrMessageBuffer.rcvMessage->len;
message.message.time.tv_nsec = ts.tv_nsec;
ReportingMessages_t &message,
int failedMsgId,
Sctp_Map_t *sctpMap) {
ReportingMessages_t &message,
int failedMsgId,
Sctp_Map_t *sctpMap) {
+ if (mdclog_level_get() >= MDCLOG_DEBUG) {
+ mdclog_write(MDCLOG_DEBUG, "send message: %d to %s address", message.message.messageType, message.message.enodbName);
+ }
getRequestMetaData(message, messageBuffer);
if (mdclog_level_get() >= MDCLOG_INFO) {
getRequestMetaData(message, messageBuffer);
if (mdclog_level_get() >= MDCLOG_INFO) {
event.events = events;
if (epoll_ctl(epoll_fd, EPOLL_CTL_ADD, peerInfo->fileDescriptor, &event) < 0) {
if (mdclog_level_get() >= MDCLOG_DEBUG) {
event.events = events;
if (epoll_ctl(epoll_fd, EPOLL_CTL_ADD, peerInfo->fileDescriptor, &event) < 0) {
if (mdclog_level_get() >= MDCLOG_DEBUG) {
- mdclog_write(MDCLOG_DEBUG, "epoll_ctl EPOLL_CTL_ADD (may chack not to quit here), %s, %s %d",
+ mdclog_write(MDCLOG_DEBUG, "epoll_ctl EPOLL_CTL_ADD (may check not to quit here), %s, %s %d",
strerror(errno), __func__, __LINE__);
}
close(peerInfo->fileDescriptor);
strerror(errno), __func__, __LINE__);
}
close(peerInfo->fileDescriptor);
} else {
peerInfo->enodbName[0] = 0;
}
} else {
peerInfo->enodbName[0] = 0;
}
- mdclog_write(MDCLOG_ERR, "epoll_ctl EPOLL_CTL_ADD (may chack not to quit here)");
+ mdclog_write(MDCLOG_ERR, "epoll_ctl EPOLL_CTL_ADD (may check not to quit here)");
event.events = events;
if (epoll_ctl(epoll_fd, EPOLL_CTL_MOD, peerInfo->fileDescriptor, &event) < 0) {
if (mdclog_level_get() >= MDCLOG_DEBUG) {
event.events = events;
if (epoll_ctl(epoll_fd, EPOLL_CTL_MOD, peerInfo->fileDescriptor, &event) < 0) {
if (mdclog_level_get() >= MDCLOG_DEBUG) {
- mdclog_write(MDCLOG_DEBUG, "epoll_ctl EPOLL_CTL_MOD (may chack not to quit here), %s, %s %d",
+ mdclog_write(MDCLOG_DEBUG, "epoll_ctl EPOLL_CTL_MOD (may check not to quit here), %s, %s %d",
strerror(errno), __func__, __LINE__);
}
close(peerInfo->fileDescriptor);
strerror(errno), __func__, __LINE__);
}
close(peerInfo->fileDescriptor);
free(tmp);
}
sctpMap->erase(key);
free(tmp);
}
sctpMap->erase(key);
- mdclog_write(MDCLOG_ERR, "epoll_ctl EPOLL_CTL_ADD (may chack not to quit here)");
+ mdclog_write(MDCLOG_ERR, "epoll_ctl EPOLL_CTL_ADD (may check not to quit here)");
str = "RMR_OK - state is good";
break;
case RMR_ERR_BADARG:
str = "RMR_OK - state is good";
break;
case RMR_ERR_BADARG:
- str = "RMR_ERR_BADARG - argument passd to function was unusable";
+ str = "RMR_ERR_BADARG - argument passed to function was unusable";
break;
case RMR_ERR_NOENDPT:
str = "RMR_ERR_NOENDPT - send//call could not find an endpoint based on msg type";
break;
case RMR_ERR_NOENDPT:
str = "RMR_ERR_NOENDPT - send//call could not find an endpoint based on msg type";
Sctp_Map_t *sctpMap = nullptr;
char ka_message[KA_MESSAGE_SIZE] {};
int ka_message_length = 0;
Sctp_Map_t *sctpMap = nullptr;
char ka_message[KA_MESSAGE_SIZE] {};
int ka_message_length = 0;
- char rmrAddress[256] {}; // "tcp:portnumber" "tcp:5566" listen to all address on port 5566
+ char rmrAddress[256] {}; // "tcp:port number" "tcp:5566" listen to all address on port 5566
mdclog_severity_t logLevel = MDCLOG_INFO;
char volume[VOLUME_URL_SIZE];
string myIP {};
mdclog_severity_t logLevel = MDCLOG_INFO;
char volume[VOLUME_URL_SIZE];
string myIP {};
// RAN to RIC
#define IN_INITI 0 //INITIATING
// RAN to RIC
#define IN_INITI 0 //INITIATING
-#define IN_SUCC 1 //SUCCESSFULL
-#define IN_UN_SUCC 2 //UN-Successfull
+#define IN_SUCC 1 //SUCCESSFUL
+#define IN_UN_SUCC 2 //UN-Successful
// RIC To RAN
#define OUT_INITI 3 //INITIATING
// RIC To RAN
#define OUT_INITI 3 //INITIATING
-#define OUT_SUCC 4 //SUCCESSFULL
-#define OUT_UN_SUCC 5 //UN-Successfull
+#define OUT_SUCC 4 //SUCCESSFUL
+#define OUT_UN_SUCC 5 //UN-Successful
#define MSG_COUNTER 0
#define BYTES_COUNTER 1
#define MSG_COUNTER 0
#define BYTES_COUNTER 1
-#define MAX_RMR_BUFF_ARRY 32
+#define MAX_RMR_BUFF_ARRAY 32
typedef struct RmrMessagesBuffer {
char ka_message[KA_MESSAGE_SIZE] {};
int ka_message_len = 0;
void *rmrCtx = nullptr;
rmr_mbuf_t *sendMessage= nullptr;
typedef struct RmrMessagesBuffer {
char ka_message[KA_MESSAGE_SIZE] {};
int ka_message_len = 0;
void *rmrCtx = nullptr;
rmr_mbuf_t *sendMessage= nullptr;
- //rmr_mbuf_t *sendBufferedMessages[MAX_RMR_BUFF_ARRY] {};
+ //rmr_mbuf_t *sendBufferedMessages[MAX_RMR_BUFF_ARRAY] {};
rmr_mbuf_t *rcvMessage= nullptr;
rmr_mbuf_t *rcvMessage= nullptr;
- //rmr_mbuf_t *rcvBufferedMessages[MAX_RMR_BUFF_ARRY] {};
+ //rmr_mbuf_t *rcvBufferedMessages[MAX_RMR_BUFF_ARRAY] {};
} RmrMessagesBuffer_t;
typedef struct formatedMessage {
} RmrMessagesBuffer_t;
typedef struct formatedMessage {
* @param message
* @param failedMesgId
* @return
*/
int sendMessagetoCu(Sctp_Map_t *sctpMap,
* @param message
* @param failedMesgId
* @return
*/
int sendMessagetoCu(Sctp_Map_t *sctpMap,
- RmrMessagesBuffer_t &messagBuffer,
+ RmrMessagesBuffer_t &messageBuffer,
ReportingMessages_t &message,
int failedMesgId);
ReportingMessages_t &message,
int failedMesgId);
- * @param epoll_fd
- * @param rmrCtx
+ * @param rmrMessageBuffer
+ * @param ts
* @return
*/
int receiveXappMessages(Sctp_Map_t *sctpMap,
* @return
*/
int receiveXappMessages(Sctp_Map_t *sctpMap,
* @param failedMsgId
* @param sctpMap
* @return
*/
* @param failedMsgId
* @param sctpMap
* @return
*/
-int sendDirectionalSctpMsg(RmrMessagesBuffer_t &messagBuffer,
+int sendDirectionalSctpMsg(RmrMessagesBuffer_t &messageBuffer,
ReportingMessages_t &message,
int failedMsgId,
Sctp_Map_t *sctpMap);
ReportingMessages_t &message,
int failedMsgId,
Sctp_Map_t *sctpMap);
* @param sctpMap
* @param rmrMessageBuffer
*/
* @param sctpMap
* @param rmrMessageBuffer
*/
-void asnSuccsesfulMsg(E2AP_PDU_t *pdu,
+void asnSuccessfulMsg(E2AP_PDU_t *pdu,
Sctp_Map_t *sctpMap,
ReportingMessages_t &message,
RmrMessagesBuffer_t &rmrMessageBuffer);
Sctp_Map_t *sctpMap,
ReportingMessages_t &message,
RmrMessagesBuffer_t &rmrMessageBuffer);