X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=src%2Fdu_app%2Fdu_mgr_ex_ms.c;h=44a83ccfc3e9c796ee186678156e5e0408e2488e;hb=refs%2Fchanges%2F28%2F1828%2F1;hp=6635832839716bd6dbf40fa1e82ae7e018d3c47a;hpb=829bbd114f1c3dc00c1da47bca0a8207c049df3f;p=o-du%2Fl2.git

diff --git a/src/du_app/du_mgr_ex_ms.c b/src/du_app/du_mgr_ex_ms.c
index 663583283..44a83ccfc 100644
--- a/src/du_app/du_mgr_ex_ms.c
+++ b/src/du_app/du_mgr_ex_ms.c
@@ -18,7 +18,12 @@
 
 /* This file contains message handling functionality for DU cell management */
 
-#include "du_mgr.h"
+#include "du_sctp.h"
+#include "f1ap_msg_hdl.h"
+
+extern S16 cmUnpkLkwCfgCfm(LkwCfgCfm func,Pst *pst, Buffer *mBuf);
+extern S16 cmUnpkLkwCntrlCfm(LkwCntrlCfm func,Pst *pst, Buffer *mBuf);
+extern S16 cmUnpkLrgCfgCfm(LrgCfgCfm func,Pst *pst, Buffer *mBuf);
 
 /**************************************************************************
  * @brief Task Initiation callback function. 
@@ -42,7 +47,24 @@
  ***************************************************************************/
 S16 duActvInit(Ent entity, Inst inst, Region region, Reason reason)
 {
-//TODO: TBD
+   duCb.init.procId  = SFndProcId();
+   duCb.init.ent     = entity;
+   duCb.init.inst    = inst;
+   duCb.init.region  = region;
+   duCb.init.reason  = reason;
+   duCb.init.cfgDone = FALSE;
+   duCb.init.pool    = DU_POOL;
+   duCb.init.acnt    = FALSE;
+   duCb.init.trc     = FALSE;
+   duCb.init.usta    = TRUE;
+   duCb.mem.region   = DFLT_REGION;
+   duCb.mem.pool     = DU_POOL;
+
+   duCb.sctpStatus   = FALSE;
+   duCb.f1Status     = FALSE;
+   duCb.duStatus     = FALSE;
+
+   SSetProcId(DU_PROC);
 
    return ROK;
 
@@ -80,7 +102,7 @@ S16 duActvTsk(Pst *pst, Buffer *mBuf)
             {
                case EVTCFG:
                   {
-                     duProcCfgComplete();
+                     duSendRlcUlCfg();
                      SPutMsg(mBuf);
                      break;
                   }
@@ -94,22 +116,53 @@ S16 duActvTsk(Pst *pst, Buffer *mBuf)
 
             break;
          }
-      case ENTF1AP:
+      case ENTKW:
          {
-
+            switch(pst->event)
+            {
+               case LKW_EVT_CFG_CFM:
+                  {
+                     ret = cmUnpkLkwCfgCfm(duHdlRlcCfgComplete, pst, mBuf);
+                     break;
+                  }
+               case LKW_EVT_CNTRL_CFM:
+                  {
+                     ret = cmUnpkLkwCntrlCfm(duHdlRlcCntrlCfgComplete, pst, mBuf);
+                     break;
+                  }
+               case LKW_EVT_STA_IND:
+                  {
+                     break;
+                  }
+               default:
+                  {
+                     printf("\nInvalid event %d received at duActvTsk from ENTKW", \
+                           pst->event);
+                     SPutMsg(mBuf);
+                     ret = RFAILED;
+                  }
+            }
             break;
          }
-      case ENTRG: //TODO: Layer cfg for RLC UL, DL and MAC must be done
+      case ENTRG:
          {
             switch(pst->event)
             {
                //Config complete
                case EVTCFG:
                   {
-                     //TODO: Implement duEstablishSctpToCu();
                      SPutMsg(mBuf);
                      break;
                   }
+               case EVTLRGCFGCFM:
+                  {
+                     ret = cmUnpkLrgCfgCfm(duHdlMacCfgComplete, pst, mBuf);
+                     break;
+                  }
+               case EVTLRGCNTRLCFM:
+                  {
+                     break;
+                  }
                default:
                   {
                      printf("\nInvalid event received at duActvTsk from ENTRG");
@@ -124,20 +177,25 @@ S16 duActvTsk(Pst *pst, Buffer *mBuf)
          {
             switch(pst->event)
             {
-               case EVTSCTPUP:
+               case EVTSCTPDATA:
+               {
+                  F1InmsgHdlr(mBuf);
+                  break;
+               }
+               case EVTSCTPNTFY:
                   {
-                     //Setup F1-C
-                     SPutMsg(mBuf);
+                     ret = cmUnpkSctpNtfy(duSctpNtfyHdl, pst, mBuf);
                      break;
                   }
                default:
                   {
                      printf("\nInvalid event received at duActvTsk from ENTRG");
-                     SPutMsg(mBuf);
                      ret = RFAILED;
                   }
 
             }
+            SPutMsg(mBuf);
+            break;
          }
       default:
          {
@@ -147,35 +205,10 @@ S16 duActvTsk(Pst *pst, Buffer *mBuf)
          }
 
    }
-
    SExitTsk();
    return ret;
 }
 
-/**************************************************************************
- * @brief Function to invoke DU Layer Configs
- *
- * @details
- *
- *      Function : duProcCfgComplete 
- * 
- *      Functionality:
- *           Initiates Configs towards layers of DU
- *     
- * @param[in]  void
- * @return ROK     - success
- *         RFAILED - failure
- *
- ***************************************************************************/
-S16 duProcCfgComplete()
-{
-//TBD: invoke SCTP/layer config
-
-//   duHdlRlcUlCfgEvent();
-
-   return ROK;
-}
-
 /**********************************************************************
          End of file
 **********************************************************************/