X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2F5gnrrlc%2Fkw_tmr.c;h=a959503fd0b1cbdab654a2f2a1f631e54499f715;hb=def50dc175cebc67238db5f1acd5ff322a2279bd;hp=f050a9589ff8e1de2a43ea231b82b5a2ceffa018;hpb=5625a52ad68f6ad93684e68bbbdbaef0d462cf9a;p=o-du%2Fl2.git diff --git a/src/5gnrrlc/kw_tmr.c b/src/5gnrrlc/kw_tmr.c index f050a9589..a959503fd 100755 --- a/src/5gnrrlc/kw_tmr.c +++ b/src/5gnrrlc/kw_tmr.c @@ -24,32 +24,17 @@ Desc: Source code for timer functions such as, - - kwStartTmr - - kwStopTmr - - kwTmrExpiry - - kwBndTmrExpiry + - rlcStartTmr + - rlcStopTmr + - rlcTmrExpiry + - rlcBndTmrExpiry File: kw_tmr.c *********************************************************************21*/ -static const char* RLOG_MODULE_NAME="TMR"; -static int RLOG_MODULE_ID=2048; -static int RLOG_FILE_ID=202; - /* header (.h) include files */ -#include "envopt.h" /* environment options */ -#include "envdep.h" /* environment dependent */ -#include "envind.h" /* environment independent */ - -#include "gen.h" /* general */ -#include "ssi.h" /* system services */ -#include "cm5.h" /* common timer defines */ -#include "cm_tkns.h" /* common tokens defines */ -#include "cm_mblk.h" /* common memory allocation library defines */ -#include "cm_llist.h" /* common link list defines */ -#include "cm_hash.h" /* common hash list defines */ -#include "cm_lte.h" /* common LTE defines */ +#include "common_def.h" #include "lkw.h" /* LKW defines */ #include "ckw.h" /* CKW defines */ #include "kwu.h" /* KWU defines */ @@ -63,15 +48,6 @@ static int RLOG_FILE_ID=202; #include "kw_dl.h" /* extern (.x) include files */ -#include "gen.x" /* general */ -#include "ssi.x" /* system services */ -#include "cm5.x" /* common timer library */ -#include "cm_tkns.x" /* common tokens */ -#include "cm_mblk.x" /* common memory allocation */ -#include "cm_llist.x" /* common link list */ -#include "cm_hash.x" /* common hash list */ -#include "cm_lte.x" /* common LTE includes */ -#include "cm_lib.x" /* common memory allocation library */ #include "lkw.x" /* LKW */ #include "ckw.x" /* CKW */ #include "kwu.x" /* KWU */ @@ -88,7 +64,7 @@ static int RLOG_FILE_ID=202; */ /** - * @def KW_TMR_CALCUATE_WAIT + * @def RLC_TMR_CALCUATE_WAIT * * This macro calculates and assigns wait time based on the value of the * timer and the timer resolution. Timer value of 0 signifies that the @@ -100,7 +76,7 @@ static int RLOG_FILE_ID=202; * @param[in] _timerRes Resolution of the timer * */ -#define KW_TMR_CALCUATE_WAIT(_wait, _tmrVal, _timerRes) \ +#define RLC_TMR_CALCUATE_WAIT(_wait, _tmrVal, _timerRes) \ { \ (_wait) = ((_tmrVal) * SS_TICKS_SEC)/((_timerRes) * 1000); \ if((0 != (_tmrVal)) && (0 == (_wait))) \ @@ -110,7 +86,7 @@ static int RLOG_FILE_ID=202; } /* private function declarations */ -PRIVATE Void kwBndTmrExpiry(PTR cb); +PRIVATE Void rlcBndTmrExpiry(PTR cb); /** * @brief Handler to start timer @@ -122,112 +98,98 @@ PRIVATE Void kwBndTmrExpiry(PTR cb); * * @return Void */ -#ifdef ANSI -PUBLIC Void kwStartTmr -( -KwCb *gCb, -PTR cb, -S16 tmrEvnt -) -#else -PUBLIC Void kwStartTmr (gCb,cb, tmrEvnt) -KwCb *gCb; -PTR cb; -S16 tmrEvnt; -#endif +void rlcStartTmr(RlcCb *gCb, PTR cb, int16_t tmrEvnt) { /* kw005.201 added support for L2 Measurement */ #ifdef LTE_L2_MEAS - KwL2MeasEvtCb *measEvtCb = NULLP; + RlcL2MeasEvtCb *measEvtCb = NULLP; #endif CmTmrArg arg; arg.wait = 0; - TRC2(kwStartTmr) - /* kw002.201 Adjusting the wait time as per timeRes configured by layer manager */ switch (tmrEvnt) { - case KW_EVT_UMUL_REORD_TMR: + case RLC_EVT_UMUL_REORD_TMR: { - KwUmUl* umUl = &(((KwUlRbCb *)cb)->m.umUl); + RlcUmUl* umUl = &(((RlcUlRbCb *)cb)->m.umUl); /* kw005.201 Changed wait calculation ccpu00117634*/ - KW_TMR_CALCUATE_WAIT(arg.wait, umUl->reOrdTmrInt, gCb->genCfg.timeRes); + RLC_TMR_CALCUATE_WAIT(arg.wait, umUl->reOrdTmrInt, gCb->genCfg.timeRes); arg.timers = &umUl->reOrdTmr; - arg.max = KW_MAX_UM_TMR; + arg.max = RLC_MAX_UM_TMR; break; } - case KW_EVT_AMUL_REORD_TMR: + case RLC_EVT_AMUL_REORD_TMR: { - KwAmUl* amUl = &(((KwUlRbCb *)cb)->m.amUl); + RlcAmUl* amUl = &(((RlcUlRbCb *)cb)->m.amUl); /* kw005.201 Changed wait calculation ccpu00117634*/ - KW_TMR_CALCUATE_WAIT(arg.wait, amUl->reOrdTmrInt, gCb->genCfg.timeRes); + RLC_TMR_CALCUATE_WAIT(arg.wait, amUl->reOrdTmrInt, gCb->genCfg.timeRes); arg.timers = &amUl->reOrdTmr; - arg.max = KW_MAX_AM_TMR; + arg.max = RLC_MAX_AM_TMR; break; } - case KW_EVT_AMUL_STA_PROH_TMR: + case RLC_EVT_AMUL_STA_PROH_TMR: { - KwAmUl* amUl = &(((KwUlRbCb *)cb)->m.amUl); + RlcAmUl* amUl = &(((RlcUlRbCb *)cb)->m.amUl); /* kw005.201 Changed wait calculation ccpu00117634*/ - KW_TMR_CALCUATE_WAIT(arg.wait, + RLC_TMR_CALCUATE_WAIT(arg.wait, amUl->staProhTmrInt, gCb->genCfg.timeRes); arg.timers = &amUl->staProhTmr; - arg.max = KW_MAX_AM_TMR; + arg.max = RLC_MAX_AM_TMR; break; } - case KW_EVT_AMDL_POLL_RETX_TMR: + case RLC_EVT_AMDL_POLL_RETX_TMR: { - KwAmDl* amDl = &(((KwDlRbCb *)cb)->m.amDl); + RlcAmDl* amDl = &(((RlcDlRbCb *)cb)->m.amDl); /* kw005.201 Changed wait calculation ccpu00117634*/ - KW_TMR_CALCUATE_WAIT(arg.wait, + RLC_TMR_CALCUATE_WAIT(arg.wait, amDl->pollRetxTmrInt, gCb->genCfg.timeRes); arg.timers = &amDl->pollRetxTmr; - arg.max = KW_MAX_AM_TMR; + arg.max = RLC_MAX_AM_TMR; break; } - case KW_EVT_WAIT_BNDCFM: + case RLC_EVT_WAIT_BNDCFM: { - KwRguSapCb* rguSap = (KwRguSapCb *)cb; + RlcRguSapCb* rguSap = (RlcRguSapCb *)cb; /* kw005.201 Changed wait calculation ccpu00117634*/ - KW_TMR_CALCUATE_WAIT(arg.wait, rguSap->bndTmrInt, gCb->genCfg.timeRes); + RLC_TMR_CALCUATE_WAIT(arg.wait, rguSap->bndTmrInt, gCb->genCfg.timeRes); arg.timers = &rguSap->bndTmr; - arg.max = KW_MAX_RGUSAP_TMR; + arg.max = RLC_MAX_RGUSAP_TMR; break; } /* kw005.201 added support for L2 Measurement */ #ifdef LTE_L2_MEAS - case KW_EVT_L2_TMR: + case RLC_EVT_L2_TMR: { - measEvtCb = (KwL2MeasEvtCb *)cb; + measEvtCb = (RlcL2MeasEvtCb *)cb; /* kw005.201 Changed wait calculation ccpu00117634*/ - KW_TMR_CALCUATE_WAIT(arg.wait, + RLC_TMR_CALCUATE_WAIT(arg.wait, measEvtCb->l2TmrCfg.val, gCb->genCfg.timeRes); arg.timers = &measEvtCb->l2Tmr; - arg.max = KW_L2_MAX_TIMERS; + arg.max = RLC_L2_MAX_TIMERS; break; } #endif default: { - RLOG0(L_ERROR, "Invalid tmr Evnt"); + DU_LOG("\nRLC : rlcStartTmr: Invalid tmr Evnt [%d]", tmrEvnt); } } if(arg.wait != 0) { - arg.tqCp = &gCb->kwTqCp; - arg.tq = gCb->kwTq; + arg.tqCp = &gCb->rlcTqCp; + arg.tq = gCb->rlcTq; arg.cb = cb; arg.evnt = tmrEvnt; arg.tNum = 0; @@ -235,7 +197,7 @@ S16 tmrEvnt; cmPlcCbTq(&arg); } - RETVOID; + return; } /** @@ -248,80 +210,67 @@ S16 tmrEvnt; * * @return Void */ -#ifdef ANSI -PUBLIC Void kwStopTmr -( -KwCb *gCb, -PTR cb, -U8 tmrType -) -#else -PUBLIC Void kwStopTmr (gCb, cb, tmrType) -KwCb *gCb; -PTR cb; -U8 tmrType; -#endif +void rlcStopTmr(RlcCb *gCb, PTR cb, uint8_t tmrType) { CmTmrArg arg; /* kw005.201 added support for L2 Measurement */ #ifdef LTE_L2_MEAS - KwL2MeasEvtCb *measEvtCb = NULLP; + RlcL2MeasEvtCb *measEvtCb = NULLP; #endif - TRC2(kwStopTmr) arg.timers = NULLP; switch (tmrType) { - case KW_EVT_UMUL_REORD_TMR: + case RLC_EVT_UMUL_REORD_TMR: { - arg.timers = &((KwUlRbCb *)cb)->m.umUl.reOrdTmr; - arg.max = KW_MAX_UM_TMR; + arg.timers = &((RlcUlRbCb *)cb)->m.umUl.reOrdTmr; + arg.max = RLC_MAX_UM_TMR; break; } - case KW_EVT_AMUL_REORD_TMR: + case RLC_EVT_AMUL_REORD_TMR: { - arg.timers = &((KwUlRbCb *)cb)->m.amUl.reOrdTmr; - arg.max = KW_MAX_AM_TMR; + arg.timers = &((RlcUlRbCb *)cb)->m.amUl.reOrdTmr; + arg.max = RLC_MAX_AM_TMR; break; } - case KW_EVT_AMUL_STA_PROH_TMR: + case RLC_EVT_AMUL_STA_PROH_TMR: { - arg.timers = &((KwUlRbCb *)cb)->m.amUl.staProhTmr; - arg.max = KW_MAX_AM_TMR; + arg.timers = &((RlcUlRbCb *)cb)->m.amUl.staProhTmr; + arg.max = RLC_MAX_AM_TMR; break; } - case KW_EVT_AMDL_POLL_RETX_TMR: + case RLC_EVT_AMDL_POLL_RETX_TMR: { - arg.timers = &((KwDlRbCb *)cb)->m.amDl.pollRetxTmr; - arg.max = KW_MAX_AM_TMR; + arg.timers = &((RlcDlRbCb *)cb)->m.amDl.pollRetxTmr; + arg.max = RLC_MAX_AM_TMR; break; } - case KW_EVT_WAIT_BNDCFM: + case RLC_EVT_WAIT_BNDCFM: { - arg.timers = &((KwRguSapCb *)cb)->bndTmr; - arg.max = KW_MAX_RGUSAP_TMR; + arg.timers = &((RlcRguSapCb *)cb)->bndTmr; + arg.max = RLC_MAX_RGUSAP_TMR; break; } /* kw005.201 added support for L2 Measurement */ #ifdef LTE_L2_MEAS - case KW_EVT_L2_TMR: + case RLC_EVT_L2_TMR: { - measEvtCb = (KwL2MeasEvtCb *)cb; + measEvtCb = (RlcL2MeasEvtCb *)cb; arg.timers = &measEvtCb->l2Tmr; - arg.max = KW_L2_MAX_TIMERS; + arg.max = RLC_L2_MAX_TIMERS; break; } #endif default: { - RLOG0(L_ERROR, "Invalid tmr Evnt"); + DU_LOG("\nRLC : rlcStopTmr: Invalid tmr Evnt[%d]", tmrType); } } if (tmrType != TMR0) { - arg.tqCp = &gCb->kwTqCp; - arg.tq = gCb->kwTq; + arg.tqCp = &gCb->rlcTqCp; + arg.tq = gCb->rlcTq; arg.cb = cb; arg.evnt = tmrType; arg.wait = 0; @@ -329,7 +278,7 @@ U8 tmrType; cmRmvCbTq(&arg); } - RETVOID; + return; } /** @@ -346,55 +295,54 @@ U8 tmrType; * @return Void */ #ifdef ANSI -PUBLIC Void kwTmrExpiry +Void rlcTmrExpiry ( PTR cb, S16 tmrEvnt ) #else -PUBLIC Void kwTmrExpiry (cb, tmrEvnt) +Void rlcTmrExpiry (cb, tmrEvnt) PTR cb; S16 tmrEvnt; #endif { /* kw005.201 added support for L2 Measurement */ - TRC2(kwTmrExpiry) switch (tmrEvnt) { - case KW_EVT_UMUL_REORD_TMR: + case RLC_EVT_UMUL_REORD_TMR: { - KwUlRbCb *ulRbCb = (KwUlRbCb *)cb; - kwUmmReOrdTmrExp(KW_GET_KWCB(ulRbCb->inst), ulRbCb); + RlcUlRbCb *ulRbCb = (RlcUlRbCb *)cb; + rlcUmmReOrdTmrExp(RLC_GET_RLCCB(ulRbCb->inst), ulRbCb); break; } - case KW_EVT_AMUL_REORD_TMR: + case RLC_EVT_AMUL_REORD_TMR: { - KwUlRbCb *ulRbCb = (KwUlRbCb *)cb; - kwAmmReOrdTmrExp(KW_GET_KWCB(ulRbCb->inst), ulRbCb); + RlcUlRbCb *ulRbCb = (RlcUlRbCb *)cb; + rlcAmmReOrdTmrExp(RLC_GET_RLCCB(ulRbCb->inst), ulRbCb); break; } - case KW_EVT_AMUL_STA_PROH_TMR: + case RLC_EVT_AMUL_STA_PROH_TMR: { - KwUlRbCb *ulRbCb = (KwUlRbCb *)cb; - kwAmmStaProTmrExp(KW_GET_KWCB(ulRbCb->inst), ulRbCb); + RlcUlRbCb *ulRbCb = (RlcUlRbCb *)cb; + rlcAmmStaProTmrExp(RLC_GET_RLCCB(ulRbCb->inst), ulRbCb); break; } - case KW_EVT_AMDL_POLL_RETX_TMR: + case RLC_EVT_AMDL_POLL_RETX_TMR: { - KwDlRbCb *dlRbCb = (KwDlRbCb *)cb; - KwCb *gCb = KW_GET_KWCB(dlRbCb->inst); + RlcDlRbCb *dlRbCb = (RlcDlRbCb *)cb; + RlcCb *gCb = RLC_GET_RLCCB(dlRbCb->inst); - kwAmmPollRetxTmrExp(gCb, dlRbCb); + rlcAmmPollRetxTmrExp(gCb, dlRbCb); gCb->genSts.protTimeOut++; break; } - case KW_EVT_WAIT_BNDCFM: + case RLC_EVT_WAIT_BNDCFM: { - kwBndTmrExpiry(cb); + rlcBndTmrExpiry(cb); break; } /* kw005.201 L2 Measurement support */ @@ -404,7 +352,7 @@ S16 tmrEvnt; } } - RETVOID; + return; } /** @@ -419,55 +367,41 @@ S16 tmrEvnt; * -# ROK * -# RFAILED */ -#ifdef ANSI -PUBLIC Bool kwChkTmr -( -KwCb *gCb, -PTR cb, -S16 tmrEvnt -) -#else -PUBLIC Bool kwChkTmr(gCb,cb, tmrEvnt) -KwCb *gCb; -PTR cb; -S16 tmrEvnt; -#endif +bool rlcChkTmr(RlcCb *gCb, PTR cb, int16_t tmrEvnt) { - TRC2(kwChkTmr) - switch (tmrEvnt) { - case KW_EVT_UMUL_REORD_TMR: + case RLC_EVT_UMUL_REORD_TMR: { - return (((KwUlRbCb *)cb)->m.umUl.reOrdTmr.tmrEvnt == - KW_EVT_UMUL_REORD_TMR); + return (((RlcUlRbCb *)cb)->m.umUl.reOrdTmr.tmrEvnt == + RLC_EVT_UMUL_REORD_TMR); } - case KW_EVT_AMUL_REORD_TMR: + case RLC_EVT_AMUL_REORD_TMR: { - return (((KwUlRbCb *)cb)->m.amUl.reOrdTmr.tmrEvnt == - KW_EVT_AMUL_REORD_TMR); + return (((RlcUlRbCb *)cb)->m.amUl.reOrdTmr.tmrEvnt == + RLC_EVT_AMUL_REORD_TMR); } - case KW_EVT_AMUL_STA_PROH_TMR: + case RLC_EVT_AMUL_STA_PROH_TMR: { - return (((KwUlRbCb *)cb)->m.amUl.staProhTmr.tmrEvnt == - KW_EVT_AMUL_STA_PROH_TMR); + return (((RlcUlRbCb *)cb)->m.amUl.staProhTmr.tmrEvnt == + RLC_EVT_AMUL_STA_PROH_TMR); } - case KW_EVT_AMDL_POLL_RETX_TMR: + case RLC_EVT_AMDL_POLL_RETX_TMR: { - return (((KwDlRbCb *)cb)->m.amDl.pollRetxTmr.tmrEvnt == - KW_EVT_AMDL_POLL_RETX_TMR); + return (((RlcDlRbCb *)cb)->m.amDl.pollRetxTmr.tmrEvnt == + RLC_EVT_AMDL_POLL_RETX_TMR); } - case KW_EVT_WAIT_BNDCFM: + case RLC_EVT_WAIT_BNDCFM: { - return (((KwRguSapCb *)cb)->bndTmr.tmrEvnt == KW_EVT_WAIT_BNDCFM); + return (((RlcRguSapCb *)cb)->bndTmr.tmrEvnt == RLC_EVT_WAIT_BNDCFM); } default: { - RLOG0(L_ERROR, "Invalid tmr Evnt"); + DU_LOG("\nRLC : rlcChkTmr: Invalid tmr Evnt [%d]", tmrEvnt); } } - RETVALUE(FALSE); + return FALSE; } /** @@ -483,42 +417,40 @@ S16 tmrEvnt; * @return Void */ #ifdef ANSI -PRIVATE Void kwBndTmrExpiry +PRIVATE Void rlcBndTmrExpiry ( PTR cb ) #else -PRIVATE Void kwBndTmrExpiry(cb) +PRIVATE Void rlcBndTmrExpiry(cb) PTR cb; #endif { - KwRguSapCb *rguSapCb; - - TRC2(kwBndTmrExpiry) + RlcRguSapCb *rguSapCb; - rguSapCb = (KwRguSapCb *) cb; + rguSapCb = (RlcRguSapCb *) cb; - if (rguSapCb->state == KW_SAP_BINDING) + if (rguSapCb->state == RLC_SAP_BINDING) { - if (rguSapCb->retryCnt < KW_MAX_SAP_BND_RETRY) + if (rguSapCb->retryCnt < RLC_MAX_SAP_BND_RETRY) { /* start timer to wait for bind confirm */ - kwStartTmr(KW_GET_KWCB(rguSapCb->pst.srcInst), + rlcStartTmr(RLC_GET_RLCCB(rguSapCb->pst.srcInst), (PTR)rguSapCb, - KW_EVT_WAIT_BNDCFM); + RLC_EVT_WAIT_BNDCFM); /* Send bind request */ rguSapCb->retryCnt++; - KwLiRguBndReq (&rguSapCb->pst, rguSapCb->suId, rguSapCb->spId); + RlcLiRguBndReq (&rguSapCb->pst, rguSapCb->suId, rguSapCb->spId); } else { rguSapCb->retryCnt = 0; - rguSapCb->state = KW_SAP_CFG; + rguSapCb->state = RLC_SAP_CFG; /* Send alarm to the layer manager */ #ifdef LTE_L2_MEAS - kwLmmSendAlarm(KW_GET_KWCB(rguSapCb->pst.srcInst), + rlcLmmSendAlarm(RLC_GET_RLCCB(rguSapCb->pst.srcInst), LCM_CATEGORY_INTERFACE, LCM_EVENT_BND_FAIL, LCM_CAUSE_TMR_EXPIRED, @@ -526,7 +458,7 @@ PTR cb; 0, 0); #else - kwLmmSendAlarm(KW_GET_KWCB(rguSapCb->pst.srcInst), + rlcLmmSendAlarm(RLC_GET_RLCCB(rguSapCb->pst.srcInst), LCM_CATEGORY_INTERFACE, LCM_EVENT_BND_FAIL, LCM_CAUSE_TMR_EXPIRED, @@ -536,7 +468,7 @@ PTR cb; } } - RETVOID; + return; }