Code Review
/
o-du
/
l2.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
[Epic-ID: ODUHIGH-406][Task-ID: ODUHIGH-423] UE context setup request from CU to...
[o-du/l2.git]
/
src
/
cu_stub
/
cu_stub_egtp.c
diff --git
a/src/cu_stub/cu_stub_egtp.c
b/src/cu_stub/cu_stub_egtp.c
index
69f6dba
..
8657cb2
100644
(file)
--- a/
src/cu_stub/cu_stub_egtp.c
+++ b/
src/cu_stub/cu_stub_egtp.c
@@
-19,12
+19,17
@@
/* This file contains all EGTP related functionality */
#include "common_def.h"
/* This file contains all EGTP related functionality */
#include "common_def.h"
+#include "OCTET_STRING.h"
+#include "cu_stub_sctp.h"
#include "cu_f1ap_msg_hdl.h"
#include "cu_stub_egtp.h"
#include "cu_f1ap_msg_hdl.h"
#include "cu_stub_egtp.h"
-#include "du_log.h"
+#include "cu_stub.h"
+#include "cm_inet.h"
+#include "cm_tpt.h"
+
+#include "cm_inet.x"
+#include "cm_tpt.x"
-/* Global variable declaration */
-EgtpGlobalCb egtpCb;
/**************************************************************************
* @brief Task Initiation callback function.
*
/**************************************************************************
* @brief Task Initiation callback function.
*
@@
-115,7
+120,7
@@
S16 cuEgtpCfgReq()
{
uint8_t ret;
{
uint8_t ret;
- memcpy(&egtpCb.egtpCfg, &cuCfgParams.egtpParams, sizeof(EgtpParams));
+ memcpy(&egtpCb.egtpCfg, &cuC
b.cuC
fgParams.egtpParams, sizeof(EgtpParams));
egtpCb.recvTptSrvr.addr.address = CM_INET_NTOH_UINT32(egtpCb.egtpCfg.localIp.ipV4Addr);
egtpCb.recvTptSrvr.addr.port = EGTP_DFLT_PORT;
egtpCb.recvTptSrvr.addr.address = CM_INET_NTOH_UINT32(egtpCb.egtpCfg.localIp.ipV4Addr);
egtpCb.recvTptSrvr.addr.port = EGTP_DFLT_PORT;
@@
-497,8
+502,9
@@
S16 cuEgtpEncodeHdr(uint8_t *preEncodedHdr, EgtpMsgHdr *preDefHdr, uint8_t *hdrI
S16 cuEgtpHdlRecvMsg(Buffer *mBuf)
{
/*Decoding of EGTP message header */
S16 cuEgtpHdlRecvMsg(Buffer *mBuf)
{
/*Decoding of EGTP message header */
+
cuEgtpDecodeHdr(mBuf);
cuEgtpDecodeHdr(mBuf);
-
+
/* Start Pumping data from CU to DU */
//return (cuEgtpDatReq());
/* Start Pumping data from CU to DU */
//return (cuEgtpDatReq());
@@
-615,6
+621,8
@@
S16 cuEgtpDecodeHdr(Buffer *mBuf)
DU_LOG("\nDEBUG --> EGTP : Message Buffer after decoding header [TEID:%d]",egtpMsg.msgHdr.teId);
ODU_PRINT_MSG(mBuf, 0, 0);
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 */
return ROK;
} /* End of cuEgtpDecodeHdr */