#define _POSIX_C_SOURCE 199309L
#endif
/* mt003.301 moved env files to use the __USE_UNIX98 flag in sys includes */
-#include "envopt.h" /* environment options */
-#include "envdep.h" /* environment dependent */
-#include "envind.h" /* environment independent */
#include <fcntl.h>
#include <pthread.h>
/* header include files (.h) */
-#include "gen.h" /* general layer */
-#include "ssi.h" /* system services */
-
-#include "cm5.h" /* common timers */
-
+#include "common_def.h"
#include "mt_ss.h" /* MTSS specific */
#include "mt_err.h" /* MTSS error defines */
/* mt003.301 Additions - Task deregistration */
#include "ss_err.h" /* error */
#include "cm_mem.h" /* common memory manager */
-#include "cm_lte.h" /* common lte param */
/* mt001.301 : Additions */
#ifdef SS_THREAD_PROFILE
#include "ss_err.h"
void * mtGetWlsHdl()
{
- RETVALUE(osCp.wls.intf);
+ return (osCp.wls.intf);
}
#ifdef XEON_MULTIPLE_CELL_CHANGES
if(!osCp.wls.intf)
{
printf("Could not open WLS Interface \n");
- RETVALUE(0);
+ return (0);
}
- RETVALUE(1);
+ return (1);
}
#endif
if(smWrReadWlsConfigParams() != ROK)
{
fprintf(stderr, "Failed to read WLS params from file wr_cfg.txt");
- RETVALUE(RFAILED);
+ return RFAILED;
} /* end of if statement */
#endif
#ifdef INTEL_WLS
if(!SOpenWlsIntf())
- RETVALUE(0);
+ return (0);
#endif /* INTEL_WLS */
msArgc = argc;
printf("\n SInit failed, SSI could not start \n");
/* pthread_exit(NULLP);*/ /* Commented to Come out of Main thread*/
- RETVALUE(0);
+ return (0);
}
/*mt010.301 cleanup part exposed to user*/
SFini();
- RETVALUE(0);
+ return (0);
}
#else
SInit();
- RETVALUE(0);
+ return (0);
}
#endif
if(fileBasedMemCfg == TRUE && memConfigured == FALSE)
{
printf("\n File Based Memory configuration failed \n");
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
/* initialize the started semaphore */
if (sem_init(&osCp.dep.ssStarted, 0, 0) != 0)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* mt028.201 added compile time flag to allow not to mask signals */
if(sigaction(SIGILL, &sa, NULL) != 0)
{
printf("Failed to process sigaction for the SIGILL\n");
- RETVALUE(RFAILED);
+ return RFAILED;
}
if(sigaction(SIGSEGV, &sa, NULL) != 0)
{
printf("Failed to process sigaction for the SIGSEGV\n");
- RETVALUE(RFAILED);
+ return RFAILED;
}
if(sigaction(SIGABRT, &sa, NULL) != 0)
{
printf("Failed to process sigaction for the SIGABRT\n");
- RETVALUE(RFAILED);
+ return RFAILED;
}
if(sigaction(SIGTERM, &sa, NULL) != 0)
{
printf("Failed to process sigaction for the SIGTERM\n");
- RETVALUE(RFAILED);
+ return RFAILED;
}
if(sigaction(SIGHUP, &sa, NULL) != 0)
{
printf("Failed to process sigaction for the SIGHUP\n");
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
#else
act.sa_flags = 0;
if (sigaction(SIGINT, &act, NULLP) != 0)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
/* mt040.201 initialise random seed */
osCp.dep.randSeed = time(NULLP);
- RETVALUE(ROK);
+ return ROK;
}
\f
#if (ERRCLASS & ERRCLS_INT_PAR)
if(bktIdx >= globReg->numBkts)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
dynMemSetElem->nextBktPtr = NULLP;
dynMemSetElem->numFreeBlks = 0;
- RETVALUE(ROK);
+ return ROK;
}
/*
#if (ERRCLASS & ERRCLS_INT_PAR)
if(bktIdx >= globReg->numBkts)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
dynMemSetElem->numFreeBlks = bktCb->bucketSetSize;
- RETVALUE(ROK);
+ return ROK;
} /* ssGetDynMemBlkSet */
#if (ERRCLASS & ERRCLS_INT_PAR)
if(bktIdx >= globReg->numBkts)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
if(lstNode == NULLP)
{
SUnlock(&(bktCb->bucketLock));
- RETVALUE(RFAILED);
+ return RFAILED;
}
cmLListDelFrm(&(bktCb->listFreeBktSet), lstNode);
SUnlock(&(bktCb->bucketLock));
}
- RETVALUE(ROK);
+ return ROK;
}
/*
#if (ERRCLASS & ERRCLS_INT_PAR)
if(bktIdx >= globReg->numBkts)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
if(lstNode == NULLP)
{
SUnlock(&(bktCb->bucketLock));
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* Delete the node from the valid linked list and copy the values of the
SUnlock(&(bktCb->bucketLock));
}
- RETVALUE(ROK);
+ return ROK;
} /* ssGetDynMemBlkSet */
{
CmMmGlobRegCb *globReg;
CmMmGlobalBktCb *bktCb;
- U8 blkCnt;
U8 bktIdx= reg;
TRC3(isMemThreshReached)
#if (ERRCLASS & ERRCLS_INT_PAR)
if(bktIdx >= globReg->numBkts)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* ERRCLASS & ERRCLS_INT_PAR */
// printf ("recoverd bktCb->listValidBktSet.count %d bktIdx %d\n",bktCb->listValidBktSet.count ,bktIdx);
}
SUnlock(&(bktCb->bucketLock));
- RETVALUE(RFAILED);
+ return RFAILED;
}
else
{
SUnlock(&(bktCb->bucketLock));
}
}
- RETVALUE(ROK);
+ return ROK;
}
#endif /* USE_MALLOC */
/* Klock work fix ccpu00148484 */
if(!(region < SS_MAX_REGS))
{
- RETVALUE(NULLP);
+ return (NULLP);
}
dynRegCb = (CmMmDynRegCb *)osCp.dynRegionTbl[region].regCb;
- RETVALUE(dynRegCb->iccHdl);
+ return (dynRegCb->iccHdl);
}
#endif /* SS_USE_ICC_MEMORY */
}
//Store last region addr for validation
mtRegMemSz[i].startAddr = regMemStrtAddr;
- RETVALUE(ROK);
+ return ROK;
}
#ifdef SS_MEM_WL_DEBUG
}
#endif /* T2K_MEM_LEAK_DBG */
}
- RETVALUE(ROK);
+ return ROK;
}
PUBLIC S16 SAllocateWlsMem()
{
printf("\n ************* \n WLS memory: %lx, %d\n ****** \n", (PTR)osCp.wls.allocAddr, reqdMemSz);
#endif
SPartitionWlsMemory();
- RETVALUE(ROK);
+ return ROK;
}
PUBLIC S16 SAllocateStaticMem()
{
printf("\n ************* \n Static memory: %lx, %d\n ****** \n", (PTR)startAddr, reqdMemSz);
#endif
SPartitionStaticMemory(startAddr);
- RETVALUE(ROK);
+ return ROK;
}
#endif /* INTEL_WLS */
dynRegCb = (CmMmDynRegCb *)calloc(1, sizeof(CmMmDynRegCb));
if(dynRegCb == NULLP)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
for(k = 0; k < mtDynMemoCfg.region[i].numBkts; k++)
{
if(osCp.globRegCb == NULLP)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
globReg = (CmMmGlobRegCb *)osCp.globRegCb;
#endif
if(globReg->bktTbl[i].startAddr == NULLP)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
globReg->bktTbl[i].poolId = i;
globReg->bktTbl[i].size = mtGlobMemoCfg.bkt[i].blkSize;
dynRegCb = (CmMmDynRegCb *)calloc(1, sizeof(CmMmDynRegCb));
if(dynRegCb == NULLP)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
for(k = 0; k < mtDynMemoCfg.region[i].numBkts; k++)
{
#ifdef XEON_SPECIFIC_CHANGES
free(dynRegCb);
#endif
- RETVALUE(RFAILED);
+ return RFAILED;
}
dynRegCb->bktTbl[k].size = mtGlobMemoCfg.bkt[k].blkSize;
dynRegCb->bktTbl[k].blkSetRelThreshold = mtDynMemoCfg.region[i].bkt[k].blkSetRelThreshold;
if (pthread_mutex_init(&(regMemLeakInfo.memLock[reg]), NULL) != 0)
{
printf("\n mutex init failed\n");
- RETVALUE(RFAILED);
+ return RFAILED;
}
}
#endif
free(mtCMMRegCb[k]);
free(mtCMMRegCfg[k]);
}
- RETVALUE(RFAILED);
+ return RFAILED;
}
mtCMMRegCfg[i] = (CmMmRegCfg *)calloc(1, sizeof(CmMmRegCfg));
free(mtCMMRegCfg[k]);
}
free(mtCMMRegCb[i]);
- RETVALUE(RFAILED);
+ return RFAILED;
}
}
free(mtCMMRegCb[i]);
free(mtCMMRegCfg[i]);
- RETVALUE(RFAILED);
+ return RFAILED;
}
free(mtCMMRegCfg[i]->vAddr);
free(mtCMMRegCb[i]);
free(mtCMMRegCfg[i]);
- RETVALUE(RFAILED);
+ return RFAILED;
}
free(mtCMMRegCfg[i]->vAddr);
free(mtCMMRegCb[i]);
free(mtCMMRegCfg[i]);
- RETVALUE(RFAILED);
+ return RFAILED;
}
}
}
#endif /* SS_MEM_LEAK_STS */
- RETVALUE(ROK);
+ return ROK;
}
\f
osCp.sTskTbl[tskInd].dep.lwpId = 0;
}
#endif /* SS_MULTICORE_SUPPORT || SS_AFFINITY_SUPPORT */
- RETVALUE(ROK);
+ return ROK;
}
\f
*/
if (pipe(osCp.dep.isFildes) != 0)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#ifndef L2_L3_SPLIT
/* mt020.201 - Addition for destroying thread attribute object attr */
pthread_attr_destroy(&attr);
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
pthread_attr_destroy(&attr);
#endif
- RETVALUE(ROK);
+ return ROK;
}
\f
sTsk = ssdAddTmrSTsk();
if(!sTsk)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* SS_MULTICORE_SUPPORT */
/* create the timer handler thread */
/* mt020.201 - Addition for destroying thread attribute object attr */
pthread_attr_destroy(&attr);
- RETVALUE(RFAILED);
+ return RFAILED;
}
#ifdef SS_THR_REG_MAP
pthread_attr_destroy(&attr);
- RETVALUE(ROK);
+ return ROK;
}
\f
if ((tcgetattr(fd, &tio)) != 0)
{
printf("Error: disable canonical input processing\n");
- RETVALUE(RFAILED);
+ return RFAILED;
}
tio.c_lflag &= ~ICANON;
if ((tcsetattr(fd, TCSANOW, &tio)) != 0)
{
printf("Error: while tcsetattr() processing\n");
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* CONSTDIO */
if (fcntl(fd, F_SETFL, flags) == -1)
{
printf("Error: while fcntl processing\n");
- RETVALUE(RFAILED);
+ return RFAILED;
}
pthread_attr_destroy(&attr);
printf("Error: Logging Thread creation failed \n");
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* mt020.201 - Addition for destroying thread attribute object attr */
#endif /* CONAVL */
- RETVALUE(ROK);
+ return ROK;
}
\f
ProcId procId = SS_WD_WDPROC;
if (SAddProcIdLst(1, &procId) != ROK)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* SS_MULTIPLE_PROCS */
if (SGetMsg(SS_DFLT_REGION, SS_DFLT_POOL, &mBuf) != ROK)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#ifndef SS_MULTIPLE_PROCS
pst.srcProcId = SFndProcId();
ssdInitWatchDgPst(&pst);
SPstTsk(&pst, mBuf);
- RETVALUE(ROK);
+ return ROK;
}
#ifdef ANSI
pst->srcEnt = ENTDW; /* source entity */
pst->srcInst = 0;
- RETVALUE(ROK);
+ return ROK;
}
#ifdef SS_MULTIPLE_PROCS
cmPrcTmr(&osCp.wdCp.watchDgTqCp, osCp.wdCp.watchDgTs, (PFV)ssdWatchDgTmrEvt);
- RETVALUE(ROK);
+ return ROK;
}
#ifdef ANSI
}
SUnlock(&osCp.wdCp.wdLock);
- RETVALUE(ret);
+ return (ret);
}
#endif /* SS_WATCHDOG */
UNUSED(argv);
UNUSED(opts);
- RETVALUE(EOF);
+ return (EOF);
#else
sp = 1;
/*mt013.301 : Changes as per coding standards*/
if (msOptInd >= (S16) argc || argv[msOptInd][0] == '\0')
{
- RETVALUE(EOF);
+ return (EOF);
}
else
{
if (!strcmp(argv[msOptInd], "--"))
{
msOptInd++;
- RETVALUE(EOF);
+ return (EOF);
}
else if (argv[msOptInd][0] != '-')
{
msOptInd++;
- RETVALUE('?');
+ return ('?');
}
}
}
sp = 1;
}
- RETVALUE('?');
+ return ('?');
}
if (*++cp == ':')
if (++msOptInd >= (S16) argc)
{
sp = 1;
- RETVALUE('?');
+ return ('?');
}
else msOptArg = argv[msOptInd++];
}
- RETVALUE(c);
+ return (c);
#endif /* NOCMDLINE */
}
#if (ERRCLASS & ERRCLS_DEBUG)
MTLOGERROR(ERRCLS_DEBUG, EMT001, ret, "SGetMsg() failed");
#endif
- RETVALUE(RFAILED);
+ return RFAILED;
}
mInfo = (SsMsgInfo *)mBuf->b_rptr;
MTLOGERROR(ERRCLS_DEBUG, EMT002, ret,
"Could not write to demand queue");
#endif
- RETVALUE(RFAILED);
+ return RFAILED;
}
}
- RETVALUE(ROK);
+ return ROK;
}
\f
TRC0(ssdDetachTTsk);
- RETVALUE(ROK);
+ return ROK;
}
\f
SsSTskEntry *sTsk; /* pointer to system task entry */
#endif
{
+ S16 ret;
pthread_attr_t attr;
/* struct sched_param param_sched;*/
#endif /* SS_MULTICORE_SUPPORT */
#endif /* SS_WATCHDOG */
{
- RETVALUE(ROK);
+ return ROK;
}
#endif
while(threadCreated == FALSE)
{
#endif
- if ((pthread_create(&sTsk->dep.tId, &attr, mtTskHdlrT2kL2, (Ptr)sTsk)) != 0)
+ ret = pthread_create(&sTsk->dep.tId, &attr, mtTskHdlr, (Ptr)sTsk);
+ if (ret != 0)
{
-
+ DU_LOG("\nDU APP : Failed to create thread. Cause[%d]",ret);
pthread_attr_destroy(&attr);
#if (ERRCLASS & ERRCLS_DEBUG)
MTLOGERROR(ERRCLS_DEBUG, EMT004, ERRZERO, "Could not create thread");
#endif
- RETVALUE(RFAILED);
+ return RFAILED;
}
#ifdef SS_THR_REG_MAP
threadCreated = ssCheckAndAddMemoryRegionMap(sTsk->dep.tId,
while(threadCreated == FALSE)
{
#endif
- if ((pthread_create(&sTsk->dep.tId, &attr, mtTskHdlr, (Ptr)sTsk)) != 0)
+ ret = pthread_create(&sTsk->dep.tId, &attr, mtTskHdlr, (Ptr)sTsk);
+ if (ret != 0)
{
/* mt020.201 - Addition for destroying thread attribute object attr */
MTLOGERROR(ERRCLS_DEBUG, EMT004, ERRZERO, "Could not create thread");
#endif
- RETVALUE(RFAILED);
+ return RFAILED;
}
#ifdef SS_THR_REG_MAP
threadCreated = ssCheckAndAddMemoryRegionMap(sTsk->dep.tId,
/* mt020.201 - Addition for destroying thread attribute object attr */
pthread_attr_destroy(&attr);
- RETVALUE(ROK);
+ return ROK;
}
/* Klock work fix ccpu00148484 */
if(threadArg == NULLP)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
threadArg->argument = arg;
threadArg->start_routine = start_routine;
if (((retVal = pthread_create(tid, attr, pthreadCreateHdlr, threadArg))) != 0)
{
- RETVALUE(retVal);
+ return (retVal);
}
#ifdef SS_THR_REG_MAP
threadCreated = ssCheckAndAddMemoryRegionMap(*tid, SS_MAX_REGS - 1);
#endif
}
- RETVALUE(retVal);
+ return (retVal);
}
#endif
pthread_attr_setschedparam(attr, ¶m);
- RETVALUE (ROK);
+ return (ROK);
} /* ssdSetPthreadAttr */
if (tskInd == SS_MAX_STSKS)
{
MTLOGERROR(ERRCLS_DEBUG, EMT036, ERRZERO, "Invalid system task Id\n");
- RETVALUE(RFAILED);
+ return RFAILED;
}
#if (ERRCLASS & ERRCLS_DEBUG)
MTLOGERROR(ERRCLS_DEBUG, EMT037, ERRZERO, "Could not get thread affinity\n");
#endif
- RETVALUE(RFAILED);
+ return RFAILED;
} /* end if pthread_setaffinity fails */
for (cpuInd = 0; cpuInd <CPU_SETSIZE; cpuInd++)
if (tskInd == SS_MAX_STSKS)
{
MTLOGERROR(ERRCLS_DEBUG, EMT036, ERRZERO, "Invalid system task Id\n");
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* set thread affinity for Solaris */
#if (ERRCLASS & ERRCLS_DEBUG)
MTLOGERROR(ERRCLS_DEBUG, EMT037, ERRZERO, "Could not get thread affinity\n");
#endif
- RETVALUE(RFAILED);
+ return RFAILED;
} /* end if processor_bind fails */
#endif /* SUNOS */
#endif /* SS_LINUX */
- RETVALUE(ROK);
+ return ROK;
} /* ssdGetAffinity */
if (tskInd == SS_MAX_STSKS)
{
MTLOGERROR(ERRCLS_DEBUG, EMT036, ERRZERO, "Invalid system task Id\n");
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* initialize the cpu mask */
#if (ERRCLASS & ERRCLS_DEBUG)
MTLOGERROR(ERRCLS_DEBUG, EMT038, ERRZERO, "Could not set thread affinity\n");
#endif
- RETVALUE(RFAILED);
+ return RFAILED;
} /* end if pthread_setaffinity fails */
#else
if (tskInd == SS_MAX_STSKS)
{
MTLOGERROR(ERRCLS_DEBUG, EMT036, ERRZERO, "Invalid system task Id\n");
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* set thread affinity for Solaris */
#if (ERRCLASS & ERRCLS_DEBUG)
MTLOGERROR(ERRCLS_DEBUG, EMT038, ERRZERO, "Could not set thread affinity\n");
#endif
- RETVALUE(RFAILED);
+ return RFAILED;
} /* end if processor_bind fails */
#endif /* SUNOS */
#endif /* SS_LINUX */
- RETVALUE(ROK);
+ return ROK;
} /* ssdSetAffinity */
#endif /* SS_MULTICORE_SUPPORT || SS_AFFINITY_SUPPORT */
MTLOGERROR(ERRCLS_DEBUG, EMT005, ERRZERO, "Could not get a message");
#endif
- RETVALUE(RFAILED);
+ return RFAILED;
}
mInfo = (SsMsgInfo *)mBuf->b_rptr;
"Could not write to demand queue");
#endif
- RETVALUE(RFAILED);
+ return RFAILED;
}
- RETVALUE(ROK);
+ return ROK;
}
/* mt023.201 - Added SThreadYield function to yield CPU
tw.tv_sec=0;
tw.tv_usec=0;
- RETVALUE(select(0,0,0,0,&tw) == 0 ? ROK : RFAILED);
+ return (select(0,0,0,0,&tw) == 0 ? ROK : RFAILED);
}
#else /* other UNICes */
- RETVALUE(sleep(0) == 0 ? ROK : RFAILED);
+ return (sleep(0) == 0 ? ROK : RFAILED);
#endif /* SS_LINUX */
cmPlcCbTq(&arg);
- RETVALUE(ROK);
+ return ROK;
}
\f
cmRmvCbTq(&arg);
- RETVALUE(ROK);
+ return ROK;
}
\f
/* won't reach here */
- RETVALUE(ROK);
+ return ROK;
}
\f
TRC0(ssdRegDrvrTsk);
- RETVALUE(ROK);
+ return ROK;
}
/* mt001.30 : Additions */
/*
TRC0(ssdDeregDrvrTsk);
- RETVALUE(ROK);
+ return ROK;
}
#endif
if (ret != ROK)
{
MTLOGERROR(ERRCLS_DEBUG, EMTXXX, ERRZERO, "Could not lock system task table");
- RETVALUE(RFAILED);
+ return RFAILED;
}
SS_ACQUIRE_ALL_SEMA(&osCp.tTskTblSem, ret);
if (ret != ROK)
{
#if (ERRCLASS & ERRCLS_DEBUG)
MTLOGERROR(ERRCLS_DEBUG, EMTXXX, ERRZERO, "Could not Unlock system task table");
- RETVALUE(RFAILED);
+ return RFAILED;
#endif
}
- RETVALUE(RFAILED);
+ return RFAILED;
}
#ifdef SS_MULTIPLE_PROCS
#if (ERRCLASS & ERRCLS_DEBUG)
MTLOGERROR(ERRCLS_DEBUG, EMTXXX, ERRZERO, "Could not Unlock system task table");
#endif
- RETVALUE(RFAILED);
+ return RFAILED;
}
- RETVALUE(ROK);
+ return ROK;
}
//#ifndef SPLIT_RLC_DL_TASK
* (processes L1 msgs) */
}
- RETVALUE(NULLP);
+ return (NULLP);
}
#else
EXTERN Void ysMtTskHdlr(Void);
#endif
}
- RETVALUE(NULLP);
+ return (NULLP);
}
#endif /* TENB_T2K3K_SPECIFIC_CHANGES */
#endif
continue;
pthreadCreateArg->start_routine(pthreadCreateArg->argument);
- RETVALUE(ROK);
+ return ROK;
}
\f
/*
}
}
- RETVALUE(NULLP);
+ return (NULLP);
}
\f
if (ret != ROK)
{
/* nothing to receive */
- RETVALUE(ROK);
+ return ROK;
}
/* if we can't lock this system task entry, return the message */
"Could not lock system task entry");
#endif
SPutMsg(mBuf);
- RETVALUE(ROK);
+ return ROK;
}
/* mt034.201 */
"Could not lock system task table");
#endif
/* what to do here? */
- RETVALUE(ROK);
+ return ROK;
}
/* clean up the system task entry */
/* unlock the system task table */
SUnlock(&osCp.sTskTblLock);
- RETVALUE(RFAILED);
+ return RFAILED;
/* this is a data message or a permanent task keep-alive message */
SThreadYield();
#endif
- RETVALUE(ROK);
+ return ROK;
}
Bool g_usettitmr;
}
/* mt009.21: addition */
- RETVALUE( (Void *) NULLP);
+ return ( (Void *) NULLP);
/* will not reach here */
}
if (osCp.dep.conInFp == NULLP)
{
/* die */
- RETVALUE(NULLP);
+ return (NULLP);
}
fd = fileno(osCp.dep.conInFp);
}
}
/* mt009.21: addition */
- RETVALUE( (Void *) NULLP);
+ return ( (Void *) NULLP);
/* not reached */
}
if (buf == NULLP)
{
MTLOGERROR(ERRCLS_INT_PAR, EMT022, ERRZERO, "Null pointer");
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
#ifndef XEON_SPECIFIC_CHANGES
#ifdef TENB_T2K3K_SPECIFIC_CHANGES
ssMemlog(buf, strlen(buf));
- RETVALUE(ROK);
+ return ROK;
#endif
#endif
#endif
#endif
- RETVALUE(ROK);
+ return ROK;
}
/*mt010.301 */
#endif
pthread_exit(NULLP);
- RETVALUE(0);
+ return (0);
}
\f
/*
UNUSED(dt);
- RETVALUE(ROK);
+ return ROK;
}
\f
if (dt == NULLP)
{
MTLOGERROR(ERRCLS_INT_PAR, EMT023, ERRZERO, "Null pointer");
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
#endif
#endif /*-- SS_DATETIME_USEC --*/
- RETVALUE(ROK);
+ return ROK;
}
/*
#if (ERRCLASS & ERRCLS_INT_PAR)
if (et == NULLP)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
*et = now;
- RETVALUE(ROK);
+ return ROK;
}
if (sysTime == NULLP)
{
MTLOGERROR(ERRCLS_INT_PAR, EMT024, ERRZERO, "Null pointer");
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
*sysTime = osCp.dep.sysTicks;
- RETVALUE(ROK);
+ return ROK;
}
/* mt021.201 - Addition of SGetRefTime function */
if (sec == NULLP || usec == NULLP)
{
MTLOGERROR(ERRCLS_INT_PAR, EMT025, ERRZERO, "Null pointer");
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* mt022.201 - Modification to fix compile warning */
if (refTime > (U32)(ptime.tv_sec))
{
MTLOGERROR(ERRCLS_INT_PAR, EMT026, ERRZERO, "Reference time exceeds present time");
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
*usec = ptime.tv_usec;
#endif
- RETVALUE(ROK);
+ return ROK;
}
{
/* mt011.21: addition */
MTLOGERROR(ERRCLS_INT_PAR, EMT028, (ErrVal)0 , "Null pointer");
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
*value = (Random) rand_r(&osCp.dep.randSeed);
- RETVALUE(ROK);
+ return ROK;
}
\f
TRC1(SExitTsk);
- RETVALUE(ROK);
+ return ROK;
}
\f
TRC1(SExitInt);
- RETVALUE(ROK);
+ return ROK;
}
\f
TRC1(SHoldInt);
- RETVALUE(ROK);
+ return ROK;
}
\f
TRC1(SRelInt);
- RETVALUE(ROK);
+ return ROK;
}
\f
TRC1(SEnbInt);
- RETVALUE(ROK);
+ return ROK;
}
\f
TRC1(SDisInt);
- RETVALUE(ROK);
+ return ROK;
}
\f
UNUSED(vectFnct);
- RETVALUE(ROK);
+ return ROK;
}
\f
UNUSED(vectFnct);
- RETVALUE(ROK);
+ return ROK;
}
/* mt028.201: modification: multiple procs support related changes */
if (ent == NULLP || inst == NULLP)
{
MTLOGERROR(ERRCLS_INT_PAR, EMT029, ERRZERO, "Null pointer");
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
ret = SLock(&osCp.sTskTblLock);
if (ret != ROK)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
for (i = 0; i < SS_MAX_STSKS; i++)
{
SUnlock(&osCp.sTskTblLock);
- RETVALUE(ret == ROK ? ROK : RFAILED);
+ return (ret == ROK ? ROK : RFAILED);
}
\f
if (ent >= ENTNC || inst >= INSTNC)
{
MTLOGERROR(ERRCLS_INT_PAR, EMT030, ERRZERO, "Invalid entity/instance");
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
ret = SLock(&osCp.sTskTblLock);
if (ret != ROK)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
for (i = 0; i < SS_MAX_STSKS; i++)
{
SUnlock(&osCp.sTskTblLock);
- RETVALUE(ret == ROK ? ROK : RFAILED);
+ return (ret == ROK ? ROK : RFAILED);
}
#endif /* SS_MULTIPLE_PROCS */
if (id >= SS_MAX_DRVRTSKS || osCp.drvrTskTbl[id].used == FALSE)
{
MTLOGERROR(ERRCLS_INT_PAR, EMT031, id, "Invalid instance");
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
if (write(osCp.dep.isFildes[1], &isFlag, sizeof(isFlag)) != sizeof(isFlag))
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
- RETVALUE(ROK);
+ return ROK;
}
#endif /* SS_DRVR_SUPPORT */
sprintf(prntBuf, "--------------------------------------------------------------\n");
SDisplay(0, prntBuf);
- RETVALUE(ROK);
+ return ROK;
}
#endif /* SS_LOCKLESS_MEMORY */
pool,
mtCMMRegCb[reg]->bktTbl[pool].numAlloc,
mtCMMRegCb[reg]->bktTbl[pool].numBlks);
- RETVALUE(TRUE);
+ return (TRUE);
}
- RETVALUE(FALSE);
+ return (FALSE);
}
*/
if (region > (SS_MAX_REGS-1) )
{
MTLOGERROR(ERRCLS_INT_PAR, EMT032, ERRZERO, "Invalid Region");
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
SDisplay(0, prntBuf);
#endif
- RETVALUE(ROK);
+ return ROK;
}
#ifdef XEON_SPECIFIC_CHANGES
#define SSI_MAX_BKT_THRESHOLD 6
memStatus = 2;
}
}
- RETVALUE(memStatus);
+ return (memStatus);
}
#endif
/* mt033.201 - addition of API to return the memory statistical data */
if (region >= mtMemoCfg.numRegions )
{
MTLOGERROR(ERRCLS_INT_PAR, EMT033, ERRZERO, "Invalid Region");
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
dbgInfo->numFragBlk = mtCMMRegCb[region]->heapCb.numFragBlk;
#endif
- RETVALUE(ROK);
+ return ROK;
}
#ifdef ANSI
/* Send number of Pools available */
*numPool = cfgRegInfo[0].numPools;
- RETVALUE(ROK);
+ return ROK;
}
/* mt033.201 - addition of APIs to print the memory statistical data
if (region >= mtMemoCfg.numRegions )
{
MTLOGERROR(ERRCLS_INT_PAR, EMT034, ERRZERO, "Invalid Region");
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
else if (typeFlag == SS_MEM_BLK_SIZE_PROFILE)
{
/* Bucket Memory allocation Statistics */
- RETVALUE(SPrintRegMemStats(region));
+ return (SPrintRegMemStats(region));
}
else
{
SDisplay(0, prntBuf);
}
- RETVALUE(ROK);
+ return ROK;
}
/*
sprintf(prntBuf, "\n");
SDisplay(0, prntBuf);
- RETVALUE(ROK);
+ return ROK;
}
/*
if (region >= mtMemoCfg.numRegions )
{
MTLOGERROR(ERRCLS_INT_PAR, EMT035, ERRZERO, "Invalid Region");
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
* we cannot rely on this size. So it is better to stop here unless there
* exists any other mechanism(?) to know the offset to next block.
*/
- RETVALUE(ROK);
+ return ROK;
}
/*mt009.301 Fixed 64BIT compilation warnings*/
}
- RETVALUE(ROK);
+ return ROK;
}
#endif /* SSI_DEBUG_LEVEL1 */
sprintf(ts, "%s.%03ld", time_string, microseconds);
#endif
- RETVALUE(ROK);
+ return ROK;
}
/*-- mt037.201 : Added new API for SGetSystemTsk --*/
{
TRC1(SGetSystemTskS);
- RETVALUE(pthread_self());
+ return (pthread_self());
} /* end of SGetSystemTsk */
"Could not lock system task table");
#endif
- RETVALUE(sTsk);
+ return (sTsk);
}
/* check count of system tasks */
#if (ERRCLASS & ERRCLS_DEBUG)
MTLOGERROR(ERRCLS_DEBUG, EMT040, ERRZERO,
"Could not give the Semaphore");
- RETVALUE(sTsk);
+ return (sTsk);
#endif
}
MTLOGERROR(ERRCLS_ADD_RES, EMT041, ERRZERO, "Too many system tasks");
#endif
- RETVALUE(sTsk);
+ return (sTsk);
}
#if (ERRCLASS & ERRCLS_DEBUG)
MTLOGERROR(ERRCLS_DEBUG, EMT042, ERRZERO,
"Could not give the Semaphore");
- RETVALUE(NULLP);
+ return (NULLP);
#endif
}
"Could not initialize demand queue");
#endif
- RETVALUE(NULLP);
+ return (NULLP);
}
/* initialize the system task entry lock */
#if (ERRCLASS & ERRCLS_DEBUG)
MTLOGERROR(ERRCLS_DEBUG, EMT044, ERRZERO,
"Could not give the Semaphore");
- RETVALUE(NULLP);
+ return (NULLP);
#endif
}
"Could not initialize system task entry lock");
#endif
- RETVALUE(NULLP);
+ return (NULLP);
}
#if (ERRCLASS & ERRCLS_DEBUG)
MTLOGERROR(ERRCLS_DEBUG, EMT046, ERRZERO,
"Could not give the Semaphore");
- RETVALUE(NULLP);
+ return (NULLP);
#endif
}
- RETVALUE(sTsk);
+ return (sTsk);
}
#endif /* SS_MULTICORE_SUPPORT */
/* mt003.301 Readwrite lock and recursive mutex additions */
{
sprintf(prntBuf, "\n\n ssdInitLockNew(): Initialization of read write lock failed,Error# retVal %d\n", retVal);
SDisplay(0, prntBuf);
- RETVALUE(RFAILED);
+ return RFAILED;
}
break;
}
{
sprintf(prntBuf,"\n ssdInitLockNew(): mutexattr init failed,Error# %d \n",retVal);
SPrint(prntBuf);
- RETVALUE(RFAILED);
+ return RFAILED;
}
#ifdef SS_LINUX
retVal = pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE_NP);
sprintf(prntBuf,"\n ssdInitLockNew(): mutexattr settype failed,Error# %d \n",retVal);
pthread_mutexattr_destroy(&attr);
SPrint(prntBuf);
- RETVALUE(RFAILED);
+ return RFAILED;
}
retVal = pthread_mutex_init((pthread_mutex_t *)&(lockId->l.recurLock), &attr);
if(retVal != 0)
sprintf(prntBuf,"\n ssdInitLockNew(): mutex init failed,Error# %d \n",retVal);
pthread_mutexattr_destroy(&attr);
SPrint(prntBuf);
- RETVALUE(RFAILED);
+ return RFAILED;
}
break;
}
{
sprintf(prntBuf, "\n\n ssdInitLockNew(): Invalid lock type %d\n", lockType);
SDisplay(0, prntBuf);
- RETVALUE(RFAILED);
+ return RFAILED;
}
}
- RETVALUE(ROK);
+ return ROK;
}
/*
*
{
sprintf(prntBuf, "\n\n ssdLockNew(): Failed to aquire the read lock,Error# %d\n", retVal);
SDisplay(0, prntBuf);
- RETVALUE(RFAILED);
+ return RFAILED;
}
break;
}
{
sprintf(prntBuf, "\n\n ssdLockNew(): Failed to aquire the write lock,Error# %d\n", retVal);
SDisplay(0, prntBuf);
- RETVALUE(RFAILED);
+ return RFAILED;
}
break;
}
{
sprintf(prntBuf, "\n\n ssdLockNew(): Failed to aquire the read lock,Error# %d\n", retVal);
SDisplay(0, prntBuf);
- RETVALUE(RFAILED);
+ return RFAILED;
}
break;
}
{
sprintf(prntBuf, "\n\n ssdLockNew(): Failed to aquire the read lock,Error# %d\n", retVal);
SDisplay(0, prntBuf);
- RETVALUE(RFAILED);
+ return RFAILED;
}
break;
}
{
sprintf(prntBuf, "\n\n ssdLockNew(): Failed to aquire the recursive mutex,Error# %d\n", retVal);
SDisplay(0, prntBuf);
- RETVALUE(RFAILED);
+ return RFAILED;
}
break;
}
{
sprintf(prntBuf, "\n\n ssdLockNew(): Invalid lock type %d\n", lockType);
SDisplay(0, prntBuf);
- RETVALUE(RFAILED);
+ return RFAILED;
}
}
- RETVALUE(ROK);
+ return ROK;
}
{
sprintf(prntBuf, "\n\n ssdUnLockNew(): Failed to unlock the lock,Error# %d\n", retVal);
SDisplay(0, prntBuf);
- RETVALUE(RFAILED);
+ return RFAILED;
}
break;
}
{
sprintf(prntBuf, "\n\n ssdUnLockNew(): Failed to aquire the recursive mutex,Error# %d\n", retVal);
SDisplay(0, prntBuf);
- RETVALUE(RFAILED);
+ return RFAILED;
}
break;
}
{
sprintf(prntBuf, "\n\n ssdUnlockNew(): Invalid lock type %d\n", lockType);
SDisplay(0, prntBuf);
- RETVALUE(RFAILED);
+ return RFAILED;
}
}
- RETVALUE(ROK);
+ return ROK;
}
/*
{
sprintf(prntBuf, "\n\n ssdDestroyLockNew(): Failed to destroy the lock,Error# %d\n", retVal);
SDisplay(0, prntBuf);
- RETVALUE(RFAILED);
+ return RFAILED;
}
break;
}
{
sprintf(prntBuf, "\n\n ssdDestroyLockNew(): Failed to destroy the mutex,Error# %d\n", retVal);
SDisplay(0, prntBuf);
- RETVALUE(RFAILED);
+ return RFAILED;
}
break;
}
{
sprintf(prntBuf, "\n\n ssdDestroyLockNew(): Invalid lock type %d\n", lockType);
SDisplay(0, prntBuf);
- RETVALUE(RFAILED);
+ return RFAILED;
}
}
- RETVALUE(ROK);
+ return ROK;
}
#endif /* SS_LOCK_SUPPORT */
{
pthread_attr_destroy(&attr);
- RETVALUE(RFAILED);
+ return RFAILED;
}
pthread_attr_destroy(&attr);
- RETVALUE(ROK);
+ return ROK;
}/* ssInitRcvWork */
exit(1);
}
createdThreadIds[createdThreads++] = threadId;
- RETVALUE(FALSE);
+ return (FALSE);
}
/* If we found free mapping table entry, place the region and send pthread_cancel
* for all the thread Ids which are created before this
}
createdThreads = 0;
- RETVALUE(TRUE);
+ return (TRUE);
} /* ssCheckAndAddMemoryRegionMap */
#else
printf("Invalid Thread ID (%d)\n", (U32)threadId);
#endif
- RETVALUE(RFAILED);
+ return RFAILED;
}
/* If we found free mapping table entry, place the region and send pthread_cancel
* for all the thread Ids which are created before this
*/
osCp.threadMemoryRegionMap[((threadId >> SS_MEM_THREAD_ID_SHIFT) % SS_MAX_THREAD_REGION_MAP)] = SS_INVALID_THREAD_REG_MAP;
- RETVALUE(ROK);
+ return ROK;
} /* ssCheckAndAddMemoryRegionMap */
#ifdef MSPD_MLOG_NEW
*startTime = GetTIMETICK();
#endif
- RETVALUE(ROK);
+ return ROK;
}
\f
/*
#endif
break;
}
- RETVALUE(ROK);
+ return ROK;
}
#else
#ifdef ANSI
#endif
{
*startTime = 0;
- RETVALUE(ROK);
+ return ROK;
}
#ifdef ANSI
U32 taskId;
#endif
{
- RETVALUE(ROK);
+ return ROK;
}
#endif /*#ifdef SS_TSKLOG_ENABLE */
"Could not lock system task table");
#endif
- RETVALUE(sTsk);
+ return (sTsk);
}
/* initialize the system task entry with the information we have */
#if (ERRCLASS & ERRCLS_DEBUG)
MTLOGERROR(ERRCLS_DEBUG, EMT042, ERRZERO,
"Could not give the Semaphore");
- RETVALUE(NULLP);
+ return (NULLP);
#endif
}
"Could not initialize demand queue");
#endif
- RETVALUE(NULLP);
+ return (NULLP);
}
/* initialize the system task entry lock */
#if (ERRCLASS & ERRCLS_DEBUG)
MTLOGERROR(ERRCLS_DEBUG, EMT044, ERRZERO,
"Could not give the Semaphore");
- RETVALUE(NULLP);
+ return (NULLP);
#endif
}
"Could not initialize system task entry lock");
#endif
- RETVALUE(NULLP);
+ return (NULLP);
}
#if (ERRCLASS & ERRCLS_DEBUG)
MTLOGERROR(ERRCLS_DEBUG, EMT046, ERRZERO,
"Could not give the Semaphore");
- RETVALUE(NULLP);
+ return (NULLP);
#endif
}
- RETVALUE(sTsk);
+ return (sTsk);
}
#endif /* SS_MULTICORE_SUPPORT */
MTLOGERROR(ERRCLS_DEBUG, EMT046, ERRZERO,
"Could not give the Semaphore");
#endif
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif
sTsk = ssdReAddTmrSTsk(0);
if(!sTsk)
{
- RETVALUE(RFAILED);
+ return RFAILED;
}
#endif /* SS_MULTICORE_SUPPORT */
/* create the timer handler thread */
/* mt020.201 - Addition for destroying thread attribute object attr */
pthread_attr_destroy(&attr);
- RETVALUE(RFAILED);
+ return RFAILED;
}
#ifdef SS_THR_REG_MAP
/* mt020.201 - Addition for destroying thread attribute object attr */
pthread_attr_destroy(&attr);
sem_post(&osCp.dep.ssStarted);
- RETVALUE(ROK);
+ return ROK;
}
/**********************************************************************
Code Review / o-du / l2.git / blobdiff