<[Epic-ID: ODUHIGH-406][Task-ID: ODUHIGH-421]Paging Message: CU_STUB Trigger and...

[o-du/l2.git] / src / cu_stub / cu_stub.c

diff --git a/src/cu_stub/cu_stub.c b/src/cu_stub/cu_stub.c
index 11b7a4e..1a7fe9c 100644 (file)
--- a/src/cu_stub/cu_stub.c
+++ b/src/cu_stub/cu_stub.c
@@ -33,60 +33,6 @@
 extern StartupConfig g_cfg;
 #endif
 
-/*******************************************************************
- *
- * @brief Fetches pointer to DU Database
- *
- * @details
- *
- *    Function : getDuDb
- *
- *    Functionality:
- *      Searches and returns pointer to DU structure based on DU Id
- *
- * @params[in] DU Id
- * @return Pointer to DU Db
- *
- ******************************************************************/
-DuDb* getDuDb(uint32_t duId)
-{
-   uint8_t duIdx;
-   for(duIdx=0; duIdx < cuCb.numDu; duIdx++)
-   {
-      if(cuCb.duInfo[duIdx].duId == duId)
-         return (&cuCb.duInfo[duIdx]);
-   }
-   return NULLP;
-}
-
-/*******************************************************************
- *
- * @brief Fetches pointer to Cell Cb
- *
- * @details
- *
- *    Function : getCellCb
- *
- *    Functionality:
- *       Searches for a cell within a DU based on NR cell Id
- *       Returns pointer to this cell Cb structure
- *
- * @params[in] Pointer to DU Db
- *             NR Cell ID
- * @return Pointer to cell Cb
- *
- ******************************************************************/
-CuCellCb* getCellCb(DuDb *duDb, uint32_t cellId)
-{
-   uint8_t cellIdx;
-   for(cellIdx=0; cellIdx < duDb->numCells; cellIdx++)
-   {
-      if(duDb->cellCb[cellIdx].nrCellId == cellId)
-         return &(duDb->cellCb[cellIdx]);
-   }
-   return NULLP;
-}
-
 /*******************************************************************
  *
  * @brief Handles SCTP notification 
@@ -204,10 +150,16 @@ void readCuCfg()
    }
    
    cmInetAddr((S8*)g_cfg.DU_IPV4_Addr, &ipv4_du);
+   cuCb.cuCfgParams.sctpParams.sctpAssoc[0].duIpAddr.ipV4Addr = ipv4_du;
+   cuCb.cuCfgParams.sctpParams.sctpAssoc[0].duIpAddr.ipV6Pres = false;
+   
    cmInetAddr((S8*)g_cfg.CU_IPV4_Addr, &ipv4_cu);
-
-   cuCb.cuCfgParams.sctpParams.duPort = g_cfg.DU_Port;
-   cuCb.cuCfgParams.sctpParams.cuPort = g_cfg.CU_Port;
+   cuCb.cuCfgParams.sctpParams.sctpAssoc[0].cuIpAddr.ipV4Addr = ipv4_cu;
+   cuCb.cuCfgParams.sctpParams.sctpAssoc[0].cuIpAddr.ipV6Pres = false;
+   
+   cuCb.cuCfgParams.sctpParams.sctpAssoc[0].duPort = g_cfg.DU_Port;
+   cuCb.cuCfgParams.sctpParams.sctpAssoc[0].cuPort = g_cfg.CU_Port; 
+   cuCb.cuCfgParams.sctpParams.numDu = 1;
 #else
    cuCb.cuCfgParams.sctpParams.numDu = 0;
    numDu = &cuCb.cuCfgParams.sctpParams.numDu;
@@ -257,6 +209,45 @@ void readCuCfg()
 
 } /* End of readCuCfg */
 
+/*******************************************************************
+ *
+ * @brief Initiates inter DU handover
+ *
+ * @details
+ *
+ *    Function : initiateInterDuHandover
+ *
+ *    Functionality: Initiates the first procedure of inter-DU
+ *    handover i.eG GNB-DU configuration query to source DU
+ *
+ * @params[in] Source DU Id
+ *             Target DU Id
+ *             UE Id to be handed off 
+ * @return ROK     - success
+ *         RFAILED - failure
+ *
+ * ****************************************************************/
+void initiateInterDuHandover(uint32_t sourceDuId, uint32_t targetDuId, uint32_t ueId)
+{
+    uint8_t duIdx = 0;
+    DuDb *duDb = NULLP;
+    CuUeCb *ueCb = NULLP;
+   
+    SEARCH_DU_DB(duIdx, sourceDuId, duDb); 
+    if(duDb)
+       ueCb = &duDb->ueCb[ueId-1];
+    if(ueCb)
+    {
+       ueCb->state = UE_HANDOVER_IN_PROGRESS;
+       ueCb->hoInfo.sourceDuId = sourceDuId;
+       ueCb->hoInfo.targetDuId = targetDuId;
+    }
+
+    DU_LOG("\nINFO  --> CU_STUB: Inter-DU Handover Started for ueId [%d] from DU ID [%d] to DU ID [%d]", \
+          ueId, sourceDuId, targetDuId);
+    BuildAndSendUeContextModificationReq(sourceDuId, ueCb, QUERY_CONFIG);
+}
+
 /*******************************************************************
  *
  * @brief Handles Console input
@@ -289,15 +280,16 @@ void *cuConsoleHandler(void *args)
 
    while(true) 
    {
+      ch = getchar();
       /* Send DL user data to CU when user enters 'd' on console */
-      if((ch = getchar()) == 'd')
+      if(ch == 'd')
       {
 
-      /* Change #if 0 to #if 1 to take input from user */
+         /* Change #if 0 to #if 1 to take input from user */
 #if 0
          DU_LOG("\n EGTP --> : Enter TEID id(1..10) where DL Data to be sent\n");
          scanf("%d",&teId);
-         
+
          if(teId > MAX_TEID || teId < MIN_TEID)
          {
             DU_LOG("\nERROR  -->  EGTP : TEID(%x) OUT Of Range",teId);
@@ -344,6 +336,38 @@ void *cuConsoleHandler(void *args)
 #endif
          continue;
       } 
+
+      /* Start Handover procedure towards DU when 'h' is received from console input */
+      else if(ch == 'h')
+      {
+         uint32_t sourceDuId, targetDuId, ueId;
+
+         DU_LOG("\nEnter Source DU ID for Inter-DU Handover");
+         scanf("%d", &sourceDuId);
+         DU_LOG("\nEnter Target DU ID for Inter-DU Handover");
+         scanf("%d", &targetDuId);
+         DU_LOG("\nEnter DU UE F1AP ID to be handed over");
+         scanf("%d", &ueId);
+
+         initiateInterDuHandover(sourceDuId, targetDuId, ueId);
+      }
+      /* Start Idle mode paging when 'p' is received from console input */
+      else if(ch == 'p')
+      {
+         uint64_t sTmsi = 0;
+         uint8_t duId = 0;
+
+         DU_LOG("\nEnter DU ID on which this UE to be pagged");
+         scanf("%d", &duId);
+         DU_LOG("\nEnter 5g-S-TMSI");
+         scanf("%lu", &sTmsi);
+
+         if(BuildAndSendPagingMsg(sTmsi, duId) != ROK)
+         {
+            DU_LOG("\nERROR --> EGTP: Failed to build and send paging message for 5gsTmsi[%lu]\n", sTmsi);   
+         }
+         continue;
+      }
    }
 }
 /**********************************************************************