+++ /dev/null
-/*******************************************************************************
-################################################################################
-# Copyright (c) [2017-2019] [Radisys] #
-# #
-# Licensed under the Apache License, Version 2.0 (the "License"); #
-# you may not use this file except in compliance with the License. #
-# You may obtain a copy of the License at #
-# #
-# http://www.apache.org/licenses/LICENSE-2.0 #
-# #
-# Unless required by applicable law or agreed to in writing, software #
-# distributed under the License is distributed on an "AS IS" BASIS, #
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. #
-# See the License for the specific language governing permissions and #
-# limitations under the License. #
-################################################################################
-*******************************************************************************/
-
-/********************************************************************20**
-
- Name: RLC service user (PDCP) lower interface
-
- Type: C file
-
- Desc: This file Contains the RLC service user lower interface
- primitive implementain
-
- File: pj_ptli.c
-
-*********************************************************************21*/
-\f
-/* header (.h) include files */
-#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 hash list defines */
-#include "cm_lte.h" /* common LTE defines */
-#include "kwu.h" /* KWU defines */
-#include "pj_err.h"
-
-/* extern (.x) include files */
-#include "gen.x" /* general */
-#include "ssi.x" /* system services */
-//#if defined(PDCP_RLC_DL_RBUF)
-#include "ss_rbuf.h"
-#include "ss_rbuf.x"
-#include "kwu.h" /* PJU */
-#include "ss_queue.h"
-#include "ss_queue.x"
-#include "ss_task.h"
-#include "ss_task.x"
-#include "ss_timer.x" /* System services */
-#include "ss_msg.h" /* System services */
-#include "ss_msg.x" /* System services */
-#include "ss_mem.h" /* System services */
-#include "ss_mem.x" /* System services */
-#include "ss_drvr.x"
-#include "ss_gen.h"
-#include "ss_gen.x"
-//#endif
-
-#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 hash list */
-#include "cm_lte.x" /* common LTE includes */
-#include "cm_lib.x" /* common memory allocation library */
-#include "kwu.x" /* KWU */
-
-
-PUBLIC U8 SUpdMbufMemInfo (Pst *pst,Buffer *mBuf);
-#if defined(PDCP_RLC_DL_RBUF) && !defined(SS_RBUF)
-PUBLIC S16 pjKwuRbufDatReq(Pst * pst,SpId spId,KwuDatReqInfo* datReq,Buffer * mBuf);
-#endif
-
-EXTERN S16 PtLiKwuBndReq ARGS ((
-Pst *post,
-SuId suId,
-SpId spId
-));
-
-EXTERN S16 PtLiKwuUbndReq ARGS ((
-Pst *post,
-SpId spId,
-Reason reason
-));
-
-EXTERN S16 PtLiKwuDiscSduReq ARGS ((
-Pst *post,
-SpId spId,
-KwuDiscSduInfo *discSdu
-));
-
-EXTERN S16 PtLiKwuDatReq ARGS ((
-Pst *post,
-SpId spId,
-KwuDatReqInfo *datReq,
-Buffer *mBuf
-));
-\f
-/************************************************************************
- KWU Interface Matrices
-************************************************************************/
-
-PUBLIC KwuBndReq pjLiKwuBndReqMt [] =
-{
-#ifdef LCKWUIKWU
- cmPkKwuBndReq, /* 0 - loosely coupled */
-#else
- PtLiKwuBndReq, /* 0 - loosely coupled, portable */
-#endif
-#ifdef KW
- KwUiKwuBndReq, /* 1 - tightly coupled, stub layer */
-#else
- PtLiKwuBndReq, /* 1 - tightly coupled, portable */
-#endif
-#ifdef LWLCKWUIKWU
- cmPkKwuBndReq, /* 3 - light weight loosely coupled */
-#else
- PtLiKwuBndReq, /* 3 - light weight loosely coupled, portable */
-#endif
-};
-
-PUBLIC KwuUbndReq pjLiKwuUbndReqMt [] =
-{
-#ifdef LCKWUIKWU
- cmPkKwuUbndReq, /* 0 - loosely coupled */
-#else
- PtLiKwuUbndReq, /* 0 - loosely coupled, portable */
-#endif
-#ifdef KW
- KwUiKwuUbndReq, /* 1 - tightly coupled, stub layer */
-#else
- PtLiKwuUbndReq, /* 1 - tightly coupled, portable */
-#endif
-#ifdef LWLCKWUIKWU
- cmPkKwuUbndReq, /* 3 - light weight loosely coupled */
-#else
- PtLiKwuUbndReq, /* 3 - light weight loosely coupled, portable */
-#endif
-};
-
-PUBLIC KwuDatReq pjLiKwuDatReqMt [] =
-{
-#ifdef LCKWUIKWU
- cmPkKwuDatReq, /* 0 - loosely coupled */
-#else
- PtLiKwuDatReq, /* 0 - loosely coupled, portable */
-#endif
-#ifdef KW
- KwUiKwuDatReq, /* 1 - tightly coupled, stub layer */
-#else
- PtLiKwuDatReq, /* 1 - tightly coupled, portable */
-#endif
-#ifdef LWLCKWUIKWU
- cmPkKwuDatReq, /* 3 - light weight loosely coupled */
-#else
- PtLiKwuDatReq, /* 3 - light weight loosely coupled, portable */
-#endif
-};
-
-PUBLIC KwuDiscSduReq pjLiKwuDiscSduReqMt [] =
-{
-#ifdef LCKWUIKWU
- cmPkKwuDiscSduReq, /* 0 - loosely coupled */
-#else
- PtLiKwuDiscSduReq, /* 0 - loosely coupled, portable */
-#endif
-#ifdef KW
- KwUiKwuDiscSduReq, /* 1 - tightly coupled, stub layer */
-#else
- PtLiKwuDiscSduReq, /* 1 - tightly coupled, portable */
-#endif
-#ifdef LWLCKWUIKWU
- cmPkKwuDiscSduReq, /* 3 - light weight loosely coupled */
-#else
- PtLiKwuDiscSduReq, /* 3 - light weight loosely coupled, portable */
-#endif
-};
-
-\f
-/****************************************************************************
- * KWU Interface Mt functions
- ***************************************************************************/
-/**
- *
- * @brief
- *
- * PjLiKwuBndReq - KWU SAP bind Request
- *
- * @param[in] pst - Post structure
- * @param[in] suId - Service user SAP ID
- * @param[in] spId - Service provider ID
- *
- * @return S16
- * -# ROK
- */
-#ifdef ANSI
-PUBLIC S16 PjLiKwuBndReq
-(
-Pst *pst, /* post structure */
-SuId suId, /* Service User Id */
-SpId spId /* Service Provider Id */
-)
-#else
-PUBLIC S16 PjLiKwuBndReq(pst, suId, spId)
-Pst *pst; /* post structure */
-SuId suId; /* Service User Id */
-SpId spId; /* Service Provider Id */
-#endif
-{
- TRC3(PjLiKwuBndReq)
-
- /* jump to specific primitive depending on configured selector */
- (*pjLiKwuBndReqMt[pst->selector])(pst, suId, spId);
-
- RETVALUE(ROK);
-
-} /* end of PjLiKwuBndReq */
-
-\f
-/**
- *
- * @brief
- *
- * PjLiKwuUbndReq - KWU SAP unbind Request
- *
- * @param[in] pst - Post structure
- * @param[in] spId - Service provider SAP ID
- * @param[in] reason - Reason
- *
- * @return S16
- * -# ROK
- */
-#ifdef ANSI
-PUBLIC S16 PjLiKwuUbndReq
-(
-Pst *pst,
-SpId spId,
-Reason reason
-)
-#else
-PUBLIC S16 PjLiKwuUbndReq(pst, spId, reason)
-Pst *pst;
-SpId spId;
-Reason reason;
-#endif
-{
- TRC3(PjLiKwuUbndReq)
-
- /* jump to specific primitive depending on configured selector */
- (*pjLiKwuUbndReqMt[pst->selector])(pst, spId, reason);
-
- RETVALUE(ROK);
-
-} /* end of PjLiKwuUbndReq */
-
-\f
-/**
- *
- * @brief
- *
- * PjLiKwuDatReq - KWU Data Request
- *
- * @param[in] pst - Post structure
- * @param[in] spId - Service provider SAP ID
- * @param[in] datReq - Data Request
- *
- * @return S16
- * -# ROK
- */
-#ifdef ANSI
-PUBLIC S16 PjLiKwuDatReq
-(
-Pst *pst,
-SpId spId,
-KwuDatReqInfo *datReq,
-Buffer *mBuf
-)
-#else
-PUBLIC S16 PjLiKwuDatReq(pst, spId, datReq, mBuf)
-Pst *pst;
-SpId spId;
-KwuDatReqInfo *datReq;
-Buffer *mBuf;
-#endif
-{
- S16 ret = ROK;
-
- TRC3(PjLiKwuDatReq)
-#if defined(PDCP_RLC_DL_RBUF) && !defined(SS_RBUF)
- if(datReq->lcType == CM_LTE_LCH_DTCH)
- {
- if((pjKwuRbufDatReq(pst,spId, datReq, mBuf)) != ROK)
- {
- /* Posting the message as ring buffer write failure */
- ret = RFAILED;
- }
- }
- else
-#endif
- {
- /* jump to specific primitive depending on configured selector */
- ret = (*pjLiKwuDatReqMt[pst->selector])(pst, spId, datReq, mBuf);
- }
- RETVALUE(ret);
-
-} /* end of PjLiKwuDatReq */
-
-\f
-/**
- *
- * @brief
- *
- * PjLiKwuDiscSduReq - KWU Discard SDU Request
- *
- * @param[in] pst - Post structure
- * @param[in] spId - Service provider SAP ID
- * @param[in] datReq - Data Request
- *
- * @return S16
- * -# ROK
- */
-#ifdef ANSI
-PUBLIC S16 PjLiKwuDiscSduReq
-(
-Pst *pst,
-SpId spId,
-KwuDiscSduInfo *discSdu
-)
-#else
-PUBLIC S16 PjLiKwuDiscSduReq(pst, spId, discSdu)
-Pst *pst;
-SpId spId;
-KwuDiscSduInfo *discSdu;
-#endif
-{
- TRC3(PjLiKwuDiscSduReq)
-
- /* jump to specific primitive depending on configured selector */
- (*pjLiKwuDiscSduReqMt[pst->selector])(pst, spId, discSdu);
-
- RETVALUE(ROK);
-
-} /* end of PjLiKwuDiscSduReq */
-
-/****************************************************************************
- * Porting Functions
- ***************************************************************************/
-/**
- *
- * @brief
- *
- * PtLiKwuBndReq - portable bind request
- *
- * @param[in] pst - Post structure
- * @param[in] suId - Service user SAP ID
- * @param[in] spId - Service provider ID
- *
- * @return S16
- * -# ROK
- */
-
-#ifdef ANSI
-PUBLIC S16 PtLiKwuBndReq
-(
-Pst *post,
-SuId suId,
-SpId spId
-)
-#else
-PUBLIC S16 PtLiKwuBndReq(post, suId, spId)
-Pst *post;
-SuId suId;
-SpId spId;
-#endif /* ANSI */
-{
- TRC3(PtLiKwuBndReq)
-#if (ERRCLASS & ERRCLS_DEBUG)
- /* S16 ret1; */
- SLogError(post->srcEnt, post->srcInst, post->srcProcId,
- __FILE__, __LINE__, (ErrCls)ERRCLS_DEBUG,
- (ErrVal)EPJXXX, (ErrVal)ERRZERO, "Improper selector for NhLiKwuBndReq\n");
- RETVALUE( RFAILED );
-#endif /* (ERRCLASS & ERRCLS_DEBUG) */
- UNUSED(post);
- UNUSED(suId);
- UNUSED(spId);
-
- RETVALUE(ROK);
-} /* end of PtLiKwuBndReq() */
-
-\f
-/**
- *
- * @brief
- *
- * PtLiKwuUbndReq - portable unbind request
- *
- * @param[in] pst - Post structure
- * @param[in] suId - Service provider SAP ID
- * @param[in] reason - Reason
- *
- * @return S16
- * -# ROK
- */
-#ifdef ANSI
-PUBLIC S16 PtLiKwuUbndReq
-(
-Pst *post,
-SpId spId,
-Reason reason
-)
-#else
-PUBLIC S16 PtLiKwuUbndReq(post, spId, reason)
-Pst *post;
-SpId spId;
-Reason reason;
-#endif /* ANSI */
-{
- TRC3(PtLiKwuUbndReq)
-#if (ERRCLASS & ERRCLS_DEBUG)
- /* S16 ret1; */
- SLogError(post->srcEnt, post->srcInst, post->srcProcId,
- __FILE__, __LINE__, (ErrCls)ERRCLS_DEBUG,
- (ErrVal)EPJXXX, (ErrVal)ERRZERO, "Improper selector for NhLiKwuUbndReq\n");
- RETVALUE( RFAILED );
-#endif /* (ERRCLASS & ERRCLS_DEBUG) */
- UNUSED(post);
- UNUSED(spId);
- UNUSED(reason);
-
- RETVALUE(ROK);
-} /* end of PtLiKwuUbndReq() */
-
-/**
- *
- * @brief
- *
- * PtLiKwuDiscSduReq - portable discard SDU request
- *
- * @param[in] pst - Post structure
- * @param[in] spId - Service provider SAP ID
- * @param[in] datReq - Data Request
- *
- * @return S16
- * -# ROK
- */
-#ifdef ANSI
-PUBLIC S16 PtLiKwuDiscSduReq
-(
-Pst *post,
-SpId spId,
-KwuDiscSduInfo *discSdu
-)
-#else
-PUBLIC S16 PtLiKwuDiscSduReq(post, spId, discSdu)
-Pst *post;
-SpId spId;
-KwuDiscSduInfo *discSdu;
-#endif /* ANSI */
-{
- TRC3(PtLiKwuDiscSduReq)
-#if (ERRCLASS & ERRCLS_DEBUG)
- /* S16 ret1; */
- SLogError(post->srcEnt, post->srcInst, post->srcProcId,
- __FILE__, __LINE__, (ErrCls)ERRCLS_DEBUG,
- (ErrVal)EKWU010, (ErrVal)ERRZERO, "Improper selector for NhLiKwuDiscSduReq\n");
- RETVALUE( RFAILED );
-
-#endif /* (ERRCLASS & ERRCLS_DEBUG) */
- UNUSED(post);
- UNUSED(spId);
- UNUSED(discSdu);
-
- RETVALUE(ROK);
-} /* end of PtLiKwuDiscSduReq() */
-
-/**
- *
- * @brief
- *
- * PtLiKwuDatReq - portable data request
- *
- * @param[in] pst - Post structure
- * @param[in] spId - Service provider SAP ID
- * @param[in] datReq - Data Request
- *
- * @return S16
- * -# ROK
- */
-#ifdef ANSI
-PUBLIC S16 PtLiKwuDatReq
-(
-Pst *pst,
-SpId spId,
-KwuDatReqInfo *datReq,
-Buffer *mBuf
-)
-#else
-PUBLIC S16 PtLiKwuDatReq(pst, spId, datReq, mBuf)
-Pst *pst;
-SpId spId;
-KwuDatReqInfo *datReq;
-Buffer *mBuf;
-#endif /* ANSI */
-{
- TRC3(PtLiKwuDatReq)
-#if (ERRCLASS & ERRCLS_DEBUG)
- /* S16 ret1; */
- SLogError(pst->srcEnt, pst->srcInst, pst->srcProcId,
- __FILE__, __LINE__, (ErrCls)ERRCLS_DEBUG,
- (ErrVal)EPJXXX, (ErrVal)ERRZERO, "Improper selector for NhLiKwuDatReq\n");
- RETVALUE( RFAILED );
-#endif /* (ERRCLASS & ERRCLS_DEBUG) */
- UNUSED(pst);
- UNUSED(spId);
- UNUSED(datReq);
- UNUSED(mBuf);
-
- RETVALUE(ROK);
-} /* end of PtLiKwuDatReq() */
-/*
-*
-* Fun: SUpdMbufMemInfo
-*
-* Desc: This function is used to get the mem region info of a task.
-*
-* Ret: ROK - ok
-* RFAILED - failed, general (optional)
-*
-*
-* File: ss_task.c
-*
-*/
-#ifdef TENB_T2K3K_SPECIFIC_CHANGES
-#ifdef ANSI
-PUBLIC U8 SUpdMbufMemInfo
-(
-Pst *pst,
-Buffer *mBuf
-)
-#else
-PUBLIC U8 SUpdMbufMemInfo(pst,mBuf)
-Pst *pst;
-Buffer *mBuf;
-#endif
-{
- SsMsgInfo *minfo;
- SsTTskEntry *tTsk;
- SsIdx dstIdx;
-
-
- minfo = (SsMsgInfo*) mBuf->b_rptr;
-
- dstIdx = osCp.tTskIds[pst->dstEnt][pst->dstInst];
- tTsk = &osCp.tTskTbl[dstIdx];
-#ifdef SS_MULTICORE_SUPPORT
- minfo->region = tTsk->sTsk->region;
-#endif /* SS_MULTICORE_SUPPORT */
- RETVALUE(ROK);
-}
-#endif
-
-#if defined(PDCP_RLC_DL_RBUF) && !defined(SS_RBUF)
-#ifdef ANSI
-PUBLIC S16 pjKwuRbufDatReq
-(
-Pst * pst,
-SpId spId,
-KwuDatReqInfo* datReq,
-Buffer * mBuf
-)
-#else
-PUBLIC S16 pjKwuRbufDatReq(pst, spId, datReq, mBuf)
-Pst * pst;
-SpId spId;
-KwuDatReqInfo* datReq;
-Buffer * mBuf;
-#endif
-{
- S16 ret1 = ROK;
-
- Void *elem = NULLP;
- KwuDatReqDetl *kwuDatReqDetl = NULLP;
-
- elem = SRngGetWIndx(SS_RNG_BUF_DLPDCP_TO_DLRLC);
- if (NULLP != elem)
- {
- kwuDatReqDetl = (KwuDatReqDetl *) elem;
- kwuDatReqDetl->spId = spId;
- kwuDatReqDetl->lcType = datReq->lcType;
- kwuDatReqDetl->sduId = datReq->sduId;
- kwuDatReqDetl->rlcId = datReq->rlcId;
- kwuDatReqDetl->mBuf = mBuf;
- /* Commenting below function because memory region mapped with threadId*/
- /* SUpdMbufMemInfo(pst, mBuf);*/
- SRngIncrWIndx(SS_RNG_BUF_DLPDCP_TO_DLRLC);
- SsRngInfoTbl[SS_RNG_BUF_DLPDCP_TO_DLRLC].pktRate++;
- }
- else
- {
-#if (ERRCLASS & ERRCLS_DEBUG)
- SLogError(ENTPJ, 0, SFndProcId(),
- __FILE__, __LINE__, (ErrCls)ERRCLS_DEBUG,
- (ErrVal)EPJXXX, (ErrVal)ERRZERO, "PDCP-DL RBUF is FULL!!!\n");
-#endif /* (ERRCLASS & ERRCLS_DEBUG) */
- SsRngInfoTbl[SS_RNG_BUF_DLPDCP_TO_DLRLC].pktDrop++;
- ret1 = RFAILED;
- }
- RETVALUE(ret1);
-} /* cmPkKwuDatReq */
-
-#endif /* PDCP_RLC_DL_RBUF */
-
-\f
-/********************************************************************30**
- End of file
-**********************************************************************/
Code Review / o-du / l2.git / blobdiff