[Epic-ID: ODUHIGH-405][Task-ID: ODUHIGH-414] F1 Setup from multiple DU to one CU

[o-du/l2.git] / src / cu_stub / cu_stub_sctp.h

diff --git a/src/cu_stub/cu_stub_sctp.h b/src/cu_stub/cu_stub_sctp.h
index 4cd30bf..2c0a9b7 100644 (file)
--- a/src/cu_stub/cu_stub_sctp.h
+++ b/src/cu_stub/cu_stub_sctp.h
@@ -21,20 +21,83 @@
 #ifndef __CU_SCTP_H__
 #define __CU_SCTP_H__
 
-#include "cu_stub.h"
-#include "cm_inet.h"
-#include "cm_tpt.h"
+#define MAX_RETRY 5
+#define MAX_IPV6_LEN 16
+#define MAX_DU_SUPPORTED 1
 
-#include "cm_inet.x"
-#include "cm_tpt.x"
+/* Global variable declaration */
+uint8_t   socket_type;      /* Socket type */
 
-#define MAX_RETRY 5
+typedef struct
+{
+   S16              numFd;
+   uint16_t         port;   
+   uint32_t         flag;
+   Buffer           *mBuf;
+   MsgLen           bufLen; 
+   CmInetNetAddr    addr;
+   CmInetFdSet      readFd;
+   CmInetSctpSndRcvInfo   info;
+   CmInetSctpNotification ntfy;
+}sctpSockPollParams;
+
+typedef struct
+{
+   uint32_t         duId;
+   uint16_t         destPort;         /* DU PORTS */
+   uint16_t         srcPort;
+   Bool             bReadFdSet;
+   CmInetFd         sockFd;           /* Socket file descriptor */
+   CmInetAddr       peerAddr;
+   CmInetFd         lstnSockFd;       /* Listening Socket file descriptor */
+   CmInetNetAddrLst destAddrLst;      /* DU Ip address */
+   CmInetNetAddrLst localAddrLst;
+   CmInetNetAddr    destIpNetAddr;    /* DU Ip address */ 
+   Bool             connUp;           /* Is connection up */
+}CuSctpDestCb;
+
+typedef struct ipAddr
+{
+ Bool      ipV4Pres;
+ uint32_t  ipV4Addr;
+ Bool      ipV6Pres;
+ uint8_t   ipV6Addr[MAX_IPV6_LEN];
+}SctpIpAddr;
+
+typedef struct sctpAssocInfo
+{
+   SctpIpAddr  duIpAddr;
+   uint16_t    duPort;
+   SctpIpAddr  cuIpAddr;
+   uint16_t    cuPort;
+}SctpAssocInfo;
+
+typedef struct CuSctpParams
+{
+   uint8_t        numDu;
+   SctpAssocInfo  sctpAssoc[MAX_DU_SUPPORTED];
+}CuSctpParams;
+
+typedef struct
+{
+   CuSctpParams sctpCfg;
+   uint8_t      numDu;
+   CuSctpDestCb destCb[MAX_DU_SUPPORTED]; 
+}SctpGlobalCb;
+
+SctpGlobalCb sctpCb;
 
-EXTERN S16 sctpActvInit(Ent entity, Inst inst, Region region, Reason reason);
-EXTERN S16 sctpActvTsk(Pst *pst, Buffer *mBuf);
-EXTERN void sctpStartReq();
-EXTERN S16 sctpOutMsgSend(Buffer *mBuf);
+uint8_t sctpActvInit();
+uint8_t sctpStartReq();
+uint8_t sctpSend(uint32_t duId, Buffer *mBuf);
+uint8_t sctpCfgReq();
 
+uint8_t fillAddrLst(CmInetNetAddrLst *addrLstPtr, SctpIpAddr *ipAddr);
+uint8_t fillDestNetAddr(CmInetNetAddr *destAddrPtr, SctpIpAddr *dstIpPtr);
+uint8_t sctpSetSockOpts(CmInetFd *sock_Fd);
+uint8_t sctpSockPoll();
+uint8_t sctpAccept(CuSctpDestCb *destCb);
+uint8_t processPolling(sctpSockPollParams *pollParams, CuSctpDestCb *destCb, uint32_t *timeoutPtr, CmInetMemInfo *memInfo);
 #endif
 
 /**********************************************************************