X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fdu_app%2Fdu_mgr.h;h=49b26d75ca497f78efc6c0ffa8dd9672ec582726;hb=45d134510deb6902b870b4a0fb574b6075fba601;hp=bdd843657d63df74554e2b8d15495305cdffe74b;hpb=829bbd114f1c3dc00c1da47bca0a8207c049df3f;p=o-du%2Fl2.git diff --git a/src/du_app/du_mgr.h b/src/du_app/du_mgr.h index bdd843657..49b26d75c 100644 --- a/src/du_app/du_mgr.h +++ b/src/du_app/du_mgr.h @@ -19,66 +19,197 @@ /* This file contains message handling functionality for DU cell management */ #ifndef __DU_MGR_H__ #define __DU_MGR_H__ - -#include "stdio.h" -#include "ctype.h" -#include "envopt.h" /* Environment options */ -#include "envdep.h" /* Environment dependent */ -#include "envind.h" /* Environment independent */ -#include "gen.h" /* General */ -#include "ssi.h" /* System services */ -#include "cm5.h" /* Common timer defines */ -#include "cm_tkns.h" /* Common tokens defines */ -#include "cm_mblk.h" /* Common memory allocation library defines */ -#include "cm_llist.h" /* Common link list defines */ -#include "cm_hash.h" /* Common hashlist defines */ -#include "cm_lte.h" -#include "cm_inet.h" -#include "lkw.h" -#include "lrg.h" - -#include "du_common.h" - -#include "gen.x" /* General */ -#include "ssi.x" /* System services */ - -#include "cm5.x" /* Common timer library */ -#include "cm_tkns.x" /* Common tokens */ -#include "cm_mblk.x" /* Common memory allocation */ -#include "cm_llist.x" /* Common link list */ -#include "cm_hash.x" /* Common hashlist */ -#include "cm_lte.x" -#include "cm_inet.x" -#include "cm_lib.x" -#include "lkw.x" -#include "lrg.x" - #define DU_PROC 0 -#define DU_POOL 1 + /* Events */ #define EVTCFG 0 -#define EVTSCTPUP 1 +#define EVTSCTPSTRT 1 +#define EVENT_CU_DATA 2 +#define EVENT_SCTP_NTFY 3 +#define EVTSRVOPENREQ 4 +#define EVTSRVOPENCFM 5 +#define EVTTNLMGMTREQ 6 +#define EVTTNLMGMTCFM 7 +#define EVTSLOTIND 8 +#define EVTSTARTPOLL 9 +#define EVENT_RIC_DATA 10 + + +/* SAP IDs */ +#define DU_MAC_SUID 0 +#define DU_MAC_SPID 0 + +/* Instance */ +#define RLC_UL_INST 0 +#define RLC_DL_INST 1 + +/* SAP state */ +#define DU_SAP_UNBOUND 1 +#define DU_SAP_BINDING 2 +#define DU_SAP_BOUND 3 + +#define DU_ZERO_VAL 0 + +/* Macros */ +#define ADD 0 +#define DEL 1 + +#define RLC_GEN_CFG 1 +#define RLC_MAC_SAP_CFG 2 +#define RLC_UDX_SAP_CFG 4 + +#define MAC_GEN_CFG 1 +#define MAC_SAP_CFG 2 +#define MAX_MAC_SAP 2 + +#define DU_RLC_UL_CONFIGURED (RLC_GEN_CFG | \ + RLC_MAC_SAP_CFG | RLC_UDX_SAP_CFG) +#define DU_RLC_DL_CONFIGURED DU_RLC_UL_CONFIGURED + +#define MAC_CONFIGURED (MAC_GEN_CFG | MAC_SAP_CFG) + +#define DU_SET_ZERO(_buf, _size) \ + cmMemset((U8 *)(_buf), 0, _size); + +typedef enum +{ + CELL_OUT_OF_SERVICE, + ACTIVATION_IN_PROGRESS, + ACTIVATED, + DELETION_IN_PROGRESS +}CellStatus; + +typedef enum +{ + UE_INACTIVE, + UE_ACTIVE +}UeState; + +typedef struct cellCfgParams +{ + NrEcgi nrEcgi; /* ECGI */ + U16 nrPci; /* PCI */ + U16 fiveGsTac; /* 5gSTac */ + Plmn plmn[MAX_PLMN]; /* List of serving PLMN IDs */ + U32 maxUe; /* max UE per slot */ +}CellCfgParams; + +typedef struct duUeCb +{ + uint32_t gnbDuUeF1apId; /* GNB DU UE F1AP ID */ + uint32_t gnbCuUeF1apId; /* GNB CU UE F1AP ID */ + UeState ueState; + MacUeCfg macUeCfg; +}DuUeCb; + +typedef struct duCellCb +{ + uint16_t cellId; /* Internal cell Id */ + CellCfgParams cellInfo; /* Cell info */ + Bool firstSlotIndRcvd; + CellStatus cellStatus; /* Cell status */ + uint32_t numActvUes; /* Total Active UEs */ + DuUeCb ueCb[MAX_NUM_UE]; /* UE CONTEXT */ +}DuCellCb; + +typedef struct duLSapCb +{ + Pst pst; + SuId suId; + SpId spId; + State sapState; + Mem mem; + CmTimer timer; + U8 bndRetryCnt; + U8 maxBndRetry; + TmrCfg bndTmr; +}DuLSapCb; + +typedef struct ueCcchCtxt +{ + uint32_t gnbDuUeF1apId; /* GNB DU UE F1AP ID */ + uint16_t crnti; /* CRNTI */ + uint16_t cellId; /* Cell Id */ +}UeCcchCtxt; -/* Selector */ -#define DU_SELECTOR_LC 0 -#define DU_SELECTOR_TC 1 -#define DU_SELECTOR_LWLC 2 /* DU APP DB */ -typedef struct duDb +typedef struct duCb { - F1Status f1Status; + Mem mem; /* Memory configs */ + TskInit init; /* DU Init */ + //DuLSapCb **macSap; /* MAC SAP */ + Bool f1Status; /* Status of F1 connection */ + Bool e2Status; /* Status of E2 connection */ + uint8_t numCfgCells; + DuCellCb* cfgCellLst[MAX_NUM_CELL]; /* List of cells at DU APP of type DuCellCb */ + uint8_t numActvCells; + DuCellCb* actvCellLst[MAX_NUM_CELL]; /* List of cells activated/to be activated of type DuCellCb */ + /* pointer to store the address of macCellCfg params used to send du-app to MAC */ + MacCellCfg *duMacCellCfg; /* pointer to store params while sending DU-APP to MAC */ + uint32_t numUe; /* current number of UEs */ + UeCcchCtxt ueCcchCtxt[MAX_NUM_UE]; /* mapping of gnbDuUeF1apId to CRNTI required for CCCH processing*/ +}DuCb; -}DuDb; +typedef struct duLSapCfg +{ + SuId suId; + SpId spId; + Ent srcEnt; + Inst srcInst; + ProcId dstProcId; + Ent dstEnt; + Inst dstInst; + Priority dstPrior; + Route dstRoute; + Selector dstSel; + Mem mem; + U8 maxBndRetry; + TmrCfg bndTmr; + TmrCfg connTmr; +}DuLSapCfg; + +/* global variables */ +DuCb duCb; +//DuCfgParams duCfgParam; /* DU Cell Functions */ S16 duActvInit(Ent entity, Inst inst, Region region, Reason reason); S16 duActvTsk(Pst *pst, Buffer *mBuf); +S16 duSendRlcUlCfg(); +S16 duSendRlcDlCfg(); +S16 duBuildRlcCfg(Inst inst); +S16 duBuildRlcLsapCfg(Ent ent, Inst inst, U8 lsapInst); +S16 duBuildRlcUsapCfg(U8 elemId, Ent ent, Inst inst); +S16 duHdlRlcCfgComplete(Pst *pst, KwMngmt *cfm); +S16 duHdlRlcCntrlCfgComplete(Pst *pst, KwMngmt *cfm); +S16 duProcRlcUlCfgComplete(Pst *pst, KwMngmt *cfm); +S16 duProcRlcDlCfgComplete(Pst *pst, KwMngmt *cfm); +S16 duSendMacCfg(); +S16 duBuildMacGenCfg(); +S16 duBuildMacUsapCfg(SpId sapId); +S16 duHdlMacCfgComplete(Pst *pst, RgMngmt *cfm); +S16 duBindUnbindRlcToMacSap(U8 inst, U8 action); S16 duProcCfgComplete(); +S16 duSendSchCfg(); +S16 duSctpStartReq(); +S16 duSctpNtfyHdl(Buffer *mBuf, CmInetSctpNotification *ntfy); + +S16 duBuildEgtpCfgReq(); +S16 duHdlEgtpCfgComplete(CmStatus cfm); +S16 duSendEgtpSrvOpenReq(); +S16 duHdlEgtpSrvOpenComplete(CmStatus cfm); +S16 duSendEgtpTnlMgmtReq(U8 action, U32 lclTeid, U32 remTeid); +S16 duHdlEgtpTnlMgmtCfm(EgtpTnlEvt tnlEvtCfm); +S16 duSendEgtpTestData(); +S16 duSendEgtpDatInd(Buffer *mBuf); +S16 duHdlSchCfgComplete(Pst *pst, RgMngmt *cfm); +uint8_t duBuildAndSendMacCellStartReq(); +uint8_t duBuildAndSendMacCellStopReq(); #endif /********************************************************************** - End of file -**********************************************************************/ + End of file + **********************************************************************/