DU_LOG("\nDEBUG --> EGTP : Message Buffer after decoding header [TEID:%d]",egtpMsg.msgHdr.teId);
ODU_PRINT_MSG(mBuf, 0, 0);
+ SPutMsg(mBuf);
+
return ROK;
} /* End of cuEgtpDecodeHdr */
CmInetAddr egtpFromAddr;
CmInetMemInfo memInfo;
sctpSockPollParams f1PollParams;
+ uint64_t numMsgRcvd = 0;
memset(&f1PollParams, 0, sizeof(sctpSockPollParams));
ret = cmInetRecvMsg(&(egtpCb.recvTptSrvr.sockFd), &egtpFromAddr, &memInfo, &egtpBuf, &egtpBufLen, CM_INET_NO_FLAG);
if(ret == ROK && egtpBuf != NULLP)
{
- DU_LOG("\nINFO --> EGTP : Received message \n");
- ODU_PRINT_MSG(egtpBuf, 0 ,0);
+ DU_LOG("\nINFO --> EGTP : Received UL Message [%ld]\n", numMsgRcvd+1);
+ numMsgRcvd++;
+ //ODU_PRINT_MSG(egtpBuf, 0 ,0);
cuEgtpHdlRecvMsg(egtpBuf);
}
#include "du_egtp.h"
#include "du_utils.h"
-/* Global variable declaration */
-EgtpGlobalCb egtpCb;
/**************************************************************************
* @brief Task Initiation callback function.
uint16_t txLen;
CmInetMemInfo info;
CmInetAddr dstAddr;
+ static uint64_t numDataSent = 0;
info.region = DU_APP_MEM_REGION;
info.pool = DU_POOL;
DU_LOG("\nERROR --> EGTP : Failed sending the message");
return RFAILED;
}
+ else
+ {
+ DU_LOG("\nDEBUG --> EGTP : Sent UL Message [%ld]", numDataSent+1);
+ numDataSent++;
+ }
return ROK;
}
EgtpTptSrvr recvTptSrvr; /* Transport server for receiving UDP msg */
EgtpDstCb dstCb; /* Destination endpoint */
}EgtpGlobalCb;
+
EgtpGlobalCb egtpCb; /* EGTP global control block */
uint8_t duHdlEgtpDlData(EgtpMsg *egtpMsg);
#define NR_PCI 1
#define SLOT_DELAY 3
#define NUM_DRB_TO_PUMP_DATA 3
-#define NUM_UL_PACKETS 4
+#define NUM_UL_PACKETS 1
/*UE Ids for RACH IND*/
#define UE_IDX_0 0
#define UE_IDX_1 1