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-516][Task-ID: ODUHIGH-535] Implementation of E2 Removal Procedure...
[o-du/l2.git]
/
src
/
ric_stub
/
ric_stub_sctp.h
diff --git
a/src/ric_stub/ric_stub_sctp.h
b/src/ric_stub/ric_stub_sctp.h
index
37da878
..
9f9a8fe
100644
(file)
--- a/
src/ric_stub/ric_stub_sctp.h
+++ b/
src/ric_stub/ric_stub_sctp.h
@@
-23,7
+23,8
@@
#define MAX_RETRY 5
#define MAX_IPV6_LEN 16
#define MAX_RETRY 5
#define MAX_IPV6_LEN 16
-#define MAX_DU_SUPPORTED 1
+#define MAX_DU_SUPPORTED 2
+#define MAX_ASSOC_SUPPORTED MAX_DU_SUPPORTED
/* Global variable declaration */
uint8_t socket_type; /* Socket type */
/* Global variable declaration */
uint8_t socket_type; /* Socket type */
@@
-43,17
+44,15
@@
typedef struct
typedef struct
{
typedef struct
{
+ uint32_t duId;
uint16_t destPort; /* DU PORTS */
uint16_t destPort; /* DU PORTS */
- uint16_t srcPort;
bool bReadFdSet;
CmInetFd sockFd; /* Socket file descriptor */
CmInetAddr peerAddr;
bool bReadFdSet;
CmInetFd sockFd; /* Socket file descriptor */
CmInetAddr peerAddr;
- CmInetFd lstnSockFd; /* Listening Socket file descriptor */
CmInetNetAddrLst destAddrLst; /* DU Ip address */
CmInetNetAddrLst destAddrLst; /* DU Ip address */
- CmInetNetAddrLst localAddrLst;
CmInetNetAddr destIpNetAddr; /* DU Ip address */
Bool connUp;
CmInetNetAddr destIpNetAddr; /* DU Ip address */
Bool connUp;
-}RicSctp
Dest
Cb;
+}RicSctp
Assoc
Cb;
typedef struct ipAddr
{
typedef struct ipAddr
{
@@
-63,37
+62,39
@@
typedef struct ipAddr
uint8_t ipV6Addr[MAX_IPV6_LEN];
}SctpIpAddr;
uint8_t ipV6Addr[MAX_IPV6_LEN];
}SctpIpAddr;
-typedef struct sctp
Assoc
Info
+typedef struct sctp
Dest
Info
{
{
- SctpIpAddr duIpAddr;
- uint16_t duPort;
- SctpIpAddr ricIpAddr;
- uint16_t ricPort;
-}SctpAssocInfo;
+ SctpIpAddr destIpAddr;
+ uint16_t destPort;
+}SctpDestInfo;
typedef struct ricSctpParams
{
typedef struct ricSctpParams
{
- uint8_t numDu;
- SctpAssocInfo sctpAssoc[MAX_DU_SUPPORTED];
+ SctpIpAddr localIpAddr;
+ uint16_t e2SctpPort;
+ uint8_t numDestNode;
+ SctpDestInfo destCb[MAX_DU_SUPPORTED];
}RicSctpParams;
typedef struct sctpGlobalCb
{
}RicSctpParams;
typedef struct sctpGlobalCb
{
- RicSctpParams sctpCfg;
- uint8_t numDu;
- RicSctpDestCb destCb[MAX_DU_SUPPORTED];
+ RicSctpParams sctpCfg;
+ CmInetNetAddrLst localAddrLst;
+ CmInetFd e2LstnSockFd; /* Listening Socket file descriptor for E2 association */
+ uint8_t numAssoc;
+ RicSctpAssocCb assocCb[MAX_ASSOC_SUPPORTED];
}SctpGlobalCb;
SctpGlobalCb sctpCb;
uint8_t sctpActvInit();
}SctpGlobalCb;
SctpGlobalCb sctpCb;
uint8_t sctpActvInit();
-uint8_t sctpSend(Buffer *mBuf);
+uint8_t sctpSend(
uint32_t duId,
Buffer *mBuf);
uint8_t sctpCfgReq();
uint8_t sctpStartReq();
uint8_t sctpSetSockOpts(CmInetFd *sock_Fd);
uint8_t sctpCfgReq();
uint8_t sctpStartReq();
uint8_t sctpSetSockOpts(CmInetFd *sock_Fd);
-uint8_t sctpAccept(RicSctp
DestCb *dest
Cb);
+uint8_t sctpAccept(RicSctp
AssocCb *assoc
Cb);
uint8_t sctpSockPoll();
uint8_t sctpSockPoll();
-uint8_t processPolling(sctpSockPollParams *pollParams, RicSctp
Dest
Cb *destCb, uint32_t *timeoutPtr, CmInetMemInfo *memInfo);
+uint8_t processPolling(sctpSockPollParams *pollParams, RicSctp
Assoc
Cb *destCb, uint32_t *timeoutPtr, CmInetMemInfo *memInfo);
uint8_t fillAddrLst(CmInetNetAddrLst *addrLstPtr, SctpIpAddr *ipAddr);
uint8_t fillDestNetAddr(CmInetNetAddr *destAddrPtr, SctpIpAddr *dstIpPtr);
uint8_t fillAddrLst(CmInetNetAddrLst *addrLstPtr, SctpIpAddr *ipAddr);
uint8_t fillDestNetAddr(CmInetNetAddr *destAddrPtr, SctpIpAddr *dstIpPtr);