{
DU_LOG("\nDU_APP : SCTP communication UP");
//Setup F1-C
- if(ntfy->u.assocChange.assocId == f1Params.assocId & (!duCb.f1Status))
+ if(ntfy->u.assocChange.assocId == f1Params.assocId)
{
/* Build and send F1 Setup response */
if(BuildAndSendF1SetupReq() != ROK)
}
}
//Setup E2
- if(ntfy->u.assocChange.assocId == ricParams.assocId & (!duCb.e2Status))
+ if(ntfy->u.assocChange.assocId == ricParams.assocId)
{
/* Build and send F1 Setup response */
if(BuildAndSendE2SetupReq() != ROK)
DU_LOG("\nDU_APP : Tunnel management confirm OK");
#ifdef EGTP_TEST
- duSendEgtpDatInd();
+ duSendUeCreateReqToRlc();
+
+ duSendEgtpTestData();
/* For testing purpose. TTI thread should actually be in L1 */
duStartTtiThread();
RETVALUE(ret);
}
+S16 duSendEgtpDatInd(Buffer *mBuf)
+{
+ EgtpMsg egtpMsg;
+
+ /* Fill EGTP header */
+ egtpMsg.msgHdr.msgType = EGTPU_MSG_GPDU;
+ egtpMsg.msgHdr.nPdu.pres = FALSE;
+ egtpMsg.msgHdr.seqNum.pres = FALSE;
+ egtpMsg.msgHdr.extHdr.udpPort.pres = FALSE;
+ egtpMsg.msgHdr.extHdr.pdcpNmb.pres = FALSE;
+ egtpMsg.msgHdr.teId = 1;
+ egtpMsg.msg = mBuf;
+
+ egtpHdlDatInd(egtpMsg);
+
+ return ROK;
+
+}
+
#ifdef EGTP_TEST
/*******************************************************************
*
- * @brief Simulate RLC to EGTP data indication
+ * @brief Simulate UL Data for intial test
*
* @details
*
- * Function : duSendEgtpDatInd
+ * Function : duSendEgtpTestData
*
* Functionality:
- * Simulate RLC to EGTP data indication
+ * Simulate UL data for initial test
*
* @params[in]
* @return ROK - success
* RFAILED - failure
*
* ****************************************************************/
-S16 duSendEgtpDatInd()
+S16 duSendEgtpTestData()
{
char data[30] = "This is EGTP data from DU";
int datSize = 30;
Buffer *mBuf;
- EgtpMsg egtpMsg;
if(SGetMsg(DU_APP_MEM_REGION, DU_POOL, &mBuf) == ROK)
{
- if(SAddPstMsgMult((Data *)data, datSize, mBuf) == ROK)
- {
- SPrntMsg(mBuf, 0,0);
- }
- else
+ if(SAddPstMsgMult((Data *)data, datSize, mBuf) != ROK)
{
DU_LOG("\nDU_APP : SAddPstMsgMult failed");
SPutMsg(mBuf);
/* this function automatically reverses revPkArray */
ret = SAddPreMsgMult(revPkArray, (MsgLen)cnt, mBuf);
-
-
- egtpMsg.msgHdr.msgType = EGTPU_MSG_GPDU;
- egtpMsg.msgHdr.nPdu.pres = FALSE;
- egtpMsg.msgHdr.seqNum.pres = FALSE;
- egtpMsg.msgHdr.extHdr.udpPort.pres = FALSE;
- egtpMsg.msgHdr.extHdr.pdcpNmb.pres = FALSE;
- egtpMsg.msgHdr.teId = 1;
- egtpMsg.msg = mBuf;
-
- SPrntMsg(mBuf, 0, 0);
-
- egtpHdlDatInd(egtpMsg);
+
+ duSendEgtpDatInd(mBuf);
RETVALUE(ROK);
}
return ROK;
}
-/*******************************************************************
- *
- * @brief Checks the status of the received information
- *
- * @details
- *
- * Function : duCheckReqStatus
- *
- * Functionality:
- * Checks the status of the received information
- *
- * @params[in] Confirm status
- * @return ROK - success
- * RFAILED - failure
- *
- ******************************************************************/
-S16 duCheckReqStatus(CmStatus *cfm)
-{
- S16 ret = ROK;
- if(cfm->status != LCM_PRIM_OK)
- {
- DU_LOG("\nDU_APP : Failed to process the request successfully");
- ret = RFAILED;
- }
- RETVALUE(ret);
-}
/**************************************************************************
* @brief Function to configure SCTP params and
S16 duLayerConfigComplete()
{
S16 ret = ROK;
- CmStatus cfm;
DU_LOG("\nDU_APP : Configuring all Layer is complete");
- duSctpCfgReq(duCfgParam.sctpParams, &cfm);
- if((ret = duCheckReqStatus(&cfm)) != ROK)
+ if((ret = duSctpCfgReq(duCfgParam.sctpParams)) != ROK)
{
DU_LOG("\nDU_APP : Failed configuring Sctp Params");
ret = RFAILED;
}
- duSctpAssocReq(duCfgParam.sctpParams.itfType.f1Itf, &cfm);
- if((ret = duCheckReqStatus(&cfm)) != ROK)
+ if((ret = duSctpAssocReq(F1_INTERFACE)) != ROK)
{
DU_LOG("\nDU_APP : Failed to send AssocReq F1");
ret = RFAILED;
}
- duSctpAssocReq(duCfgParam.sctpParams.itfType.e2Itf, &cfm);
- if((ret = duCheckReqStatus(&cfm)) != ROK)
+ if((ret = duSctpAssocReq(E2_INTERFACE)) != ROK)
{
DU_LOG("\nDU_APP : Failed to send AssocReq E2");
ret = RFAILED;