Merge "[Epic-ID: ODUHIGH-516][Task-ID: ODUHIGH-534] Handling of reset req and Impleme...

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

diff --git a/src/5gnrrlc/rlc_dl_msg_router.c b/src/5gnrrlc/rlc_dl_msg_router.c
index 258e2e6..595d996 100755 (executable)
--- a/src/5gnrrlc/rlc_dl_msg_router.c
+++ b/src/5gnrrlc/rlc_dl_msg_router.c
@@ -188,6 +188,189 @@ Reason reason               /* reason */
    return ROK;
 } /* kwActvInit */
 
+#ifdef CALL_FLOW_DEBUG_LOG
+/*
+*
+* @brief
+*
+* Function:
+*   name : callFlowRlcDlActvTsk
+*
+*  @b Description:
+*  Function used to print values of src, dest, message 
+*  received at the layer
+*
+*  @param[in] pst   - Pst Structure
+*
+*  @return void  
+*/
+void callFlowRlcDlActvTsk(Pst *pst)
+{
+   char sourceTask[50];
+   char destTask[50]="ENTMAC";
+   char message[100];
+   switch(pst->srcEnt)
+   {
+      case ENTDUAPP:
+         {
+            strcpy(sourceTask,"ENTDUAPP");
+            switch(pst->event)
+            {
+#ifdef LCLKW
+               case LKW_EVT_CFG_REQ:
+                  {
+                     strcpy(message,"LKW_EVT_CFG_REQ");
+                     break;
+                  }
+
+               case LKW_EVT_CNTRL_REQ:
+                  {
+                     strcpy(message,"LKW_EVT_CNTRL_REQ");
+                     break;
+                  }
+
+               case LKW_EVT_STS_REQ:
+                  {
+                     strcpy(message,"LKW_EVT_STS_REQ");
+                     break;
+                  }
+
+               case LKW_EVT_STA_REQ:
+                  {
+                     strcpy(message,"LKW_EVT_STA_REQ");
+                     break;
+                  }
+                  /* kw005.201 added support for L2 Measurement */
+#endif  /* LCLKW */
+
+#ifdef LCKWU
+               case KWU_EVT_DAT_REQ:              /* Data request */
+                  {
+                     strcpy(message,"KWU_EVT_DAT_REQ");
+                     break;
+                  }
+#endif /* LCKWU */
+
+               case EVENT_DL_RRC_MSG_TRANS_TO_RLC:
+                  {
+                     strcpy(message,"EVENT_DL_RRC_MSG_TRANS_TO_RLC");
+                     break;
+                  }
+               case EVENT_DL_USER_DATA_TRANS_TO_RLC:
+                  {
+                     strcpy(message,"EVENT_DL_USER_DATA_TRANS_TO_RLC");
+                     break;
+                  }
+               default:
+                  strcpy(message,"Invalid Event");
+                  break;
+            }
+            break;
+         }
+
+      case ENTRLC:
+         {
+
+            strcpy(sourceTask,"ENTRLC");
+            switch(pst->event)
+            {
+#ifdef LCUDX
+               case UDX_EVT_BND_REQ:              /* Bind request */
+                  {
+                     strcpy(message,"UDX_EVT_BND_REQ");
+                     break;
+                  }
+
+               case UDX_EVT_UBND_REQ:              /* Bind request */
+                  {
+                     strcpy(message,"UDX_EVT_UBND_REQ");
+                     break;
+                  }
+               case UDX_EVT_CFG_REQ:             /* Unbind request */
+                  {
+                     strcpy(message,"UDX_EVT_CFG_REQ");
+                     break;
+                  }
+
+               case UDX_EVT_UEIDCHG_REQ:              /* Configuration request */
+                  {
+                     strcpy(message,"UDX_EVT_UEIDCHG_REQ");
+                     break;
+                  }
+
+               case UDX_EVT_STA_UPD_REQ:              /* Configuration request */
+                  {
+                     strcpy(message,"UDX_EVT_STA_UPD_REQ");
+                     break;
+                  }
+
+               case UDX_EVT_STA_PDU_REQ:              /* Configuration request */
+                  {
+                     strcpy(message,"UDX_EVT_STA_PDU_REQ");
+                     break;
+                  }
+
+#endif  /* LCCKW */
+               case UDX_EVT_DL_CLEANUP_MEM:
+                  {
+                  strcpy(message,"UDX_EVT_DL_CLEANUP_MEM");
+                     break;
+                  }
+               
+               default:
+                  strcpy(message,"Invalid Event");
+                  break;
+
+            }
+            break;
+         }
+
+      case ENTMAC:
+         {
+            strcpy(sourceTask,"ENTMAC");
+            switch(pst->event)
+            {
+#ifdef LCRGU
+               case EVTRGUBNDCFM:     /* Bind request */
+                  {
+                     strcpy(message,"EVTRGUBNDCFM");
+                     break;
+                  }
+               case EVENT_SCHED_RESULT_TO_RLC: 
+                  {
+                     strcpy(message,"EVENT_SCHED_RESULT_TO_RLC");
+                     break;
+                  }
+                  /* kw005.201 added support for L2 Measurement */
+               case EVTRGUFLOWCNTRLIND:
+                  {
+                     strcpy(message,"EVTRGUFLOWCNTRLIND");
+                     break;
+                  }   
+#endif  /* LCRGU */
+#ifdef RLC_STA_PROC_IN_MAC/* RLC Status PDU Processing */
+               case UDX_EVT_STA_UPD_REQ:              /* Configuration request */
+                  {
+                     strcpy(message,"UDX_EVT_STA_UPD_REQ");
+                     break;
+                  }
+#endif
+               default:
+                  strcpy(message,"Invalid Event");
+                  break;
+
+            }
+            break;
+         }
+      default:
+         {
+            strcpy(sourceTask,"Invalid Source Entity Id");
+         }
+    }
+   DU_LOG("\nCall Flow: %s -> %s : %s\n", sourceTask, destTask, message);
+}
+#endif
+
 \f
 /**
  *
@@ -221,6 +404,10 @@ Buffer *mBuf            /* message buffer */
    gRlcTId = pthread_self();
 #endif
 
+#ifdef CALL_FLOW_DEBUG_LOG
+   callFlowRlcDlActvTsk(pst);
+#endif
+
    switch(pst->srcEnt)
    {
       case ENTDUAPP: