#include "cxxopts.hpp"
//#include "config-cpp/include/config-cpp/config-cpp.h"
-#ifdef __TRACING__
-#include "openTracing.h"
-#endif
#include "mapWrapper.h"
+#include "statCollector.h"
#include "base64.h"
#define MAXEVENTS 128
-#define RECEIVE_SCTP_BUFFER_SIZE (8 * 1024)
+#define RECEIVE_SCTP_BUFFER_SIZE (128 * 1024)
#define RECEIVE_XAPP_BUFFER_SIZE RECEIVE_SCTP_BUFFER_SIZE
typedef mapWrapper Sctp_Map_t;
+
#define VOLUME_URL_SIZE 256
#define KA_MESSAGE_SIZE 2048
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_ARRY] {};
rmr_mbuf_t *rcvMessage= nullptr;
- rmr_mbuf_t *rcvBufferedMessages[MAX_RMR_BUFF_ARRY] {};
+ //rmr_mbuf_t *rcvBufferedMessages[MAX_RMR_BUFF_ARRY] {};
} RmrMessagesBuffer_t;
typedef struct formatedMessage {
long outLen = 0;
unsigned char base64Data[RECEIVE_SCTP_BUFFER_SIZE * 2] {};
char buffer[RECEIVE_SCTP_BUFFER_SIZE * 8] {};
+ StatCollector *statCollector = nullptr;
} ReportingMessages_t;
cxxopts::ParseResult parse(int argc, char *argv[], sctp_params_t &pSctpParams);
void cleanHashEntry(ConnectedCU_t *peerInfo, Sctp_Map_t *m);
-int getSetupRequestMetaData(ReportingMessages_t &message, char *data, char *host, uint16_t &port);
/**
*
* @param messagBuffer
* @return
*/
-int receiveXappMessages(int epoll_fd,
- Sctp_Map_t *sctpMap,
+int receiveXappMessages(Sctp_Map_t *sctpMap,
RmrMessagesBuffer_t &rmrMessageBuffer,
struct timespec &ts);
-/**
- *
- * @param rmrMessageBuffer
- * @param message
- * @param epoll_fd
- * @param sctpMap
- * @return
- */
-int connectToCUandSetUp(RmrMessagesBuffer_t &rmrMessageBuffer,
- ReportingMessages_t &message,
- int epoll_fd,
- Sctp_Map_t *sctpMap);
-
/**
*
* @param messagBuffer
*/
void asnSuccsesfulMsg(E2AP_PDU_t *pdu,
ReportingMessages_t &message,
- Sctp_Map_t *sctpMap,
RmrMessagesBuffer_t &rmrMessageBuffer);
/**
*
*/
void asnUnSuccsesfulMsg(E2AP_PDU_t *pdu,
ReportingMessages_t &message,
- Sctp_Map_t *sctpMap,
RmrMessagesBuffer_t &rmrMessageBuffer);
/**