#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"
typedef mapWrapper Sctp_Map_t;
+
#define VOLUME_URL_SIZE 256
#define KA_MESSAGE_SIZE 2048
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);
/**