5.4.1 Stop counting HC messages to avoid skiping Term_INIT message umtil E2M send KA
Change-Id: I39bd353efe56e3b155d80e9d4f51905f9941b55b
Signed-off-by: aa7133@att.com <aa7133@att.com>
diff --git a/RIC-E2-TERMINATION/sctpThread.cpp b/RIC-E2-TERMINATION/sctpThread.cpp
index ddcaae2..36f5e34 100644
--- a/RIC-E2-TERMINATION/sctpThread.cpp
+++ b/RIC-E2-TERMINATION/sctpThread.cpp
@@ -482,7 +482,7 @@
("f,file", "config file name", cxxopts::value<std::string>(sctpParams.configFileName)->default_value("config.conf"))
("h,help", "Print help");
- auto result = options.parse(argc, argv);
+ auto result = options.parse(argc, (const char **&)argv);
if (result.count("help")) {
std::cout << options.help({""}) << std::endl;
@@ -671,7 +671,7 @@
}
} else if (params->rmrListenFd == events[i].data.fd) {
// got message from XAPP
- num_of_XAPP_messages.fetch_add(1, std::memory_order_release);
+ //num_of_XAPP_messages.fetch_add(1, std::memory_order_release);
num_of_messages.fetch_add(1, std::memory_order_release);
if (mdclog_level_get() >= MDCLOG_DEBUG) {
mdclog_write(MDCLOG_DEBUG, "new message from RMR");
@@ -2067,6 +2067,10 @@
}
}
+ if (rmrMessageBuffer.rcvMessage->mtype != RIC_HEALTH_CHECK_REQ) {
+ num_of_XAPP_messages.fetch_add(1, std::memory_order_release);
+
+ }
switch (rmrMessageBuffer.rcvMessage->mtype) {
case RIC_E2_SETUP_RESP : {
if (PER_FromXML(message, rmrMessageBuffer) != 0) {