+
+/*******************************************************************
+ *
+ * @brief Initiates inter CU handover
+ *
+ * @details
+ *
+ * Function : initiateInterCuHandover
+ *
+ * Functionality: Initiates the first procedure of inter-CU
+ * handover
+ *
+ * @params[in] Source CU Id
+ * Target CU Id
+ * UE Id to be handed off
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+void initiateInterCuHandover(uint32_t sourceCuId, uint32_t targetCuId, uint32_t ueId)
+{
+ DU_LOG("\nINFO --> CU_STUB: Inter-CU Handover Started for ueId [%d] from CU ID [%d] to CU ID [%d]", \
+ ueId, sourceCuId, targetCuId);
+ //TODO : First message of HO procedure to be triggered here. Changes to be done in next commit.
+}
+
+/*******************************************************************
+ *
+ * @brief start Dl data
+ *
+ * @details
+ *
+ * Function : startDlData
+ *
+ * Functionality: start the downlink data
+ *
+ * @params[in]
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+
+uint8_t startDlData()
+{
+ uint32_t teId = 0;
+ uint32_t duId;
+ uint8_t ret = ROK;
+ uint8_t cnt = 0;
+ int32_t totalNumOfTestFlow = 20;
+ EgtpTeIdCb *teidCb = NULLP;
+
+ while(totalNumOfTestFlow)
+ {
+ for(duId = 1; duId <= cuCb.cuCfgParams.egtpParams.numDu; duId++)
+ {
+ for(teId = 1; teId <= NUM_TUNNEL_TO_PUMP_DATA; teId++)
+ {
+ teidCb = NULLP;
+ cmHashListFind(&(egtpCb.dstCb[duId-1].teIdLst), (uint8_t *)&(teId), sizeof(uint32_t), 0, (PTR *)&teidCb);
+ if(teidCb)
+ {
+ cnt =0;
+ DU_LOG("\nDEBUG --> EGTP: Sending DL User Data(duId %d, teId:%d)\n", duId, teId);
+ while(cnt < NUM_DL_PACKETS)
+ {
+ ret = cuEgtpDatReq(duId, teId);
+ if(ret != ROK)
+ {
+ DU_LOG("\nERROR --> EGTP: Issue with teid=%d\n",teId);
+ break;
+ }
+ /* TODO : sleep(1) will be removed later once we will be able to
+ * support the continuous data pack transfer */
+ sleep(1);
+ cnt++;
+ }
+ }
+ else
+ {
+ DU_LOG("\nDEBUG --> EGTP: TunnelId Not Found for (duId %d, teId:%d)\n", duId, teId);
+ }
+ }
+ }
+ totalNumOfTestFlow--;
+ }
+
+ return ROK;
+}
+