#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
char portNumber[NI_MAXSERV] {};
char enodbName[MAX_ENODB_NAME_SIZE] {};
char asnData[RECEIVE_SCTP_BUFFER_SIZE] {};
- int rcvMsgs = 0;
- int sentMesgs = 0;
size_t asnLength = 0;
int mtype = 0;
bool isConnected = false;
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);
* @param messagBuffer
* @return
*/
-int receiveXappMessages(int epoll_fd,
- Sctp_Map_t *sctpMap,
+int receiveXappMessages(Sctp_Map_t *sctpMap,
RmrMessagesBuffer_t &rmrMessageBuffer,
struct timespec &ts);