X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=RIC-E2-TERMINATION%2FsctpThread.cpp;fp=RIC-E2-TERMINATION%2FsctpThread.cpp;h=fc32c363bf90aeec5fe55f9eb7887cc1117cf220;hb=a62ff9eb5772ab8aff486fb2f2de960af26232c3;hp=b0f58ab714be362a9c688073b6c144fcd88d9984;hpb=b18770630126b37e52930954672167aae649b3a0;p=ric-plt%2Fe2.git

diff --git a/RIC-E2-TERMINATION/sctpThread.cpp b/RIC-E2-TERMINATION/sctpThread.cpp
index b0f58ab..fc32c36 100644
--- a/RIC-E2-TERMINATION/sctpThread.cpp
+++ b/RIC-E2-TERMINATION/sctpThread.cpp
@@ -921,14 +921,16 @@ void listener(sctp_params_t *params) {
 #if !(defined(UNIT_TEST) || defined(MODULE_TEST))
                         if ((errno == EAGAIN) || (errno == EWOULDBLOCK)) {
                             /* We have processed all incoming connections. */
-                            if(peerInfo)
+                            if(peerInfo) {
                                 free(peerInfo);
                                 peerInfo = nullptr;
+                            }
                             break;
                         } else {
-                            if(peerInfo)
+                            if(peerInfo) {
                                 free(peerInfo);
                                 peerInfo = nullptr;
+                            }
                             mdclog_write(MDCLOG_ERR, "Accept error, errno = %s", strerror(errno));
                             break;
                         }
@@ -936,9 +938,10 @@ void listener(sctp_params_t *params) {
                     if (setSocketNoBlocking(peerInfo->fileDescriptor) == -1) {
                         mdclog_write(MDCLOG_ERR, "setSocketNoBlocking failed to set new connection %s on port %s\n", hostBuff, portBuff);
                         close(peerInfo->fileDescriptor);
-                        if(peerInfo)
+                        if(peerInfo) {
                             free(peerInfo);
                             peerInfo = nullptr;
+                        }
                         break;
 #endif
                     }
@@ -953,9 +956,10 @@ void listener(sctp_params_t *params) {
                     if (ans < 0) {
                         mdclog_write(MDCLOG_ERR, "Failed to get info on connection request. %s\n", strerror(errno));
                         close(peerInfo->fileDescriptor);
-                        if(peerInfo)
+                        if(peerInfo) {
                             free(peerInfo);
                             peerInfo = nullptr;
+                        }
                         break;
                     }
                     if (mdclog_level_get() >= MDCLOG_DEBUG) {
@@ -968,9 +972,10 @@ void listener(sctp_params_t *params) {
                                    (EPOLLIN | EPOLLET),
                                    params->sctpMap, nullptr,
                                    0) != 0) {
-                        if(peerInfo)
+                        if(peerInfo) {
                             free(peerInfo);
                             peerInfo = nullptr;
+                        }
                         break;
                     }
                     break;
@@ -1261,28 +1266,25 @@ int setSocketNoBlocking(int socket) {
  * @param m
  */
 void cleanHashEntry(ConnectedCU_t *val, Sctp_Map_t *m) {
-    if(val != nullptr)
-    {
-    char *dummy;
-    auto port = (uint16_t) strtol(val->portNumber, &dummy, 10);
-    char searchBuff[2048]{};
+    if(val != nullptr) {
+        char *dummy;
+        auto port = (uint16_t) strtol(val->portNumber, &dummy, 10);
+        char searchBuff[2048]{};
 
-    snprintf(searchBuff, sizeof searchBuff, "host:%s:%d", val->hostName, port);
-    if(m->find(searchBuff))
-    {
-    m->erase(searchBuff);
-    }
+        snprintf(searchBuff, sizeof searchBuff, "host:%s:%d", val->hostName, port);
+        if(m->find(searchBuff)) {
+            m->erase(searchBuff);
+        }
 
-    if(m->find(val->enodbName))
-    {
-    mdclog_write(MDCLOG_DEBUG, "remove key enodbName = %s from %s at line %d", val->enodbName, __FUNCTION__, __LINE__);
-    m->erase(val->enodbName);
-    }
+        if(m->find(val->enodbName)) {
+            mdclog_write(MDCLOG_DEBUG, "remove key enodbName = %s from %s at line %d", val->enodbName, __FUNCTION__, __LINE__);
+            m->erase(val->enodbName);
+        }
 #ifndef UNIT_TEST
-    if(val) {
-       free(val);
-       val = nullptr;
-    }
+        if(val) {
+            free(val);
+            val = nullptr;
+        }
 #endif
     }
 }
@@ -1400,7 +1402,7 @@ int receiveDataFromSctp(struct epoll_event *events,
 
     // get the identity of the interface
     if (events->data.ptr != nullptr){
-    message.peerInfo = (ConnectedCU_t *)events->data.ptr;
+        message.peerInfo = (ConnectedCU_t *)events->data.ptr;
     }
 
     struct timespec start{0, 0};
@@ -2280,12 +2282,12 @@ case ProcedureCode_id_E2nodeConfigurationUpdate: {
                 mdclog_write(MDCLOG_DEBUG, "Got RICsubscriptionDeleteRequired %s", message.message.enodbName);
             }
         #if !(defined(UNIT_TEST) || defined(MODULE_TEST))
-                    message.peerInfo->counters[IN_INITI][MSG_COUNTER][ProcedureCode_id_RICsubscriptionDeleteRequired]->Increment();
-                    message.peerInfo->counters[IN_INITI][BYTES_COUNTER][ProcedureCode_id_RICsubscriptionDeleteRequired]->Increment((double)message.message.asnLength);
+            message.peerInfo->counters[IN_INITI][MSG_COUNTER][ProcedureCode_id_RICsubscriptionDeleteRequired]->Increment();
+            message.peerInfo->counters[IN_INITI][BYTES_COUNTER][ProcedureCode_id_RICsubscriptionDeleteRequired]->Increment((double)message.message.asnLength);
 
-                    // Update E2T instance level metrics
-                    message.peerInfo->sctpParams->e2tCounters[IN_INITI][MSG_COUNTER][ProcedureCode_id_RICsubscriptionDeleteRequired]->Increment();
-                    message.peerInfo->sctpParams->e2tCounters[IN_INITI][BYTES_COUNTER][ProcedureCode_id_RICsubscriptionDeleteRequired]->Increment((double)message.message.asnLength);
+            // Update E2T instance level metrics
+            message.peerInfo->sctpParams->e2tCounters[IN_INITI][MSG_COUNTER][ProcedureCode_id_RICsubscriptionDeleteRequired]->Increment();
+            message.peerInfo->sctpParams->e2tCounters[IN_INITI][BYTES_COUNTER][ProcedureCode_id_RICsubscriptionDeleteRequired]->Increment((double)message.message.asnLength);
         #endif
             if (sendRequestToXapp(message, RIC_SUB_DEL_REQUIRED, rmrMessageBuffer) != 0) {
                 mdclog_write(MDCLOG_ERR, "Subscription Delete Required message failed to send to xAPP");
@@ -3240,7 +3242,7 @@ int modifyToEpoll(int epoll_fd,
         if (tmp) {
             free(tmp);
             tmp = nullptr;
-        sctpMap->erase(key);
+            sctpMap->erase(key);
         }
         mdclog_write(MDCLOG_ERR, "epoll_ctl EPOLL_CTL_ADD (may check not to quit here)");
         return -1;