Code Review
/
o-du
/
l2.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Replaced old SSI function with new macros jira id - ODUHIGH-212
[o-du/l2.git]
/
src
/
cu_stub
/
cu_stub_sctp.c
diff --git
a/src/cu_stub/cu_stub_sctp.c
b/src/cu_stub/cu_stub_sctp.c
index
627abdd
..
ab262d5
100644
(file)
--- 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);
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);
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);
/* 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");
}
{
DU_LOG("\nSCTP: Polling failed to start at CU");
}
-
RETVALUE
(ret);
+
return
(ret);
}
/*******************************************************************
*
}
/*******************************************************************
*
@@
-240,7
+240,7
@@
S16 sctpSetSockOpts(CmInetFd *sock_Fd)
ret = RFAILED;
}
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);
{
DU_LOG("\nSCTP : Listening on socket failed");
cmInetClose(lstnSock_Fd);
-
RETVALUE(RFAILED)
;
+
return RFAILED
;
}
DU_LOG("\nSCTP : Connecting");
}
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");
else if(ret != ROK)
{
DU_LOG("\nSCTP : Failed to accept connection");
-
RETVALUE(RFAILED)
;
+
return RFAILED
;
}
else
{
}
else
{
@@
-295,7
+295,7
@@
S16 sctpAccept(CmInetFd *lstnSock_Fd, CmInetAddr *peerAddr, CmInetFd *sock_Fd)
}
DU_LOG("\nSCTP : Connection established");
}
DU_LOG("\nSCTP : Connection established");
-
RETVALUE(ROK)
;
+
return ROK
;
}
/*******************************************************************
}
/*******************************************************************
@@
-375,7
+375,7
@@
S16 sctpNtfyHdlr(CmInetSctpNotification *ntfy)
}
sctpNtfyInd(ntfy);
}
sctpNtfyInd(ntfy);
-
RETVALUE(ROK)
;
+
return ROK
;
}/* End of sctpNtfyHdlr */
/*******************************************************************
}/* End of sctpNtfyHdlr */
/*******************************************************************
@@
-439,12
+439,12
@@
S16 sctpSockPoll()
if(ret == ROK && egtpBuf != NULLP)
{
DU_LOG("\nEGTP : Received message \n");
if(ret == ROK && egtpBuf != NULLP)
{
DU_LOG("\nEGTP : Received message \n");
-
SPrntMsg
(egtpBuf, 0 ,0);
+
ODU_PRINT_MSG
(egtpBuf, 0 ,0);
cuEgtpHdlRecvMsg(egtpBuf);
}
};
cuEgtpHdlRecvMsg(egtpBuf);
}
};
-
RETVALUE
(ret);
+
return
(ret);
}/* End of sctpSockPoll() */
/*******************************************************************
}/* 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);
else if(connUp & (pollParams->port == f1Params.destPort))
{
F1APMsgHdlr(pollParams->mBuf);
-
SPutMsg
(pollParams->mBuf);
+
ODU_PUT_MSG
(pollParams->mBuf);
}
else
{
}
else
{
-
SPutMsg
(pollParams->mBuf);
+
ODU_PUT_MSG
(pollParams->mBuf);
}
}
}
}
}
}
-
RETVALUE(ROK)
;
+
return ROK
;
}/* End of sctpSockPoll() */
/*******************************************************************
}/* End of sctpSockPoll() */
/*******************************************************************
@@
-537,10
+537,10
@@
S16 sctpSend(Buffer *mBuf)
if(ret != ROK && ret != RWOULDBLOCK)
{
DU_LOG("\nSCTP : Send message failed");
if(ret != ROK && ret != RWOULDBLOCK)
{
DU_LOG("\nSCTP : Send message failed");
-
RETVALUE(RFAILED)
;
+
return RFAILED
;
}
}
-
RETVALUE(ROK)
;
+
return ROK
;
} /* End of sctpSend */
/**********************************************************************
} /* End of sctpSend */
/**********************************************************************