Merge "DL throughput calculation for UM [Issue-ID: ODUHIGH-319]"

[o-du/l2.git] / src / 5gnrrlc / kw_lmm.c

diff --git a/src/5gnrrlc/kw_lmm.c b/src/5gnrrlc/kw_lmm.c
index efae6b2..7031615 100755 (executable)
--- a/src/5gnrrlc/kw_lmm.c
+++ b/src/5gnrrlc/kw_lmm.c
@@ -18,7 +18,7 @@
 
 /********************************************************************20**
 
-        Name:    LTE - RLC - Layer Manager file
+        Name:    NR RLC - Layer Manager file
 
         Type:    C source file
 
@@ -38,9 +38,6 @@
         File:     kw_lmm.c
 
 *********************************************************************21*/
-static const char* RLOG_MODULE_NAME="LMM";
-static int RLOG_MODULE_ID=2048;
-static int RLOG_FILE_ID=197;
 /** @file kw_lmm.c
 @brief RLC Layer Manager Module
 **/
@@ -133,7 +130,7 @@ static S16 rlcLmmGenCfg(RlcCb  *gCb,RlcGenCfg *cfg)
    if(cfg->maxUe > RLC_MAX_UE) 
    {
 #if (ERRCLASS & ERRCLS_INT_PAR)
-      RLOG2(L_ERROR, "Invalid maxUe : Max [%lu] Received [%lu]", 
+      DU_LOG("\nERROR  --> RLC : Invalid maxUe : Max [%lu] Received [%lu]", 
             RLC_MAX_UE, 
             cfg->maxUe);
 #endif /* ERRCLASS & ERRCLS_INT_PAR */
@@ -143,7 +140,7 @@ static S16 rlcLmmGenCfg(RlcCb  *gCb,RlcGenCfg *cfg)
    if(cfg->maxKwuSaps > RLC_MAX_KWUSAPS)
    {
 #if (ERRCLASS & ERRCLS_INT_PAR)
-      RLOG2(L_ERROR, "Invalid maxKwuSaps : Max [%lu] Received [%lu]", 
+      DU_LOG("\nERROR  --> RLC : Invalid maxKwuSaps : Max [%lu] Received [%lu]", 
             RLC_MAX_KWUSAPS, 
             cfg->maxKwuSaps);
 #endif /* ERRCLASS & ERRCLS_INT_PAR */
@@ -153,7 +150,7 @@ static S16 rlcLmmGenCfg(RlcCb  *gCb,RlcGenCfg *cfg)
    if(cfg->maxUdxSaps > RLC_MAX_UDXSAPS)
    {
 #if (ERRCLASS & ERRCLS_INT_PAR)
-      RLOG2(L_ERROR, "Invalid maxUduSaps : Max [%lu] Received [%lu]", 
+      DU_LOG("\nERROR  --> RLC : Invalid maxUduSaps : Max [%lu] Received [%lu]", 
             RLC_MAX_UDXSAPS, 
             cfg->maxUdxSaps);
 #endif /* ERRCLASS & ERRCLS_INT_PAR */
@@ -189,7 +186,7 @@ static S16 rlcLmmGenCfg(RlcCb  *gCb,RlcGenCfg *cfg)
       RLC_ALLOC(gCb,gCb->u.dlCb, sizeof (RlcDlCb));
       if (gCb->u.dlCb == NULLP)
       {  
-         RLOG0(L_FATAL,"Memory Allocation failed");   
+         DU_LOG("\nERROR  --> RLC : Memory Allocation failed");   
          return (LCM_REASON_MEM_NOAVAIL);
       
       }
@@ -203,7 +200,7 @@ static S16 rlcLmmGenCfg(RlcCb  *gCb,RlcGenCfg *cfg)
       if(gCb->u.dlCb->rlcKwuDlSap == NULLP)
       {
          RLC_FREE(gCb,gCb->u.dlCb, sizeof (RlcDlCb));
-         RLOG0(L_FATAL,"Memory Allocation failed");   
+         DU_LOG("\nERROR  --> RLC : Memory Allocation failed");   
          return (LCM_REASON_MEM_NOAVAIL);
       }
 #endif /* ERRCLASS & ERRCLS_INT_PAR */
@@ -219,7 +216,7 @@ static S16 rlcLmmGenCfg(RlcCb  *gCb,RlcGenCfg *cfg)
       {
          RLC_FREE(gCb,gCb->u.dlCb->rlcKwuDlSap, rlcSapSize);
          RLC_FREE(gCb,gCb->u.dlCb, sizeof (RlcDlCb));
-         RLOG0(L_FATAL,"Memory Allocation failed");   
+         DU_LOG("\nERROR  --> RLC : Memory Allocation failed");   
          return (LCM_REASON_MEM_NOAVAIL);
       }
 #endif /* ERRCLASS & ERRCLS_INT_PAR */
@@ -249,7 +246,7 @@ static S16 rlcLmmGenCfg(RlcCb  *gCb,RlcGenCfg *cfg)
          RLC_FREE(gCb,gCb->u.dlCb->rlcKwuDlSap, rlcSapSize);
          RLC_FREE(gCb,gCb->u.dlCb->rguDlSap, rguSapSize);
          RLC_FREE(gCb,gCb->u.dlCb, sizeof (RlcDlCb));
-         RLOG0(L_FATAL,"RLC DL Initialization failed");   
+         DU_LOG("\nERROR  --> RLC_DL : RLC DL Initialization failed");   
          return (LCM_REASON_MEM_NOAVAIL);
       }
 
@@ -290,7 +287,7 @@ static S16 rlcLmmGenCfg(RlcCb  *gCb,RlcGenCfg *cfg)
       RLC_ALLOC(gCb,gCb->u.ulCb, sizeof (RlcUlCb));
       if (gCb->u.ulCb == NULLP)
       {     
-         RLOG0(L_FATAL,"Memory Allocation failed");   
+         DU_LOG("\nERROR  --> RLC : Memory Allocation failed");   
          return (LCM_REASON_MEM_NOAVAIL);
       
       }
@@ -304,7 +301,7 @@ static S16 rlcLmmGenCfg(RlcCb  *gCb,RlcGenCfg *cfg)
       if(gCb->u.ulCb->rlcKwuUlSap == NULLP)
       {
          RLC_FREE(gCb,gCb->u.ulCb, sizeof (RlcUlCb));
-         RLOG0(L_FATAL,"Memory Allocation failed");   
+         DU_LOG("\nERROR  --> RLC : Memory Allocation failed");   
          return (LCM_REASON_MEM_NOAVAIL);
       }
 #endif /* ERRCLASS & ERRCLS_INT_PAR */
@@ -322,7 +319,7 @@ static S16 rlcLmmGenCfg(RlcCb  *gCb,RlcGenCfg *cfg)
       {
          RLC_FREE(gCb,gCb->u.ulCb->rlcKwuUlSap, rlcSapSize);
          RLC_FREE(gCb,gCb->u.ulCb, sizeof (RlcUlCb));
-         RLOG0(L_FATAL,"Memory Allocation failed");   
+         DU_LOG("\nERROR  --> RLC : Memory Allocation failed");   
          return (LCM_REASON_MEM_NOAVAIL);
       }
 #endif /* ERRCLASS & ERRCLS_INT_PAR */
@@ -351,7 +348,7 @@ static S16 rlcLmmGenCfg(RlcCb  *gCb,RlcGenCfg *cfg)
          RLC_FREE(gCb,gCb->u.ulCb->rlcKwuUlSap, rlcSapSize);
          RLC_FREE(gCb,gCb->u.ulCb->rguUlSap, rlcSapSize);
          RLC_FREE(gCb,gCb->u.ulCb, sizeof (RlcUlCb));
-         RLOG0(L_FATAL,"RLC DL Initialization failed");   
+         DU_LOG("\nERROR  --> RLC_DL : RLC DL Initialization failed");   
       }
 
       /* Register the timer */
@@ -373,7 +370,7 @@ static S16 rlcLmmGenCfg(RlcCb  *gCb,RlcGenCfg *cfg)
    else
    {
 #if (ERRCLASS & ERRCLS_INT_PAR)
-      RLOG0(L_ERROR, "Received Invalid RLC Mode");
+      DU_LOG("\nERROR  --> RLC : Received Invalid RLC Mode");
 #endif /* ERRCLASS & ERRCLS_INT_PAR */
 
       return (LCM_REASON_INVALID_PAR_VAL);
@@ -476,7 +473,7 @@ Header     *hdr
          break;
       default:
 #if (ERRCLASS & ERRCLS_INT_PAR)
-         RLOG0(L_ERROR, "Received Invalid Message Type");
+         DU_LOG("\nERROR  --> RLC : Received Invalid Message Type");
          if(!gCb)
          {
             fflush(stdout);
@@ -585,7 +582,7 @@ uint8_t RlcMiRlcConfigReq (Pst *pst,RlcMngmt *cfg)
       return (RFAILED);
    }
 
-   RLOG1(L_DEBUG, "RlcMiRlcConfigReq elmId(%d)", cfg->hdr.elmId.elmnt);
+   DU_LOG("\nDEBUG  --> RLC : RlcMiRlcConfigReq elmId(%d)", cfg->hdr.elmId.elmnt);
 
    switch(cfg->hdr.elmId.elmnt)
    {
@@ -723,7 +720,7 @@ uint8_t RlcMiLkwCntrlReq(Pst *pst, RlcMngmt *cntrl)
       rlcLmmSendCfm(tRlcCb,pst, cntrl, TCNTRL, &cntrl->hdr);
       return (RFAILED);
    }
-   RLOG1(L_DEBUG, "RlcMiLkwCntrlReq(elmId(%d))", cntrl->hdr.elmId.elmnt);
+   DU_LOG("\nDEBUG  --> RLC : RlcMiLkwCntrlReq(elmId(%d))", cntrl->hdr.elmId.elmnt);
 
    /* In normal cases, LCM_REASON_NOT_APPL is returned in cfm.
     * In all error cases appropriate reason is returned
@@ -813,7 +810,7 @@ S16 RlcMiLkwStaReq(Pst *pst,RlcMngmt *sta)
       return (RFAILED);
    }
 
-   RLOG1(L_DEBUG, "Status request for elmId(%d))", sta->hdr.elmId.elmnt);
+   DU_LOG("\nDEBUG  --> RLC : Status request for elmId(%d))", sta->hdr.elmId.elmnt);
 
    reason = LCM_REASON_NOT_APPL;
 
@@ -935,7 +932,7 @@ S16 RlcMiLkwStsReq (Pst *pst, Action action,RlcMngmt *sts)
       return (RFAILED);
    }
 
-   RLOG2(L_DEBUG, "RlcMiLkwStsReq(elmId(%d),action(%d))", 
+   DU_LOG("\nDEBUG  --> RLC : RlcMiLkwStsReq(elmId(%d),action(%d))", 
                        action, 
                        sts->hdr.elmId.elmnt);
 
@@ -1089,7 +1086,7 @@ S16 RlcMiLkwL2MeasReq(Pst *pst, RlcL2MeasReqEvt *measReqEvt)
 #if (ERRCLASS & ERRCLS_ADD_RES) /* KW_FIX */ 
       if(measEvt == NULLP)
       {
-         RLOG0(L_FATAL,"Memory Allocation failed");   
+         DU_LOG("\nERROR  --> RLC : Memory Allocation failed");   
          return RFAILED;
       }   
 #endif      
@@ -1252,7 +1249,7 @@ static S16 rlcLmmCfgKwuSap(RlcCb *gCb,RlcSapCfg *cfg)
    /* Check for reconfiguration */
    if (rlcKwuSapCb->state != RLC_SAP_NOT_CFG)
    {
-      RLOG2(L_ERROR,"RLC Mode [%d] : Invalid rlckwuSap State [%d]",
+      DU_LOG("\nERROR  --> RLC : RLC Mode [%d] : Invalid rlckwuSap State [%d]",
             gCb->genCfg.rlcMode, rlcKwuSapCb->state);
       /* reconfiguration not allowed */
       return (LCM_REASON_RECONFIG_FAIL);
@@ -1302,7 +1299,7 @@ static S16 rlcLmmCfgCkwSap(RlcCb  *gCb,RlcSapCfg *cfg)
    /* Check for reconfiguration */
    if(ckwSap->state  != RLC_SAP_NOT_CFG)
    {
-      RLOG1(L_ERROR,"Invalid rlckwuSap State [%d]",ckwSap->state);
+      DU_LOG("\nERROR  --> RLC : Invalid rlckwuSap State [%d]",ckwSap->state);
       return (LCM_REASON_RECONFIG_FAIL);
    }
 #endif /* ERRCLASS & ERRCLS_INT_PAR */
@@ -1346,7 +1343,7 @@ static S16 rlcLmmCfgUdxSap(RlcCb *gCb,RlcSapCfg *cfg)
       /* Check for reconfiguration */
       if(udxDlSap->state != RLC_SAP_NOT_CFG)
       {
-         RLOG1(L_ERROR,"Invalid udxDlSap State [%d]",udxDlSap->state);
+         DU_LOG("\nERROR  --> RLC : Invalid udxDlSap State [%d]",udxDlSap->state);
          return (LCM_REASON_RECONFIG_FAIL);
       }
 #endif /* ERRCLASS & ERRCLS_INT_PAR */
@@ -1362,7 +1359,7 @@ static S16 rlcLmmCfgUdxSap(RlcCb *gCb,RlcSapCfg *cfg)
    /* Check for reconfiguration */
       if(udxUlSap->state != RLC_SAP_NOT_CFG)
       {
-         RLOG1(L_ERROR,"Invalid udxUlSap State [%d]", udxUlSap->state);
+         DU_LOG("\nERROR  --> RLC : Invalid udxUlSap State [%d]", udxUlSap->state);
          return (LCM_REASON_RECONFIG_FAIL);
       }
 #endif /* ERRCLASS & ERRCLS_INT_PAR */
@@ -1412,7 +1409,7 @@ static S16 rlcLmmCfgRguSap(RlcCb *gCb,RlcSapCfg *cfg)
    /* Check for reconfiguration */
    if(rguSap->state != RLC_SAP_NOT_CFG)
    {
-      RLOG2(L_ERROR,"RLC Mode [%d]: Invalid rguSap State [%d]",
+      DU_LOG("\nERROR  --> RLC : RLC Mode [%d]: Invalid rguSap State [%d]",
             gCb->genCfg.rlcMode, rguSap->state);
       return (LCM_REASON_RECONFIG_FAIL);
    }
@@ -1749,7 +1746,7 @@ static S16 rlcLmmUdxSapCntrl(RlcCb *gCb,RlcMngmt *cntrl)
    /* validate SAP */
    if(UDX_SAP.state == RLC_SAP_NOT_CFG)
    {
-      RLOG0(L_ERROR,"udxUlSap not configured yet");
+      DU_LOG("\nERROR  --> RLC : udxUlSap not configured yet");
       return (LCM_REASON_INVALID_STATE);
    }
 #endif /* ERRCLASS & ERRCLS_INT_PAR */
@@ -1821,7 +1818,7 @@ static S16 rlcLmmLSapCntrl(RlcCb *gCb,RlcMngmt *cntrl)
    /* validate SAP */
    if(rguSap->state == RLC_SAP_NOT_CFG)
    {
-      RLOG1(L_ERROR,"RLC Mode [%d]:rguSap not configured yet", gCb->genCfg.rlcMode);
+      DU_LOG("\nERROR  --> RLC : RLC Mode [%d]:rguSap not configured yet", gCb->genCfg.rlcMode);
       return (LCM_REASON_INVALID_STATE);
    }
 #endif /* ERRCLASS & ERRCLS_INT_PAR */
@@ -2147,7 +2144,7 @@ S16 rlcLmmSendTrc(RlcCb *gCb,Event event,Buffer *mBuf)
    MsgLen    tempCnt;
    Pst       pst;
 
-   RLOG2(L_DEBUG, "rlcLmmSendTrc(): Trace for event=%d, gCb->trcLen=%d",
+   DU_LOG("\nDEBUG  --> RLC : rlcLmmSendTrc(): Trace for event=%d, gCb->trcLen=%d",
                      event,
                      gCb->trcLen);
 
@@ -2169,7 +2166,7 @@ S16 rlcLmmSendTrc(RlcCb *gCb,Event event,Buffer *mBuf)
             != ROK)
         {
            /* rg005.201 removed SPutSBuf on error */
-           RLOG0(L_ERROR,"SCpyMsgMsg Failed");   
+           DU_LOG("\nERROR  --> RLC : SCpyMsgMsg Failed");   
            return RFAILED;
         }
         /* Send Trace Indication to Layer manager */
@@ -2181,7 +2178,7 @@ S16 rlcLmmSendTrc(RlcCb *gCb,Event event,Buffer *mBuf)
         /* Get the length of the recvd message buffer */
         if (SFndLenMsg(mBuf, &bufLen) != ROK)
         {
-           RLOG0(L_ERROR,"SFndLenMsg Failed");   
+           DU_LOG("\nERROR  --> RLC : SFndLenMsg Failed");   
            return RFAILED;
         }
         /* Check if the recvd buffer size is less than request trace len */
@@ -2192,7 +2189,7 @@ S16 rlcLmmSendTrc(RlcCb *gCb,Event event,Buffer *mBuf)
            if (SCpyMsgMsg(mBuf, pst.region, pst.pool, &dstMbuf)
               != ROK)
            {
-              RLOG0(L_ERROR,"SCpyMsgMsg Failed");   
+              DU_LOG("\nERROR  --> RLC : SCpyMsgMsg Failed");   
               return RFAILED;
            }
          
@@ -2210,7 +2207,7 @@ S16 rlcLmmSendTrc(RlcCb *gCb,Event event,Buffer *mBuf)
            {
               (Void) SPutSMem(RLC_GET_MEM_REGION(gCb), RLC_GET_MEM_POOL(gCb));
       
-               RLOG0(L_FATAL,"Memory Allocation failed");   
+               DU_LOG("\nERROR  --> RLC : Memory Allocation failed");   
                return (LCM_REASON_MEM_NOAVAIL);
            }
 #endif /* ERRCLASS & ERRCLS_INT_PAR */
@@ -2218,19 +2215,19 @@ S16 rlcLmmSendTrc(RlcCb *gCb,Event event,Buffer *mBuf)
            /* Copy trcLen nos of bytes from the recvd message */
            if (SCpyMsgFix(mBuf,0,gCb->trcLen,tempBuf,&tempCnt) != ROK)   
            {
-              RLOG0(L_ERROR,"SCpyMsgFix Failed");   
+              DU_LOG("\nERROR  --> RLC : SCpyMsgFix Failed");   
               return RFAILED;
            }
 
            if (SGetMsg(pst.region, pst.pool, &dstMbuf) != ROK)
            {
-              RLOG0(L_FATAL,"Memory Allocation failed");   
+              DU_LOG("\nERROR  --> RLC : Memory Allocation failed");   
               return RFAILED;
            }
            /* Copy the tempBuf data to dst mBuf */
            if (SCpyFixMsg(tempBuf,dstMbuf,0,gCb->trcLen,&tempCnt) != ROK)
            {
-              RLOG0(L_ERROR,"SCpyMsgFix Failed");   
+              DU_LOG("\nERROR  --> RLC : SCpyMsgFix Failed");   
               return RFAILED;
            }