#include <atomic>
#include <sys/param.h>
#include <sys/file.h>
+#include <sys/types.h>
+#include <ifaddrs.h>
#include <ctime>
#include <netdb.h>
#include <sys/epoll.h>
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 {};
string configFilePath {};
string configFileName {};
bool trace = true;
- string prometheusMode {"pull"};
- string prometheusPushAddress {"127.0.0.1:7676"};
shared_ptr<prometheus::Registry> prometheusRegistry;
string prometheusPort {"8088"};
Family<Counter> *prometheusFamily;
- Gateway *prometheusGateway = nullptr;
Exposer *prometheusExposer = nullptr;
+ Counter *e2tCounters[6][2][ProcedureCode_id_RICsubscriptionDelete + 1] {};
} sctp_params_t;
// 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
-#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
bool isConnected = false;
bool gotSetup = false;
sctp_params_t *sctpParams = nullptr;
- Counter *counters[6][2][ProcedureCode_id_RICsubscriptionDelete] {};
+ Counter *counters[6][2][ProcedureCode_id_RICsubscriptionDelete + 1] {};
} ConnectedCU_t ;
-#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;
- //rmr_mbuf_t *sendBufferedMessages[MAX_RMR_BUFF_ARRY] {};
+ //rmr_mbuf_t *sendBufferedMessages[MAX_RMR_BUFF_ARRAY] {};
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 {
/**
*
* @param sctpMap
- * @param messagBuffer
+ * @param messageBuffer
* @param message
* @param failedMesgId
* @return
*/
int sendMessagetoCu(Sctp_Map_t *sctpMap,
- RmrMessagesBuffer_t &messagBuffer,
+ RmrMessagesBuffer_t &messageBuffer,
ReportingMessages_t &message,
int failedMesgId);
/**
*
- * @param epoll_fd
- * @param rmrCtx
* @param sctpMap
- * @param messagBuffer
+ * @param rmrMessageBuffer
+ * @param ts
* @return
*/
int receiveXappMessages(Sctp_Map_t *sctpMap,
/**
*
- * @param messagBuffer
+ * @param messageBuffer
* @param failedMsgId
* @param sctpMap
* @return
*/
-int sendDirectionalSctpMsg(RmrMessagesBuffer_t &messagBuffer,
+int sendDirectionalSctpMsg(RmrMessagesBuffer_t &messageBuffer,
ReportingMessages_t &message,
int failedMsgId,
Sctp_Map_t *sctpMap);
* @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);
*/
string translateRmrErrorMessages(int state);
+int buildConfiguration(sctp_params_t &sctpParams);
+void startPrometheus(sctp_params_t &sctpParams);
+static int enable_log_change_notify(const char* fileName);
+static int register_log_change_notify(const char *fileName);
+static void * monitor_loglevel_change_handler(void* arg);
+void update_mdc_log_level_severity(char* log_level);
+char* getinterfaceip();
+static char* parse_file(char* filename);
+
static inline uint64_t rdtscp(uint32_t &aux) {
uint64_t rax,rdx;
#define RIC_SCTP_CONNECTION_FAILURE 10080
#endif
+#ifdef UNIT_TEST
+ #define FILE_DESCRIPTOR 53424 /*Dummy value for file descriptor only when UT is defined*/
+#endif
+
+int buildListeningPort(sctp_params_t &sctpParams);
+void buildE2TPrometheusCounters(sctp_params_t &sctpParams);
+
#endif //X2_SCTP_THREAD_H