#ifdef NTL_LIB
#include "ntl_lib.h"
#endif
+#include "du_log.h"
\f
/* local defines */
#endif
CMINETLOGERROR(ERRCLS_DEBUG, ECMINETXXX, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#if (ERRCLASS & ERRCLS_INT_PAR)
snprintf(prntBuf, CMINET_PRNT_BUF_SIZE, "cmInetPoll() : Invalid Parameter (pollFdArr is NULL)");
CMINETLOGERROR(ERRCLS_DEBUG, ECMINETXXX, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
ret = poll(pollFdArr,numFds,timeout);
if (ret == 0)
{
- RETVALUE(RTIMEOUT);
+ return (RTIMEOUT);
}
if (ret == INET_ERR)
{
switch(INET_ERR_CODE)
{
case ERR_EINTR:
- RETVALUE(ROKDNA);
+ return (ROKDNA);
default:
#ifdef CMINETDBG
error(%d)\n", __FILE__, __LINE__, INET_ERR_CODE);
SPrint(prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
} /* end of switch */
}
*numRdyFds = (S16)ret;
- RETVALUE(ROK);
+ return ROK;
}
CMINETLOGERROR(ERRCLS_DEBUG, ECMINETXXX, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#if (ERRCLASS & ERRCLS_INT_PAR)
snprintf(prntBuf, CMINET_PRNT_BUF_SIZE, "cmInetPollSetFd() : Invalid Parameter (pollFdArr is NULL)");
CMINETLOGERROR(ERRCLS_DEBUG, ECMINETXXX, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
#endif /*ALIGN_64BIT */
#endif /* CMINETDBG */
- RETVALUE(ROK);
+ return ROK;
}
snprintf(prntBuf, CMINET_PRNT_BUF_SIZE, "cmInetPollFdIsSet() : Invalid Index (%d) \n",idx);
CMINETLOGERROR(ERRCLS_DEBUG, ECMINETXXX, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#if (ERRCLASS & ERRCLS_INT_PAR)
snprintf(prntBuf, CMINET_PRNT_BUF_SIZE, "cmInetPollFdIsSet() : Invalid Parameter (pollFdArr is NULL)");
CMINETLOGERROR(ERRCLS_DEBUG, ECMINETXXX, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
ret = (pollFdArr[idx].revents & eventMask);
- RETVALUE(ret);
+ return (ret);
}
/*
snprintf(prntBuf, CMINET_PRNT_BUF_SIZE, "cmInetPollClearFdREvent() : Invalid Index (%d) \n",idx);
CMINETLOGERROR(ERRCLS_DEBUG, ECMINETXXX, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#if (ERRCLASS & ERRCLS_INT_PAR)
snprintf(prntBuf, CMINET_PRNT_BUF_SIZE, "cmInetPollClearFdREvent() : Invalid Parameter (pollFdArr is NULL)");
CMINETLOGERROR(ERRCLS_DEBUG, ECMINETXXX, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
#endif /*ALIGN_64BIT */
#endif /* CMINETDBG */
- RETVALUE(ROK);
+ return ROK;
}
snprintf(prntBuf, CMINET_PRNT_BUF_SIZE, "cmInetPollClearFdEvent() : Invalid Index (%d) \n",idx);
CMINETLOGERROR(ERRCLS_DEBUG, ECMINETXXX, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#if (ERRCLASS & ERRCLS_INT_PAR)
snprintf(prntBuf, CMINET_PRNT_BUF_SIZE, "cmInetPollClearFdEvent() : Invalid Parameter (pollFdArr is NULL)");
CMINETLOGERROR(ERRCLS_DEBUG, ECMINETXXX, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
#endif /*ALIGN_64BIT */
#endif /* CMINETDBG */
- RETVALUE(ROK);
+ return ROK;
}
snprintf(prntBuf, CMINET_PRNT_BUF_SIZE, "cmInetPollDelFd() : Invalid Index \n Current Index (%d) Delete Index (%d) \n",lastIdx,delIdx);
CMINETLOGERROR(ERRCLS_DEBUG, ECMINETXXX, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
snprintf(prntBuf, CMINET_PRNT_BUF_SIZE, "cmInetPollDelFd() : Invalid Parameter (pollFdArr is NULL)");
CMINETLOGERROR(ERRCLS_DEBUG, ECMINETXXX, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
pollFdArr[lastIdx].events = 0;
pollFdArr[lastIdx].revents = 0;
- RETVALUE(ROK);
+ return ROK;
}
snprintf(prntBuf, CMINET_PRNT_BUF_SIZE, "cmInetPollInitFdArr() : Invalid Parameter (pollFdArr is NULL)");
CMINETLOGERROR(ERRCLS_DEBUG, ECMINETXXX, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
pollFdArr[idx].events = 0;
pollFdArr[idx].revents = 0;
}
- RETVALUE(ROK);
+ return ROK;
}
#if (!(defined(WIN32)) && !(defined(CMINETFLATBUF)))
ret = SGetDBuf(info->region, info->pool, &dBuf[numBuf]);
#endif
if (ret != ROK)
- RETVALUE(ret);
+ return (ret);
/* Get the data part */
ret = SGetDataRx(dBuf[numBuf], 0, &dPtr, &dLen);
msg->msg_iov = rxArr;
msg->msg_iovlen = numBuf;
- RETVALUE(ret);
+ return (ret);
cleanup:
/* cleanup */
msg->msg_iovlen = 0;
- RETVALUE(ret);
+ return (ret);
} /* end of buildRecvBuf */
/*
i++;
}
- RETVALUE(ret);
+ return (ret);
} /* end of buildRecvMsg */
\f
ret = SInitNxtDBuf(mBuf);
if (ret != ROK)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
iovIdx = 0;
{
ret = SGetNxtDBuf(mBuf, &dBuf);
if (ret != ROK)
- RETVALUE(RFAILED);
+ return RFAILED;
dBufsToSkip --;
}
}
/* cm_inet_c_001.main_50 - Assign the value of dbufs packed in IO-vector */
*ioLen = allocLen;
- RETVALUE(ret);
+ return (ret);
} /* end of buildSendIovec */
#endif /* (defined(WIN32)) && !(defined(CMINETFLATBUF)) */
#endif /* CMINETDBG */
/* Set sockFd->fd to invalid socket */
sockFd->fd = CM_INET_INV_SOCKFD;
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* set socket type */
if (ret != ROK)
{
ret = cmInetClose(sockFd);
- RETVALUE(RFAILED);
+ return RFAILED;
}
#ifdef SS_LINUX
if (ret != ROK)
{
ret = cmInetClose(sockFd);
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* CMINET_BSDCOMPAT */
#endif /* SS_LINUX */
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
ret = cmInetClose(sockFd);
- RETVALUE(RFAILED);
+ return RFAILED;
}
}
#endif /* WIN2K && WIN32 */
if (ret != ROK)
{
ret = cmInetClose(sockFd);
- RETVALUE(RFAILED);
+ return RFAILED;
}
}
#endif /* CM_LKSCTP_NONBLOCK ends */
#endif
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetSocket */
\f
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd) ||
(myAddr == NULLP))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
#endif /*ALIGN_64BIT*/
#endif /* IPV6_SUPPORTED */
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetBind */
/*cm_inet_c_001.main_38 Updated for TUCL 2.1 Release (Kernel SCTP Support) */
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd) ||
(addrLst == NULLP))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
if(addrLst->count > CM_INET_NUM_NET_ADDR)
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET005, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET057, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
addrs6[idx6].sin6_family = AF_INET6;
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET058, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
addrs6[idx6].sin6_family = AF_INET6;
CMINETLOGERROR(ERRCLS_DEBUG, ECMINET006, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
if (addrLst->count > 1)
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET059, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
ret = sctp_bindx(sockFd->fd, (Void*)tempAddrPtr, addrLst->count - 1, SCTP_BINDX_ADD_ADDR);
#else
/* linux */
ret = sctp_bindx(sockFd->fd, (struct sockaddr*)address_array, addrLst->count, SCTP_BINDX_ADD_ADDR);
+ UNUSED(sockAddrPtr);
+ UNUSED(sockAddrLen);
#endif
if (ret == INET_ERR)
{
CMINETLOGERROR(ERRCLS_DEBUG, ECMINET007, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
- RETVALUE(ROK);
+ return ROK;
}
/*
/* cm_inet_c_001.main_64: New variable used as an argument for sctp_connectx */
#ifdef SCTP_CONNECTX_NEW
- U32 assocId = 0;
+ U32 assocId = 0;
#endif
U32 addresses_array_size = 0;
U32 idx4 = 0;
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd) ||
(primAddr == NULLP))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* cm_inet_c_001.main_58 : Added check for addrLst to fix klockwork issue */
if (addrLst == NULLP)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* cm_inet_c_001.main_46: Included check for no of address aginst max */
if( addrLst->count > CM_INET_NUM_NET_ADDR )
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET060, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET008, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
addrs6[idx6].sin6_family = AF_INET6;
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET061, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
addrs6[idx6].sin6_family = AF_INET6;
addrs6[idx6].sin6_port = CM_INET_HTON_U16(port);
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET009, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
addrs6[idx6].sin6_family = AF_INET6;
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET062, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
addrs6[idx6].sin6_family = AF_INET6;
addrs6[idx6].sin6_port = CM_INET_HTON_U16(port);
}
else
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
-/* HLAL */
-#if 0
+
#ifdef IPV6_SUPPORTED
if((ipv6_array_size > 0) && (ipv6_array_size <= (CM_INET_NUM_NET_ADDR * \
sizeof(struct sockaddr_in))))
}
else
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* IPV6_SUPPORTED */
-#endif
+
/* cm_inet_c_001.main_64: Support for new definition of sctp_connectx */
#ifndef SCTP_CONNECTX_NEW
ret = sctp_connectx(sockFd->fd, (struct sockaddr*)address_array, cnt);
" sockFd->fd(%ld)\n", INET_ERR_CODE, port, sockFd->fd);
CMINETLOGERROR(ERRCLS_DEBUG, ECMINET010, 0, prntBuf);
#else
- /* cm_inet_c_001.main_62:Warning fix */
- snprintf(prntBuf, CMINET_PRNT_BUF_SIZE, "CmInetSctpConnectx() Failed : error(%d), port(0x%1x),"
- " sockFd->fd(%d)\n", INET_ERR_CODE, port, sockFd->fd);
- CMINETLOGERROR(ERRCLS_DEBUG, ECMINET010, 0, prntBuf);
+ DU_LOG("\nCmInetSctpConnectx() Failed : error(%d), port(0x%1x),\
+ sockFd->fd(%d)\n", INET_ERR_CODE, port, sockFd->fd);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
{
/* non-blocking: connection is in progress */
case ERR_INPROGRESS:
- RETVALUE(RINPROGRESS);
+ return (RINPROGRESS);
break;
/*
* blocking : connection is already established
*/
case ERR_ISCONN:
- RETVALUE(RISCONN);
+ return (RISCONN);
break;
/* resource temporarily unavailable */
case ERR_WOULDBLOCK:
- RETVALUE(ROKDNA);
+ return (ROKDNA);
break;
/* non-blocking: connection is in progress */
case ERR_ALREADY:
- RETVALUE(RINPROGRESS);
+ return (RINPROGRESS);
break;
case ERR_INVAL:
- RETVALUE(RINPROGRESS);
+ return (RINPROGRESS);
break;
/* Check for connection refused and timeout errors */
case ERR_CONNREFUSED:
case ERR_TIMEDOUT:
- RETVALUE(RCLOSED);
+ return (RCLOSED);
break;
/* it is a real error */
default:
- RETVALUE(RFAILED);
+ return RFAILED;
break;
}
}
- RETVALUE(ROK);
+ return ROK;
}
/*
/* error check on parameters */
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd) || (assocFd == NULLP))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
*assocFd = ret;
- RETVALUE(ROK);
+ return ROK;
}
/*
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd)
|| (info == NULLP) || (mBuf == NULLP) || (len == NULLP))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
ret = SFndLenMsg(mBuf, &bufLen);
if (ret != ROK)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* max message length is limited to control the memory usage */
/* casting bufLen to avoid warnings */
if ((bufLen > 0) && ((U32)bufLen > CM_INET_MAX_MSG_LEN))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
ret = SGetSBuf(info->region, info->pool, &sendBuf, bufLen);
if (ret != ROK)
{
- RETVALUE(ROUTRES);
+ return (ROUTRES);
}
ret = SCpyMsgFix(mBuf, 0, bufLen, sendBuf, &msgLen);
if ((ret != ROK) || (msgLen != bufLen))
{
SPutSBuf(info->region, info->pool, sendBuf, bufLen);
- RETVALUE(RFAILED);
+ return RFAILED;
}
if ( dstAddr != NULLP)
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET012, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
addr6.sin6_family = AF_INET6;
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET064, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
addr6.sin6_family = AF_INET6;
addr6.sin6_port = CM_INET_HTON_U16(port);
#endif /* CMINETDBG */
if ((INET_ERR_CODE == ERR_AGAIN) || (INET_ERR_CODE == ERR_WOULDBLOCK))
- RETVALUE(RWOULDBLOCK);
+ return (RWOULDBLOCK);
else if (INET_ERR_CODE == ERR_PIPE)
- RETVALUE(RCLOSED);
+ return (RCLOSED);
else
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* cm_inet_c_001.main_58 : Fix for klockwork issue */
/* cleanup */
SPutSBuf(info->region, info->pool, sendBuf, bufLen);
- RETVALUE(ROK);
+ return ROK;
}
/*
(srcAddr == NULLP) || (port == NULLP) || (meminfo == NULLP) ||
(mBuf == NULLP) || (len == NULLP) || (sinfo == NULLP) || (flag == NULLP))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
snprintf(prntBuf, CMINET_PRNT_BUF_SIZE, "SGetSBuf failed to allocate memory\n");
CMINETLOGERROR(ERRCLS_ADD_RES, ECMINET065, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
addrlen = sizeof(struct sockaddr_storage);
" sockFd->fd(%ld)\n", INET_ERR_CODE, sockFd->fd);
CMINETLOGERROR(ERRCLS_DEBUG, ECMINET014, 0, prntBuf);
#else
- /* cm_inet_c_001.main_62:Warning fix */
- snprintf(prntBuf, CMINET_PRNT_BUF_SIZE, "cmInetSctpRecvMsg() Failed : error(%d),"
- " sockFd->fd(%d)\n", INET_ERR_CODE, sockFd->fd);
- CMINETLOGERROR(ERRCLS_DEBUG, ECMINET014, 0, prntBuf);
+ DU_LOG("\ncmInetSctpRecvMsg() Failed : error(%d), sockFd->fd(%d)", \
+ INET_ERR_CODE, sockFd->fd);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* save the length of the received message */
if (ret != ROK)
{
SPutSBuf(meminfo->region, meminfo->pool, recvbuf, buflen);
- RETVALUE(RFAILED);
+ return RFAILED;
}
ret = SAddPstMsgMult(recvbuf, *len, *mBuf);
{
SPutMsg(*mBuf);
SPutSBuf(meminfo->region, meminfo->pool, recvbuf, buflen);
- RETVALUE(RFAILED);
+ return RFAILED;
}
}
/* cleanup */
SPutSBuf(meminfo->region, meminfo->pool, recvbuf, buflen);
- RETVALUE(ROK);
+ return ROK;
}
/*
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
byteAddress = (U8*)peerAddrList;
#endif /* CMINETDBG */
sctp_freepaddrs(peerAddrList);
- RETVALUE(RFAILED);
+ return RFAILED;
}
pAddr6 = (struct sockaddr_in6*)byteAddress;
sctp_freepaddrs(peerAddrList);
- RETVALUE(ROK);
+ return ROK;
}
/*
/* error check on parameters */
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
default:
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
break;
}
if (status.sstat_primary.spinfo_state == SCTP_ACTIVE)
pSctpStatus->primary.isActive = TRUE;
else
+ {
pSctpStatus->primary.isActive = FALSE;
pSctpStatus->primary.cwnd = status.sstat_primary.spinfo_cwnd;
pSctpStatus->primary.srtt = status.sstat_primary.spinfo_srtt;
pSctpStatus->primary.rto = status.sstat_primary.spinfo_rto;
pSctpStatus->primary.mtu = status.sstat_primary.spinfo_mtu;
- break;
+ }
+ break;
case CM_INET_OPT_SCTP_GET_PADDR_INFO:
pPeerAddrInfo = (CmInetSctpPeerAddrInfo*)value;
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET017, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
pAddr6 = (struct sockaddr_in6*)&(addrInfo.spinfo_address);
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET066, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
pAddr6 = (struct sockaddr_in6*)&(addrParams.spp_address);
break;
default:
- RETVALUE(RFAILED);
+ return RFAILED;
}
if (ret == INET_ERR)
CMINETLOGERROR(ERRCLS_DEBUG, ECMINET067, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
- RETVALUE(ROK);
+ return ROK;
}
/* cm_inet_c_001.main_54: Added new function cmInetShutDownSctp()*/
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
- RETVALUE(ROK);
+ return ROK;
}
/* cm_inet_c_001.main_61: Added new function cmInetAbortSctpAssoc()*/
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
- RETVALUE(ROK);
+ return ROK;
}
#endif
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd) ||
(servAddr == NULLP))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
{
/* non-blocking: connection is in progress */
case ERR_INPROGRESS:
- RETVALUE(RINPROGRESS);
+ return (RINPROGRESS);
break;
/*
* blocking : connection is already established
*/
case ERR_ISCONN:
- RETVALUE(RISCONN);
+ return (RISCONN);
break;
/* resource temporarily unavailable */
case ERR_WOULDBLOCK:
- RETVALUE(ROKDNA);
+ return (ROKDNA);
break;
/* non-blocking: connection is in progress */
case ERR_ALREADY:
- RETVALUE(RINPROGRESS);
+ return (RINPROGRESS);
break;
case ERR_INVAL:
- RETVALUE(RINPROGRESS);
+ return (RINPROGRESS);
break;
/* Check for connection refused and timeout errors */
case ERR_CONNREFUSED:
case ERR_TIMEDOUT:
- RETVALUE(RCLOSED);
+ return (RCLOSED);
break;
/* it is a real error */
#endif /*ALIGN_64BIT*/
#endif /* IPV6_SUPPORTED */
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
break;
}
}
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetConnect */
\f
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd) ||
(backLog < MIN_BACK_LOG) || (backLog > MAX_BACK_LOG))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
CMINETLOGERROR(ERRCLS_DEBUG, ECMINET021, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetListen */
\f
/* error check on parameters */
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
if (INET_ERR_CODE == ERR_WOULDBLOCK)
{
/* no connection present to accept */
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
else
{
CMINETLOGERROR(ERRCLS_DEBUG, ECMINET022, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
}
CMINETLOGERROR(ERRCLS_DEBUG, ECMINET071, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* IPV6_SUPPORTED */
if ( ret != ROK)
{
ret = cmInetClose(newSockFd);
- RETVALUE(RFAILED);
+ return RFAILED;
}
#ifdef IPV6_SUPPORTED
fromAddr->port = CM_INET_NTOH_U16(peerAddr->sin_port);
fromAddr->address = CM_INET_NTOH_U32(peerAddr->sin_addr.s_addr);
#endif /* IPV6_SUPPORTED */
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetAccept */
\f
tempHdr->cmsg_len = len;
*curMsgIdx += len;
- RETVALUE(ROK);
+ return ROK;
}/* end of cmInet4FillTos */
/*
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd) ||
(info == NULLP) || (len == NULLP))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
ret = SFndLenMsg(mBuf, &bufLen);
if (ret != ROK)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* max message length is limited to control the memory usage */
/* casting bufLen to avoid warnings */
if ((bufLen > 0) && ((U32)bufLen > CM_INET_MAX_MSG_LEN))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
ret = SGetSBuf(info->region, info->pool, &sendBuf, bufLen);
if (ret != ROK)
{
- RETVALUE(ROUTRES);
+ return (ROUTRES);
}
ret = SCpyMsgFix(mBuf, 0, bufLen, sendBuf, &msgLen);
if ((ret != ROK) || (msgLen != bufLen))
{
/* cleanup */
SPutSBuf(info->region, info->pool, sendBuf, bufLen);
- RETVALUE(RFAILED);
+ return RFAILED;
}
if (dstAddr == NULLP)
if(INET_ERR_CODE == ERR_AGAIN)
{
*len = 0;
- RETVALUE(RWOULDBLOCK);
+ return (RWOULDBLOCK);
}
/* Check for ERR_WOULDBLOCK */
if(INET_ERR_CODE == ERR_WOULDBLOCK)
{
*len = 0;
- RETVALUE(RWOULDBLOCK);
+ return (RWOULDBLOCK);
}
#ifdef CMINETDBG
/* check if network is reacheble*/
if ((INET_ERR_CODE == ERR_NETUNREACH))
{
- RETVALUE(RNETFAILED);
+ return (RNETFAILED);
}
(INET_ERR_CODE == ERR_CONNRESET))
{
*len = 0;
- RETVALUE(RCLOSED);
+ return (RCLOSED);
}
- RETVALUE(RFAILED);
+ return RFAILED;
}
*len = ret;
{
/* cleanup */
SPutSBuf(info->region, info->pool, sendBuf, bufLen);
- RETVALUE(RWOULDBLOCK);
+ return (RWOULDBLOCK);
}
/* cleanup */
ret = SFndLenMsg(mBuf, &msgLen);
if (ret != ROK)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* added */
/* Compress the message into a single dBuf */
ret = SCompressMsg(mBuf);
if (ret != ROK)
- RETVALUE(RFAILED);
+ return RFAILED;
strtEndDBufNum = 0;
/* Rebuild the send vector */
ret = buildSendIovec(mBuf, unSentLen, txArr, numDBufs, &i,
&strtEndDBufNum, &ioLen);
if (ret != ROK)
- RETVALUE(RFAILED);
+ return RFAILED;
retVal = ROK;
}
}
else
- RETVALUE(RFAILED);
+ return RFAILED;
}
msg.msg_iov = txArr;
msg.msg_iovlen = i;
{
/* cm_inet_c_001.main_50 - Return without making length 0, if in case the partial
message was sent earlier */
- RETVALUE(RWOULDBLOCK);
+ return (RWOULDBLOCK);
}
#ifdef CMINETDBG
#ifndef ALIGN_64BIT
/* check if network is reacheble or not */
if ((INET_ERR_CODE == ERR_NETUNREACH))
{
- RETVALUE(RNETFAILED);
+ return (RNETFAILED);
}
/* Check if connection was closed by the peer */
(INET_ERR_CODE == ERR_CONNABORTED))
{
*len = 0;
- RETVALUE(RCLOSED);
+ return (RCLOSED);
}
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* cm_inet_c_001.main_50 - Update the length only in successful cases */
* to be sent, then return WOULDBLOCK
*/
if (ret < ioLen)
- RETVALUE(RWOULDBLOCK);
+ return (RWOULDBLOCK);
unSentLen -= ret;
} while (*len < msgLen);
#endif /* WIN32 | CMINETFLATBUF */
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetSendDscpMsg */
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd) ||
(info == NULLP) || (len == NULLP))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
ret = SFndLenMsg(mBuf, &bufLen);
if (ret != ROK)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* max message length is limited to control the memory usage */
/* casting bufLen to avoid warnings */
if ((bufLen > 0) && ((U32)bufLen > CM_INET_MAX_MSG_LEN))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
ret = SGetSBuf(info->region, info->pool, &sendBuf, bufLen);
if (ret != ROK)
{
- RETVALUE(ROUTRES);
+ return (ROUTRES);
}
ret = SCpyMsgFix(mBuf, 0, bufLen, sendBuf, &msgLen);
if ((ret != ROK) || (msgLen != bufLen))
{
/* cleanup */
SPutSBuf(info->region, info->pool, sendBuf, bufLen);
- RETVALUE(RFAILED);
+ return RFAILED;
}
if (dstAddr == NULLP)
if(INET_ERR_CODE == ERR_AGAIN)
{
*len = 0;
- RETVALUE(RWOULDBLOCK);
+ return (RWOULDBLOCK);
}
/* Check for ERR_WOULDBLOCK */
if(INET_ERR_CODE == ERR_WOULDBLOCK)
{
*len = 0;
- RETVALUE(RWOULDBLOCK);
+ return (RWOULDBLOCK);
}
#ifdef CMINETDBG
/* check if network is reacheble*/
if ((INET_ERR_CODE == ERR_NETUNREACH))
{
- RETVALUE(RNETFAILED);
+ return (RNETFAILED);
}
(INET_ERR_CODE == ERR_CONNRESET))
{
*len = 0;
- RETVALUE(RCLOSED);
+ return (RCLOSED);
}
- RETVALUE(RFAILED);
+ return RFAILED;
}
*len = ret;
{
/* cleanup */
SPutSBuf(info->region, info->pool, sendBuf, bufLen);
- RETVALUE(RWOULDBLOCK);
+ return (RWOULDBLOCK);
}
/* cleanup */
ret = SFndLenMsg(mBuf, &msgLen);
if (ret != ROK)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* added */
/* Compress the message into a single dBuf */
ret = SCompressMsg(mBuf);
if (ret != ROK)
- RETVALUE(RFAILED);
+ return RFAILED;
strtEndDBufNum = 0;
/* Rebuild the send vector */
ret = buildSendIovec(mBuf, unSentLen, txArr, numDBufs, &i,
&strtEndDBufNum, &ioLen);
if (ret != ROK)
- RETVALUE(RFAILED);
+ return RFAILED;
retVal = ROK;
}
}
else
- RETVALUE(RFAILED);
+ return RFAILED;
}
msg.msg_iov = txArr;
msg.msg_iovlen = i;
{
/* cm_inet_c_001.main_50 - Return without making length 0, if in case the partial
message was sent earlier */
- RETVALUE(RWOULDBLOCK);
+ return (RWOULDBLOCK);
}
#ifdef CMINETDBG
#ifndef ALIGN_64BIT
/* check if network is reacheble or not */
if ((INET_ERR_CODE == ERR_NETUNREACH))
{
- RETVALUE(RNETFAILED);
+ return (RNETFAILED);
}
/* Check if connection was closed by the peer */
(INET_ERR_CODE == ERR_CONNABORTED))
{
*len = 0;
- RETVALUE(RCLOSED);
+ return (RCLOSED);
}
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* cm_inet_c_001.main_50 - Update the length only in successful cases */
* to be sent, then return WOULDBLOCK
*/
if (ret < ioLen)
- RETVALUE(RWOULDBLOCK);
+ return (RWOULDBLOCK);
unSentLen -= ret;
} while (*len < msgLen);
#endif /* WIN32 | CMINETFLATBUF */
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetSendMsg */
tempHdr->cmsg_len = len;
*curMsgIdx += len;
- RETVALUE(ROK);
+ return ROK;
}/* end of cmInet6BuildSendPktinfo */
#endif /* LOCAL_INTF */
tempHdr->cmsg_len = len;
*curMsgIdx += len;
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetBuildSendHoplimit */
#endif /* SS_LINUX */
tempHdr->cmsg_len = len;
*curMsgIdx += len;
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInet6BuildSendHBHOpts */
\f
}
*curMsgIdx += len;
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInet6BuildSendRouteOpts */
\f
snprintf(prntBuf, CMINET_PRNT_BUF_SIZE, "SGetSBuf failure 1 in cmInet6BuildRecvHopOptsArr\n");
CMINETLOGERROR(ERRCLS_ADD_RES, ECMINET028, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(ROUTRES);
+ return (ROUTRES);
}
curDataIdx = 0;
(Data *)hbhOptsArr->hbhOpts, numOpts * sizeof(CmInetIpv6HBHHdr));
hbhOptsArr->numHBHOpts = 0;
hbhOptsArr->hbhOpts = NULLP;
- RETVALUE(ROUTRES);
+ return (ROUTRES);
}
/* copy the value bytes */
cmMemcpy((U8 *)hbhOptsArr->hbhOpts[optsIdx].value,
/* get next option */
optsIdx++;
}
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInet6BuildRecvHopOptsArr() */
\f
snprintf(prntBuf, CMINET_PRNT_BUF_SIZE, "SGetSBuf failure 1 in cmInet6BuildRecvRtHdr\n");
CMINETLOGERROR(ERRCLS_ADD_RES, ECMINET032, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(ROUTRES);
+ return (ROUTRES);
}
/* copy all the ipv6 addresses */
curDataIdx += 16;
}
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInet6BuildRecvRtHdr() */
\f
hopLimitValue = (U32 *)(cmsgData);
ipv6HdrParam->ttl.val = (U8)(*hopLimitValue);
- RETVALUE(ROK);
+ return ROK;
}
#endif /* IPV6_OPTS_SUPPORTED */
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd) ||
(info == NULLP) || (mPtr == NULLP) || (len == NULLP))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
if (ret != ROK)
{
/* ret may be RFAILED or ROUTRES */
- RETVALUE(ret);
+ return (ret);
}
}
else
ret = cmInetPeekNew(sockFd, NULLP, info, 0, 1, readBuf);
if (ret == RCLOSED)
{
- RETVALUE(ret);
+ return (ret);
}
/* cm_inet_c_001.main_56:
* Returning ROKDNA even cmInetPeekNew returns ROK. Because currently
* cmInetGetNumRead at this point because of latency between the ioctl
* call and recvfrom call issues on some machines ioctl call may
* return ZERO even their a data to read. */
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
}
/* cm_inet_c_001.main_52: Support for partial reception */
ret = SGetSBuf(info->region, info->pool, &recvBuf, bufLen);
if (ret != ROK)
{
- RETVALUE(ROUTRES);
+ return (ROUTRES);
}
curLen = bufLen;
bufPtr = recvBuf;
(INET_ERR_CODE == ERR_WOULDBLOCK))
{
*len = 0;
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
(INET_ERR_CODE == ERR_CONNRESET))
{
*len = 0;
- RETVALUE(RCLOSED);
+ return (RCLOSED);
}
#ifdef CMINETDBG
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
curLen -= recvLen;
bufPtr += recvLen;
#endif
{
SPutSBuf(info->region, info->pool, recvBuf, bufLen);
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
/* cm_inet_c_001.main_48 : If Received
#endif /*ALIGN_64BIT*/
#endif
SPutSBuf(info->region, info->pool, recvBuf, bufLen);
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
/* cm_inet_c_001.main_48 : copy data to a message structure */
{
/* cleanup */
SPutSBuf(info->region, info->pool, recvBuf, bufLen);
- RETVALUE(ret);
+ return (ret);
}
#ifdef CM_INET2
{
SPutSBuf(info->region, info->pool, recvBuf, bufLen);
SPutMsg(mBuf);
- RETVALUE(ret);
+ return (ret);
}
*mPtr = mBuf;
numDBufs*sizeof(Buffer*));
if (ret != ROK)
{
- RETVALUE(ROUTRES);
+ return (ROUTRES);
}
/* Allocate dBufs for gather read */
/* allocate flat receive buffer */
ret = SGetSBuf(info->region, info->pool, &recvBuf, bufLen);
if (ret != ROK)
- RETVALUE(ROUTRES);
+ return (ROUTRES);
allocFlatBuf = TRUE;
{
SPutSBuf(info->region, info->pool, (Data*)dBufs,
numDBufs*sizeof(Buffer*));
- RETVALUE(ret);
+ return (ret);
}
}
* against unexpected WOULDBLOCKS observed in solaris
*/
if (*mPtr != NULLP)
- RETVALUE(ROK);
+ return ROK;
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
/* cm_inet_c_001.main_50 - Free the buffer only when valid, it might be that
if (INET_ERR_CODE == ERR_CONNABORTED)
{
*len = 0;
- RETVALUE(RCLOSED);
+ return (RCLOSED);
}
- RETVALUE(RFAILED);
+ return RFAILED;
}
bufLen -= recvLen;
&ipHdrParams->u.ipv6HdrParm.ipv6ExtHdr.hbhOptsArr,
0, info);
if (ret != ROK)
- RETVALUE(ret);
+ return (ret);
ipHdrParams->u.ipv6HdrParm.ipv6ExtHdr.hbhHdrPrsnt =
TRUE;
}
&ipHdrParams->u.ipv6HdrParm.ipv6ExtHdr.destOptsArr,
1, info);
if (ret != ROK)
- RETVALUE(ret);
+ return (ret);
ipHdrParams->u.ipv6HdrParm.ipv6ExtHdr.destOptsPrsnt =
TRUE;
}
&ipHdrParams->u.ipv6HdrParm.ipv6ExtHdr.rtOptsArr,
info);
if (ret != ROK)
- RETVALUE(ret);
+ return (ret);
ipHdrParams->u.ipv6HdrParm.ipv6ExtHdr.rtOptsPrsnt =
TRUE;
}
ret = cmInet6GetHopLimitValue((U8 *)CMSG_DATA(cmsgptr),
cmsgptr->cmsg_len, &ipHdrParams->u.ipv6HdrParm);
if (ret != ROK)
- RETVALUE(ret);
+ return (ret);
}
}
} /* for */
{
/* cleanup */
SPutSBuf(info->region, info->pool, recvBuf, bufLen);
- RETVALUE(ret);
+ return (ret);
}
/* cm_inet_c_001.main_48 : A 0 len UDP packet could be received */
{
SPutSBuf(info->region, info->pool, recvBuf, bufLen);
SPutMsg(tempMsg);
- RETVALUE(ret);
+ return (ret);
}
}
SPutMsg(*mPtr);
SPutSBuf(info->region, info->pool, (Data*)dBufs,
numDBufs*sizeof(Buffer*));
- RETVALUE(ret);
+ return (ret);
}
}
SPutMsg(tempMsg);
SPutSBuf(info->region, info->pool, (Data*)dBufs,
numDBufs*sizeof(Buffer*));
- RETVALUE(RFAILED);
+ return RFAILED;
}
SPutMsg(tempMsg);
}
{
SPutMsg(*mPtr);
}
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET069, 0, prntBuf);
#endif
#endif
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
else
{
/* not enough data pending yet */
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetRecvMsg */
(info == NULLP) || (data == NULLP) ||
(dataPos < 0) || (dataLen < 0))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
(INET_ERR_CODE == ERR_WOULDBLOCK))
{
recvLen = 0;
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
/* cm_inet_c_001.main_61: added host unreachable check */
if ((INET_ERR_CODE == ERR_CONNABORTED) ||
(INET_ERR_CODE == ERR_CONNREFUSED))
{
recvLen = 0;
- RETVALUE(RCLOSED);
+ return (RCLOSED);
}
#ifdef CMINETDBG
#ifndef ALIGN_64BIT
#endif
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
else if (recvLen == 0)
{
- RETVALUE(RCLOSED);
+ return (RCLOSED);
}
/* cm_inet_c_001.main_57 - Fix for validation */
if (recvLen < (S32)dataLen) /* maybe happen */
{
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
/* setup return destination Internet address */
#endif /* IPV6_SUPPORTED */
}
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetPeeknew */
\f
(info == NULLP) || (data == NULLP) ||
(dataPos < 0) || (dataLen < 0))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
* errors just return RFAILED.
*/
if (ret == RCLOSED)
- RETVALUE(RCLOSED);
+ return (RCLOSED);
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* check if connection got closed */
* considered as connection closed. So return ROKDNA instead of
* RCLOSED even for TCP sockets
*/
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
/* added check for TCP/UDP socket. Pending data len in the socket
recv buffer is determined by ioctl call in cmInetGetNumRead.
ret = SGetSBuf(info->region, info->pool, &recvBuf, bufLen);
if (ret != ROK)
{
- RETVALUE(ROUTRES);
+ return (ROUTRES);
}
/* added different recvfrom calls with
(INET_ERR_CODE == ERR_WOULDBLOCK))
{
recvLen = 0;
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
/* moved up the cleanup */
(INET_ERR_CODE == ERR_CONNRESET))
{
recvLen = 0;
- RETVALUE(RCLOSED);
+ return (RCLOSED);
}
- RETVALUE(RFAILED);
+ return RFAILED;
}
if (recvLen < (S32)bufLen) /* maybe happen */
{
/* cleanup */
SPutSBuf(info->region, info->pool, recvBuf, bufLen);
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
/* copy data */
else
{
/* not enough data pending yet */
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
}
else
{
/* no data pending */
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetPeek */
\f
/* error check on parameters */
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
CMINETLOGERROR(ERRCLS_DEBUG, ECMINET037, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetClose */
\f
/* error check on parameters */
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
if (INET_ERR_CODE == ERR_NOTCONN)
{
/* socket is not connected */
- RETVALUE(ROK);
+ return ROK;
}
else
{
CMINETLOGERROR(ERRCLS_DEBUG, ECMINET038, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
}
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetShutdown */
\f
/* error check on parameters */
if (numFdS == NULLP)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
/* cm_inet_c_001.main_53 - Return ROKDNA in case select was interrupted */
if ((ret == INET_ERR) && (INET_ERR_CODE == ERR_EINTR))
{
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
/* timeout occured */
if (ret == 0)
{
- RETVALUE(RTIMEOUT);
+ return (RTIMEOUT);
}
if (ret == INET_ERR)
switch(errCode = INET_ERR_CODE)
{
case ERR_INVAL:
- RETVALUE(ROK);
+ return ROK;
default:
#ifdef CMINETDBG
INET_ERR_CODE);
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET039, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
} /* end of switch */
}
/* cm_inet_c_001.main_54: Fix for Klockworks issue */
*numFdS = (S16)ret;
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetSelect */
\f
/* cm_inet_c_001.main_58 : Added NULL check for value field */
if(value == NULLP)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#if (ERRCLASS & ERRCLS_INT_PAR)
/* error check on parameters */
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
default:
/* wrong value */
- RETVALUE(RFAILED);
+ return RFAILED;
break;
}
break;
if (*optVal == CM_INET_OPT_ENABLE)
{
#ifdef WIN32
- RETVALUE(RNA);
+ return (RNA);
#else
ret = setsockopt(sockFd->fd, level, IP_HDRINCL,
(char*)&enable, sizeof(enable));
else if (*optVal == CM_INET_OPT_DISABLE)
{
#ifdef WIN32
- RETVALUE(RNA);
+ return (RNA);
#else
ret = setsockopt(sockFd->fd, level, IP_HDRINCL,
(char*)&disable, sizeof(disable));
ret = setsockopt(sockFd->fd, level, IP_ROUTER_ALERT,
(char*)&enable, sizeof(enable));
if (ret != ROK)
- RETVALUE(RFAILED);
+ return RFAILED;
}
else if (*optVal == CM_INET_OPT_DISABLE)
{
ret = setsockopt(sockFd->fd, level, IP_ROUTER_ALERT,
(char*)&disable, sizeof(disable));
if (ret != ROK)
- RETVALUE(RFAILED);
+ return RFAILED;
}
break;
#endif /* SS_LINUX */
/* set Router Alert socket option */
case CM_INET_OPT_IP_OPTIONS:
#if (defined (SS_VW) || defined(SS_LINUX))
- RETVALUE(RNA);
+ return (RNA);
#else
tempTknStr64=(TknStr64 *)value;
if (tempTknStr64->pres == TRUE)
(char *)tempTknStr64->val, tempTknStr64->len);
}
else
- RETVALUE(RFAILED); /* Trying to set IPv4 Hdr option
+ return RFAILED; /* Trying to set IPv4 Hdr option
* without giving option values*/
#endif /* SS_VW || SS_LINUX */
break;
(char*)&enable, sizeof(enable));
if (ret != ROK)
- RETVALUE(RFAILED);
+ return RFAILED;
}
else if (*optVal == CM_INET_OPT_DISABLE)
{
(char*)&disable, sizeof(disable));
if (ret != ROK)
- RETVALUE(RFAILED);
+ return RFAILED;
}
break;
#endif /* LOCAL_INTF */
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET040, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
pAddr6 = (struct sockaddr_in6*)&(setPrim.ssp_addr);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
pAddr6 = (struct sockaddr_in6*)&(addrParams.spp_address);
default:
/* wrong socket option type */
- RETVALUE(RFAILED);
+ return RFAILED;
break;
}
CMINETLOGERROR(ERRCLS_DEBUG, ECMINET042, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetSetOpt */
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd) ||
(dataLen == NULLP))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
* select says is ready to read. This should not be considered as
* connection closed.
*/
- RETVALUE(RCLOSED);
+ return (RCLOSED);
}
/* removed error check ERR_WOULDBLOCK */
(INET_ERR_CODE == ERR_CONNRESET))
{
*dataLen = 0;
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
#ifdef SS_LINUX
/* cm_inet_c_001.main_45: Change 2048 to CM_INET_MAX_UDPRAW_MSGSIZE */
*dataLen = CM_INET_MAX_UDPRAW_MSGSIZE;
- RETVALUE(ROK);
+ return ROK;
#endif /* SS_LINUX */
/* removed error debug printing added for recvfrom call. */
CMINETLOGERROR(ERRCLS_DEBUG, ECMINET043, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetGetNumRead */
\f
/* error check on parameters */
if ((hostName == NULLP) || (addrTbl == NULLP))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
" hostName(%p)\n", INET_ERR_CODE, hostName);
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET044, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
if (hostid->h_addrtype != AF_INET)
{
INET_ERR_CODE, hostName, hostid->h_addrtype);
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET045, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
else
{
" hostName(%p)\n", INET_ERR_CODE, hostName);
CMINETLOGERROR(ERRCLS_DEBUG, ECMINET046, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
CM_COPY_VWIPADDR(vwIpAddr, &(addrTbl->netAddr[addrTbl->count]));
addrTbl->count++;
INET_ERR_CODE, hostName, hostid.h_addrtype);
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET047, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
else
{
#endif /* WIN32 || SS_LINUX || HPOS */
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetGetHostByName */
/* error check on parameters */
if ((hostName == NULLP) || (addrArr == NULLP))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
err, hostName, addrArr->type);
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET048, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#ifdef IPV6_SUPPORTED
err, hostName, addrArr->type, hostid->h_addrtype);
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET049, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
}
else
err, hostName, hostid->h_addrtype, addrArr->type);
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET050, 0, prntBuf);
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
}
#endif /* SS_LINUX */
#endif /* SUNOS */
- RETVALUE(ROK);
+ return ROK;
#else
ret = cmInetGetHostByName(hostName, &addrArr->u.ipv4AddrArr);
- RETVALUE(ret);
+ return (ret);
#endif /* IPV6_SUPPORTED */
} /* end of cmInetGetIpNodeByName */
/* error check on parameters */
if (asciiAddr == NULLP)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
if (*address == (U32)ERR_INADDRNONE)
{
/* asciiAddr does not contain a valid internet address */
- RETVALUE(RFAILED);
+ return RFAILED;
}
- RETVALUE(ROK);
+ return ROK;
}
\f
/* error check on parameters */
if (asciiAddr == NULLP)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
*asciiAddr = inet_ntoa(inetAddr);
if (*asciiAddr == NULL)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
- RETVALUE(ROK);
+ return ROK;
}
/*
*
/* error check on parameters */
if (asciiAddr == NULLP || address == NULLP || len == 0 )
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
}
if(inet_ntop(domain,address,asciiAddr,len) == NULL)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
- RETVALUE(ROK);
+ return ROK;
}
/* error check on parameters */
if ((asciiAddr == NULLP) || (address == NULLP))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
ret = inet_pton(AF_INET, asciiAddr, (void *)address);
if (ret != 1)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetPton */
#endif /* SUNOS */
#endif /* IPV6_SUPPORTED */
/* error check on parameters */
if ((asciiAddr == NULLP) || (address6 == NULLP))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
ret = inet_pton(AF_INET6, asciiAddr, (void *)address6);
if (ret != 1)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#else
/* cm_inet_c_001.main_44 : In windows inet_pton is not implemented. so we are using the below function
cmMemcpy((U8*)address6, (U8*)&(((struct sockaddr_in6 *)&ss)->sin6_addr), sizeof(CmInetIpAddr6));
#endif /* WIN32 */
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetPton6 */
#endif /* IPV6_SUPPORTED */
#endif /* SS_PS */
*size = CM_INET_MAX_MSG_LEN;
#endif
- RETVALUE(ROK);
+ return ROK;
}
err = WSAStartup(version, &data);
if (err != 0)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
- RETVALUE(ROK);
+ return ROK;
}
\f
err = WSACleanup();
if (err != 0)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
- RETVALUE(ROK);
+ return ROK;
}/* end of cmInetDeInit() */
\f
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd) ||
(locAddr == NULLP))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
#else
locAddr->port = CM_INET_NTOH_U16(sockAddr->sin_port);
#endif /* IPV6_SUPPORTED */
- RETVALUE(ROK);
+ return ROK;
default:
#ifdef CMINETDBG
CMINETLOGERROR(ERRCLS_INT_PAR, ECMINET051, 0, prntBuf);
#endif /* ALIGN_64BIT */
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}/* end of switch */
}/* end if */
locAddr->port = CM_INET_NTOH_U16(sockAddr->sin_port);
locAddr->address = CM_INET_NTOH_U32(sockAddr->sin_addr.s_addr);
#endif /* IPV6_SUPPORTED */
- RETVALUE(ROK);
+ return ROK;
}/* end of cmInetGetSockName() */
/* New functions to peek into the file descriptor
#if (ERRCLASS & ERRCLS_INT_PAR)
if (fdSetInfo == NULLP)
- RETVALUE(RFAILED);
+ return RFAILED;
#endif /* ERRCLASS & ERRCLS_INT_PAR */
if (fdSetInfo->initDone == TRUE)
- RETVALUE(ROK);
+ return ROK;
#ifdef WIN32
fdSetInfo->numFds = 0;
#endif /* SUNOS || SS_LINUX || SS_VW || HPOS */
fdSetInfo->initDone = TRUE;
- RETVALUE(ROK);
+ return ROK;
}/* end of cmInetFdSetInfoInit() */
\f
#if (ERRCLASS & ERRCLS_INT_PAR)
if ((fdSetInfo == NULLP) || (fdSet == NULLP) || (sockFd == NULLP))
- RETVALUE(RFAILED);
+ return RFAILED;
if (fdSetInfo->initDone != TRUE)
- RETVALUE(RNA);
+ return (RNA);
#endif /* ERRCLASS & ERRCLS_INT_PAR */
#ifdef WIN32
#if (ERRCLASS & ERRCLS_DEBUG)
if (fdSetInfo->numFds > FD_SETSIZE)
- RETVALUE(RFAILED);
+ return RFAILED;
#endif /* ERRCLASS & ERRCLS_DEBUG */
/* cm_inet_c_001.main_32 : Corrected check for number of fd set in
a fdset for WIN32*/
if (fdSetInfo->numFds >= fdSet->fd_count)
- RETVALUE(ROKDNA);
+ return (ROKDNA);
*sockFd = fdSet->fd_array[fdSetInfo->numFds];
fdSetInfo->numFds += 1;
- RETVALUE(ROK);
+ return ROK;
#endif /* WIN32 */
/* cm_inet_c_001.main_59: Protected under if not defined WIN32 */
*sockFd += (curIdx * (sizOfFdSetArElem << 3));
/* Clear the file descriptor */
*tempByte &= ~(1 << bitPos);
- RETVALUE(ROK);
+ return ROK;
}
if (fdSetInfo->bigEndian)
tempByte -= 1;
}
if (!found)
- RETVALUE(ROKDNA);
+ return (ROKDNA);
- RETVALUE(ROK);
+ return ROK;
#endif /* SUNOS || SS_LINUX || SS_VW || HPOS */
} /* end of cmInetGetFd */
((val[idx] < 'A') || (val[idx] > 'F')))
{
/* Not a digit */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* (ERRCLASS & ERRCLS_DEBUG) */
if ((val[idx] != '.') && (val[idx] != ':'))
{
/* Not a digit */
- RETVALUE(RFAILED);
+ return RFAILED;
} /* if, couldn't determine IPV4 or IPV6 */
#endif /* (ERRCLASS & ERRCLS_DEBUG) */
if (compressed == TRUE)
{
/* can't have 2 :: */
- RETVALUE(RFAILED);
+ return RFAILED;
} /* if, 2 :: */
#endif /* (ERRCLASS & ERRCLS_DEBUG) */
an IPV6 address */
if (retVal != ROK)
{
- RETVALUE(retVal);
+ return (retVal);
}
embedIPV4 = TRUE;
break;
((val[idx] < 'A') || (val[idx] > 'F')))
{
/* Not a digit */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* (ERRCLASS & ERRCLS_DEBUG) */
} /* else, IPV6 */
#endif /* IPV6_SUPPORTED */
- RETVALUE(ROK);
+ return ROK;
} /* cmInetConvertStrToIpAddr */
\f
if (val[idx] < '0' || val[idx] > '9')
{
/* Not a digit */
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* (ERRCLASS & ERRCLS_DEBUG) */
idx++;
}
- RETVALUE(ROK);
+ return ROK;
} /* cmInetAsciiToIpv4 */
/* cm_inet_c_001.main_34:Added wrapper function for getaddrinfo and freeaddrinfo */
/* error check on parameters */
if ((node == NULLP) || (hints == NULLP))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
#endif /* ALIGN_64BIT */
#endif /* CMINETDBG */
}
- RETVALUE(ret);
+ return (ret);
} /* end of cmInetGetAddrInfo */
\f
/* error check on parameters */
if ((sockFd == NULLP) || CM_INET_INV_SOCK_FD(sockFd))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
if (ret != ROK)
{
/* ret may be RFAILED or ROUTRES */
- RETVALUE(ret);
+ return (ret);
}
/* check if connection got closed */
* considered as connection closed. So return ROKDNA instead of
* RCLOSED
*/
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
else
/* clear error if there is any, because if there is internal error
CMINETLOGERROR(ERRCLS_DEBUG, ECMINET054, 0, prntBuf);
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
else
{
#endif /* defined(SUNOS) || defined(SS_LINUX) */
#endif /* defined(SS_VW) || defined(HPOS) || defined(SS_PS) */
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
}
}/* if (pendLen == 0)*/
(INET_ERR_CODE == ERR_WOULDBLOCK))
{
*len = 0;
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
(INET_ERR_CODE == ERR_CONNRESET))
{
*len = 0;
- RETVALUE(RCLOSED);
+ return (RCLOSED);
}
#ifdef CMINETDBG
#endif /*ALIGN_64BIT*/
#endif /* CMINETDBG */
- RETVALUE(RFAILED);
+ return RFAILED;
}
if(recvLen < curLen)
(INET_ERR_CODE == ERR_WOULDBLOCK))
{
*len = 0;
- RETVALUE(ROKDNA);
+ return (ROKDNA);
}
#ifdef CMINETDBG
if (INET_ERR_CODE == ERR_CONNABORTED)
{
*len = 0;
- RETVALUE(RCLOSED);
+ return (RCLOSED);
}
- RETVALUE(RFAILED);
+ return RFAILED;
}/* if ((recvLen == INET_ERR) || (recvLen > CM_INET_MAX_MSG_LEN))*/
if(recvLen < curLen)
#endif /* WIN32 | CMINETFLATBUF */
- RETVALUE(ROK);
+ return ROK;
} /* end of cmInetFlushRecvBuf */
#endif /* CM_INET_FLUSH_RECV_BUF*/