X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fcu_stub%2Fcu_stub_sctp.c;h=ab262d54ab82cfcc2a01df3cd631d2c9c49664c1;hb=4d45b914f9e94203603d3b9fdbcb1aad361301dd;hp=627abddf143383aad24b8abcec68cb9c6773ebce;hpb=6b44407d464a5a4e060999255233a7cfe78bb0fa;p=o-du%2Fl2.git diff --git a/src/cu_stub/cu_stub_sctp.c b/src/cu_stub/cu_stub_sctp.c index 627abddf1..ab262d54a 100644 --- a/src/cu_stub/cu_stub_sctp.c +++ b/src/cu_stub/cu_stub_sctp.c @@ -108,7 +108,7 @@ S16 sctpCfgReq() memset(&f1Params.lstnSockFd, -1, sizeof(CmInetFd)); fillDestNetAddr(&f1Params.destIpNetAddr, &sctpCfg.duIpAddr); - RETVALUE(ROK); + return ROK; } @@ -136,7 +136,7 @@ S16 fillAddrLst(CmInetNetAddrLst *addrLstPtr, SctpIpAddr *ipAddr) addrLstPtr->addrs[(addrLstPtr->count - 1)].type = CM_INET_IPV4ADDR_TYPE; addrLstPtr->addrs[(addrLstPtr->count - 1)].u.ipv4NetAddr = CM_INET_NTOH_U32(ipAddr->ipV4Addr); - RETVALUE(ROK); + return ROK; } /****************************************************************************** @@ -161,7 +161,7 @@ S16 fillDestNetAddr(CmInetNetAddr *destAddrPtr, SctpIpAddr *dstIpPtr) /* Filling destination address */ destAddrPtr->type = CM_INET_IPV4ADDR_TYPE; destAddrPtr->u.ipv4NetAddr = CM_INET_NTOH_U32(dstIpPtr->ipV4Addr); - RETVALUE(ROK); + return ROK; } /****************************************************************************** @@ -203,7 +203,7 @@ S16 sctpStartReq() { DU_LOG("\nSCTP: Polling failed to start at CU"); } - RETVALUE(ret); + return (ret); } /******************************************************************* * @@ -240,7 +240,7 @@ S16 sctpSetSockOpts(CmInetFd *sock_Fd) ret = RFAILED; } - RETVALUE(ret); + return (ret); } /******************************************************************* @@ -269,7 +269,7 @@ S16 sctpAccept(CmInetFd *lstnSock_Fd, CmInetAddr *peerAddr, CmInetFd *sock_Fd) { DU_LOG("\nSCTP : Listening on socket failed"); cmInetClose(lstnSock_Fd); - RETVALUE(RFAILED); + return RFAILED; } DU_LOG("\nSCTP : Connecting"); @@ -284,7 +284,7 @@ S16 sctpAccept(CmInetFd *lstnSock_Fd, CmInetAddr *peerAddr, CmInetFd *sock_Fd) else if(ret != ROK) { DU_LOG("\nSCTP : Failed to accept connection"); - RETVALUE(RFAILED); + return RFAILED; } else { @@ -295,7 +295,7 @@ S16 sctpAccept(CmInetFd *lstnSock_Fd, CmInetAddr *peerAddr, CmInetFd *sock_Fd) } DU_LOG("\nSCTP : Connection established"); - RETVALUE(ROK); + return ROK; } /******************************************************************* @@ -375,7 +375,7 @@ S16 sctpNtfyHdlr(CmInetSctpNotification *ntfy) } sctpNtfyInd(ntfy); - RETVALUE(ROK); + return ROK; }/* End of sctpNtfyHdlr */ /******************************************************************* @@ -439,12 +439,12 @@ S16 sctpSockPoll() if(ret == ROK && egtpBuf != NULLP) { DU_LOG("\nEGTP : Received message \n"); - SPrntMsg(egtpBuf, 0 ,0); + ODU_PRINT_MSG(egtpBuf, 0 ,0); cuEgtpHdlRecvMsg(egtpBuf); } }; - RETVALUE(ret); + return (ret); }/* End of sctpSockPoll() */ /******************************************************************* @@ -496,15 +496,15 @@ S16 processPolling(sctpSockPollParams *pollParams, CmInetFd *sockFd, U32 *timeou else if(connUp & (pollParams->port == f1Params.destPort)) { F1APMsgHdlr(pollParams->mBuf); - SPutMsg(pollParams->mBuf); + ODU_PUT_MSG(pollParams->mBuf); } else { - SPutMsg(pollParams->mBuf); + ODU_PUT_MSG(pollParams->mBuf); } } } - RETVALUE(ROK); + return ROK; }/* End of sctpSockPoll() */ /******************************************************************* @@ -537,10 +537,10 @@ S16 sctpSend(Buffer *mBuf) if(ret != ROK && ret != RWOULDBLOCK) { DU_LOG("\nSCTP : Send message failed"); - RETVALUE(RFAILED); + return RFAILED; } - RETVALUE(ROK); + return ROK; } /* End of sctpSend */ /**********************************************************************