/* This file contains all SCTP related functionality */
#include "common_def.h"
-#include "odu_common_codec.h"
#include "ric_e2ap_msg_hdl.h"
#include "ric_stub_sctp.h"
#include "ric_stub.h"
{
addrLstPtr->count++;
addrLstPtr->addrs[(addrLstPtr->count - 1)].type = CM_INET_IPV4ADDR_TYPE;
- addrLstPtr->addrs[(addrLstPtr->count - 1)].u.ipv4NetAddr = CM_INET_NTOH_U32(ipAddr->ipV4Addr);
+ addrLstPtr->addrs[(addrLstPtr->count - 1)].u.ipv4NetAddr = CM_INET_NTOH_UINT32(ipAddr->ipV4Addr);
return ROK;
}
{
/* Filling destination address */
destAddrPtr->type = CM_INET_IPV4ADDR_TYPE;
- destAddrPtr->u.ipv4NetAddr = CM_INET_NTOH_U32(dstIpPtr->ipV4Addr);
+ destAddrPtr->u.ipv4NetAddr = CM_INET_NTOH_UINT32(dstIpPtr->ipV4Addr);
return ROK;
}
{
DU_LOG("\nSCTP: Polling failed to start at RIC");
}
- RETVALUE(ret);
+ return (ret);
}
/*******************************************************************
*
ret = RFAILED;
}
- RETVALUE(ret);
+ return (ret);
}
/*******************************************************************
* ****************************************************************/
S16 sctpAccept(CmInetFd *lstnSock_Fd, CmInetAddr *peerAddr, CmInetFd *sock_Fd)
{
- U8 ret;
+ uint8_t ret;
ret = cmInetListen(lstnSock_Fd, 1);
if (ret != ROK)
* ****************************************************************/
S16 sctpSockPoll()
{
- U16 ret = ROK;
- U32 timeout;
- U32 *timeoutPtr;
- CmInetMemInfo memInfo;
+ uint16_t ret = ROK;
+ uint32_t timeout;
+ uint32_t *timeoutPtr;
+ CmInetMemInfo memInfo;
sctpSockPollParams e2PollParams;
memset(&e2PollParams, 0, sizeof(sctpSockPollParams));
DU_LOG("\nSCTP : Failed to RecvMsg for E2 at RIC \n");
}
};
- RETVALUE(ret);
+ return (ret);
}/* End of sctpSockPoll() */
/*******************************************************************
* ****************************************************************/
-S16 processPolling(sctpSockPollParams *pollParams, CmInetFd *sockFd, U32 *timeoutPtr, CmInetMemInfo *memInfo)
+S16 processPolling(sctpSockPollParams *pollParams, CmInetFd *sockFd, uint32_t *timeoutPtr, CmInetMemInfo *memInfo)
{
- U16 ret = ROK;
+ uint16_t ret = ROK;
CM_INET_FD_SET(sockFd, &pollParams->readFd);
ret = cmInetSelect(&pollParams->readFd, NULLP, timeoutPtr, &pollParams->numFd);
if(CM_INET_FD_ISSET(sockFd, &pollParams->readFd))
else if(connUp & (pollParams->port == ricParams.destPort))
{
E2APMsgHdlr(pollParams->mBuf);
- SPutMsg(pollParams->mBuf);
+ ODU_PUT_MSG_BUF(pollParams->mBuf);
}
else
{
- SPutMsg(pollParams->mBuf);
+ ODU_PUT_MSG_BUF(pollParams->mBuf);
}
}
}
* ****************************************************************/
S16 sctpSend(Buffer *mBuf)
{
- U8 ret;
+ uint8_t ret;
MsgLen len; /* number of actually sent octets */
CmInetMemInfo memInfo;