src/5gnrrlc/kw_ptui.c

   1 /*******************************************************************************
   2 ################################################################################
   3 #   Copyright (c) [2017-2019] [Radisys]                                        #
   4 #                                                                              #
   5 #   Licensed under the Apache License, Version 2.0 (the "License");            #
   6 #   you may not use this file except in compliance with the License.           #
   7 #   You may obtain a copy of the License at                                    #
   8 #                                                                              #
   9 #       http://www.apache.org/licenses/LICENSE-2.0                             #
  10 #                                                                              #
  11 #   Unless required by applicable law or agreed to in writing, software        #
  12 #   distributed under the License is distributed on an "AS IS" BASIS,          #
  13 #   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.   #
  14 #   See the License for the specific language governing permissions and        #
  15 #   limitations under the License.                                             #
  16 ################################################################################
  17 *******************************************************************************/
  18
  19 /********************************************************************20**
  20
  21         Name:    LTE-RLC Layer - Upper Interface
  22
  23         Type:    C file
  24
  25         Desc:    C source code for the upper interface of LTE-RLC
  26
  27         File:    kw_ptui.c
  28
  29 *********************************************************************21*/
  30 static const char* RLOG_MODULE_NAME="UIM";
  31 static int RLOG_MODULE_ID=2048;
  32 static int RLOG_FILE_ID=199;
  33
  34 /** @file kw_ptui.c
  35 @brief RLC Upper Interface
  36 */
  37
  38 \f
  39 /* header (.h) include files */
  40 #include "envopt.h"        /* environment options */
  41 #include "envdep.h"        /* environment dependent */
  42 #include "envind.h"        /* environment independent */
  43
  44 #include "gen.h"           /* general */
  45 #include "ssi.h"           /* system services */
  46 #include "cm5.h"           /* common timer defines */
  47 #include "cm_tkns.h"       /* common tokens defines */
  48 #include "cm_mblk.h"       /* common memory allocation library defines */
  49 #include "cm_llist.h"      /* common link list  defines  */
  50 #include "cm_hash.h"       /* common hash list  defines */
  51 #include "cm_lte.h"        /* common LTE defines */
  52 #include "lkw.h"           /* LKW defines */
  53 #include "ckw.h"           /* CKW defines */
  54 #include "kwu.h"           /* KWU defines */
  55 #include "rgu.h"           /* RGU defines */
  56
  57 #include "kw_err.h"
  58 #include "kw_env.h"        /* RLC environment options */
  59 #include "kw.h"            /* RLC defines */
  60
  61 /* extern (.x) include files */
  62 #include "gen.x"           /* general */
  63 #include "ssi.x"           /* system services */
  64
  65 #include "cm5.x"           /* common timer library */
  66 #include "cm_tkns.x"       /* common tokens */
  67 #include "cm_mblk.x"       /* common memory allocation */
  68 #include "cm_llist.x"      /* common link list */
  69 #include "cm_hash.x"       /* common hash list */
  70 #include "cm_lte.x"        /* common LTE includes */
  71 #include "cm_lib.x"        /* common memory allocation library */
  72 #include "lkw.x"           /* LKW */
  73 #include "ckw.x"           /* CKW */
  74 #include "kwu.x"           /* KWU */
  75 #include "rgu.x"           /* RGU */
  76 #if defined(MAC_RLC_UL_RBUF) || (defined(L2_L3_SPLIT) && defined(ICC_RECV_TSK_RBUF)) || defined(SS_RBUF)
  77 #include "ss_rbuf.h"
  78 #include "ss_rbuf.x"
  79 #endif
  80 #include "kw.x"
  81 #if defined(L2_L3_SPLIT) && defined(ICC_RECV_TSK_RBUF)
  82 #include "mt_plat_t33.h"
  83 #include "mt_plat_t33.x"
  84 #endif
  85
  86 #ifndef LCKWUIKWU
  87 #define PTKWKWU
  88 #endif
  89
  90 #ifndef LCKWUICKW
  91 #define PTKWCKW
  92 #endif
  93
  94 #ifndef NH
  95 #define PTKWKWU
  96 #define PTKWCKW
  97 #endif
  98
  99 #ifndef PJ
 100 #define PTKWKWU
 101 #define PTKWCKW
 102 #endif
 103
 104
 105 #ifdef __cplusplus
 106 EXTERN "C" {
 107 #endif /* __cplusplus */
 108
 109 \f
 110 /*********************************************************************
 111  *             Forward Declartion for KWU Porting Functions
 112  ********************************************************************/
 113 #if defined(PDCP_RLC_DL_RBUF) || defined(SS_RBUF)
 114 PUBLIC S16 kwDlBatchProc ARGS ((Void));
 115 PUBLIC S16 kwUtlDlFreeRlcRBuf ARGS((Void));
 116 EXTERN void kwUtlDlBatchProcHqStaInd ARGS ((Void));
 117 EXTERN Void kwUtlFreeDlMem ARGS((Void));
 118 EXTERN SsRngBufCnt rngCb;
 119 EXTERN S16 kwUtlDlBatchProcPkts ARGS((Void));
 120 #endif
 121
 122 #if (defined(L2_L3_SPLIT) && defined(ICC_RECV_TSK_RBUF))
 123 PUBLIC S16 kwDlBatchProcSplit  ARGS((Void));
 124 #endif
 125
 126 \f
 127 /*********************************************************************
 128  *             Primitives for KWU interface
 129  ********************************************************************/
 130
 131 /* KWU Bind Confirm primitive */
 132
 133 PUBLIC KwuBndCfm kwUiKwuBndCfmMt[] =
 134 {
 135 #ifdef LCKWUIKWU
 136    cmPkKwuBndCfm,            /* 0 - loosely coupled */
 137 #endif /* LCKWUIKWU */
 138 #ifdef NH
 139    NhLiKwuBndCfm,            /* 1 - tightly coupled, RRC  */
 140 #endif /* NH */
 141 #ifndef KW_PDCP
 142 #ifdef PJ
 143    PjLiKwuBndCfm,            /* 2 - tightly coupled, PDCP */
 144 #endif /* NH */
 145 #endif /* KW_PDCP */
 146 #ifndef TENB_ACC
 147 #ifdef LWLCKWUIKWU
 148    cmPkKwuBndCfm,      /* 3 - light weight loosely coupled */
 149 #endif /* LCKWUIKWU */
 150 #endif /*TENB_ACC*/
 151 };
 152
 153 /* KWU Data Indication primitive */
 154
 155 PUBLIC KwuDatInd kwUiKwuDatIndMt[] =
 156 {
 157 #ifdef LCKWUIKWU
 158    cmPkKwuDatInd,            /* 0 - loosely coupled */
 159 #endif /* LCKWUIKWU */
 160 #ifdef NH
 161    NhLiKwuDatInd,            /* 1 - tightly coupled, RRC  */
 162 #endif /* NH */
 163 #ifdef KW_PDCP
 164 #else
 165 #ifdef PJ
 166    PjLiKwuDatInd,            /* 2 - tightly coupled, PDCP */
 167 #endif /* NH */
 168 #ifndef TENB_ACC
 169 #ifdef LWLCKWUIKWU
 170    cmPkKwuDatInd,         /* 3 - light weight loosely coupled */
 171 #endif /* LCKWUIKWU */
 172 #endif /*TENB_ACC*/
 173 #endif /* KW_PDCP */
 174 };
 175
 176 #ifndef KW_PDCP
 177 PUBLIC KwuDatCfm kwUiKwuDatCfmMt[] =
 178 {
 179 #ifdef LCKWUIKWU
 180    cmPkKwuDatCfm,            /* 0 - loosely coupled */
 181 #endif /* LCKWUIKWU */
 182 #ifdef PJ
 183    PjLiKwuDatCfm,            /* 2 - tightly coupled, PDCP */
 184 #endif /* PJ */
 185 #ifndef TENB_ACC
 186 #ifdef LWLCKWUIKWU
 187    cmPkKwuDatCfm,         /* 3 - light weight loosely coupled */
 188 #endif /* LCKWUIKWU */
 189 #endif /*TENB_ACC*/
 190 };
 191
 192 /* KWU AM Status Indication primitive */
 193
 194 PUBLIC KwuStaInd kwUiKwuStaIndMt[] =
 195 {
 196 #ifdef LCKWUIKWU
 197    cmPkKwuStaInd,            /* 0 - loosely coupled */
 198 #endif /* LCKWUIKWU */
 199 #ifdef PJ
 200    PjLiKwuStaInd,            /* 2 - tightly coupled, PDCP */
 201 #endif /* PJ */
 202 #ifndef TENB_ACC
 203 #ifdef LWLCKWUIKWU
 204    cmPkKwuStaInd,         /* 3 - light weight loosely coupled */
 205 #endif /* LCKWUIKWU */
 206 #endif /*TENB_ACC*/
 207 };
 208
 209 PUBLIC KwuReEstCmpInd kwUiKwuReEstCmpIndMt[] =
 210 {
 211 #ifdef LCKWUIKWU
 212    cmPkKwuReEstCmpInd,            /* 0 - loosely coupled */
 213 #endif /* LCKWUIKWU */
 214 #ifdef PJ
 215    PjLiKwuReEstCmpInd,            /* 2 - tightly coupled, PDCP */
 216 #else
 217 #endif /* PJ */
 218 #ifndef TENB_ACC
 219 #ifdef LWLCKWUIKWU
 220    cmPkKwuReEstCmpInd,    /* 3 - light weight loosely coupled */
 221 #endif /* LCKWUIKWU */
 222 #endif /*TENB_ACC*/
 223 };
 224
 225 /* kw005.201 added support for L2 measurement */
 226 PUBLIC KwuDiscSduCfm kwUiKwuDiscSduCfmMt[] =
 227 {
 228 #ifdef LCKWUIKWU
 229    cmPkKwuDiscSduCfm,            /* 0 - loosely coupled */
 230 #endif /* LCKWUIKWU */
 231 #ifdef PJ
 232    PjLiKwuDiscSduCfm,            /* 2 - tightly coupled, PDCP */
 233 #endif
 234 #ifndef TENB_ACC
 235 #ifdef LWLCKWUIKWU
 236    cmPkKwuDiscSduCfm,    /* 3 - light weight loosely coupled */
 237 #endif /* PJ */
 238 #endif /*TENB_ACC*/
 239 };
 240 PUBLIC KwuFlowCntrlInd kwUiKwuFlowCntrlIndMt[] =
 241 {
 242 #ifdef LCKWUIKWU
 243    cmPkKwuFlowCntrlInd,            /* 0 - loosely coupled */
 244 #endif /* LCKWUIKWU */
 245 #ifdef PJ
 246    PjLiKwuFlowCntrlInd,            /* 2 - tightly coupled, PDCP */
 247 #endif /* PJ */
 248 #ifdef LCKWUIKWU
 249    cmPkKwuFlowCntrlInd,            /* 3 - light weight loosely coupled */
 250 #endif /* LCKWUIKWU */
 251 };
 252 #ifdef LTE_L2_MEAS
 253 PUBLIC KwuDatAckInd kwUiKwuDatAckIndMt[] =
 254 {
 255 #ifdef LCKWUIKWU
 256    cmPkKwuDatAckInd,            /* 0 - loosely coupled */
 257 #endif /* LCKWUIKWU */
 258 #ifdef PJ
 259    PjLiKwuDatAckInd,            /* 2 - tightly coupled, PDCP */
 260 #endif /* PJ */
 261 #ifndef TENB_ACC
 262 #ifdef LWLCKWUIKWU
 263    cmPkKwuDatAckInd,     /* 3 - light weight loosely coupled, portable */
 264 #endif /* PJ */
 265 #endif /*TENB_ACC*/
 266 };
 267 #endif /* LTE_L2_MEAS */
 268 /* KWU AM Data confirm primitive */
 269
 270 #endif /* KW_PDCP */
 271
 272 \f
 273 /****************************************************************************
 274  *                         KWU Interface Mt functions
 275  ***************************************************************************/\f
 276 /**
 277  *
 278  * @brief
 279  *
 280  *        Handler for confirming  the bind request received from KWU
 281  *        interface.
 282  *
 283  * @b Description:
 284  *
 285  *        This function send the bind confirm primitive to the RLC user,
 286  *        when it receives a bind request from its service user.
 287  *
 288  *  @param[in] pst     Post structure
 289  *  @param[in] suId    Service user SAP ID
 290  *  @param[in] status  Status of Confirmation
 291  *
 292  *  @return  S16
 293  *      -# ROK
 294  *
 295  */
 296 #ifdef ANSI
 297 PUBLIC S16 KwUiKwuBndCfm
 298 (
 299 Pst *pst,                       /* post structure */
 300 SuId suId,                      /* Service User Id */
 301 U8   status                     /* Status */
 302 )
 303 #else
 304 PUBLIC S16 KwUiKwuBndCfm(pst, suId, status)
 305 Pst *pst;                       /* post structure */
 306 SuId suId;                      /* Service User Id */
 307 U8   status;                    /* Status */
 308 #endif
 309 {
 310    TRC3(KwUiKwuBndCfm)
 311
 312    /* jump to specific primitive depending on configured selector */
 313    (*kwUiKwuBndCfmMt[pst->selector])(pst, suId, status);
 314
 315    RETVALUE(ROK);
 316
 317 } /* end of KwUiKwuBndCfm */
 318
 319 \f
 320 /**
 321  *
 322  * @brief
 323  *
 324  *        Handler for sending the data(SDU) from upper layer.
 325  *
 326  * @b Description:
 327  *
 328  *        This function is used to transfer a SDU received from the peer
 329  *        RLC entity to the service user(RRC/PDCP).
 330  *
 331  *  @param[in] pst         Post structure
 332  *  @param[in] suId        Service User SAP ID
 333  *  @param[in] datIndInfo  Data Request Information
 334  *  @param[in] mBuf         Data Buffer (SDU)
 335  *
 336  *  @return  S16
 337  *      -# ROK
 338  *      -# RFAILED
 339  */
 340 #ifdef ANSI
 341 PUBLIC S16 KwUiKwuDatInd
 342 (
 343 Pst               *pst,
 344 KwuDatIndInfo     *datInd,
 345 Buffer            *mBuf
 346 )
 347 #else
 348 PUBLIC S16 KwUiKwuDatInd(pst, datInd, mBuf)
 349 Pst               *pst;
 350 KwuDatIndInfo     *datInd;
 351 Buffer            *mBuf;
 352 #endif
 353 {
 354    TRC3(KwUiKwuDatInd)
 355
 356    /* jump to specific primitive depending on configured selector */
 357    (*kwUiKwuDatIndMt[pst->selector])(pst, datInd, mBuf);
 358
 359    RETVALUE(ROK);
 360
 361 } /* end of KwUiKwuDatInd */
 362
 363    PUBLIC int rlcDatCfmsSent = 0;
 364 \f
 365 #ifndef KW_PDCP
 366 /**
 367  *
 368  * @brief
 369  *
 370  *        Handler for sending the data confirmation to upper layer.
 371  *
 372  * @b Description:
 373  *
 374  *        This function is used to send a confirmation to the service
 375  *        user about the data received by the peer RLC entity.
 376  *
 377  *  @param[in] pst         Post structure
 378  *  @param[in] suId        Service User SAP ID
 379  *  @param[in] datCfmInfo  Data Confirmation Information
 380  *
 381  *  @return  S16
 382  *      -# ROK
 383  *      -# RFAILED
 384  */
 385 #ifdef ANSI
 386 PUBLIC S16 KwUiKwuDatCfm
 387 (
 388 Pst               *pst,
 389 SuId              suId,
 390 KwuDatCfmInfo     *datCfm
 391 )
 392 #else
 393 PUBLIC S16 KwUiKwuDatCfm(pst, suId, datCfm)
 394 Pst               *pst;
 395 SuId              suId;
 396 KwuDatCfmInfo     *datCfm;
 397 #endif
 398 {
 399    rlcDatCfmsSent++;
 400    TRC3(KwUiKwuDatCfm)
 401
 402    /* jump to specific primitive depending on configured selector */
 403    (*kwUiKwuDatCfmMt[pst->selector])(pst, suId, datCfm);
 404
 405    RETVALUE(ROK);
 406
 407 } /* end of KwUiKwuDatCfm */
 408
 409 \f
 410 /**
 411  *
 412  * @brief
 413  *
 414  *        Handler for sending the Status Indication to the upper layer.
 415  *
 416  * @b Description:
 417  *
 418  *        This function is used only by RLC AM entity.It send status
 419  *        indication to the upper layer about the maximum number of
 420  *        re-transmissions reached for a RLC AM entity.
 421  *
 422  *  @param[in] pst         Post structure
 423  *  @param[in] suId        Service User SAP ID
 424  *  @param[in] staInd      RLC Entity Id
 425  *
 426  *  @return  S16
 427  *      -# ROK
 428  *      -# RFAILED
 429  */
 430 #ifdef ANSI
 431 PUBLIC S16 KwUiKwuStaInd
 432 (
 433 Pst               *pst,
 434 SuId              suId,
 435 KwuStaIndInfo     *staInd
 436 )
 437 #else
 438 PUBLIC S16 KwUiKwuStaInd(pst, suId, staInd)
 439 Pst               *pst;
 440 SuId              suId;
 441 KwuStaIndInfo     *staInd;
 442 #endif
 443 {
 444    TRC3(KwUiKwuStaInd)
 445
 446    /* jump to specific primitive depending on configured selector */
 447    (*kwUiKwuStaIndMt[pst->selector])(pst, suId, staInd);
 448
 449    RETVALUE(ROK);
 450
 451 } /* end of KwUiKwuStaInd */
 452
 453 \f
 454 /**
 455  *
 456  * @brief
 457  *
 458  *        Handler for sending the Status Indication to the upper layer.
 459  *
 460  * @b Description:
 461  *
 462  *        This function is used only by RLC AM entity.It send status
 463  *        indication to the upper layer about the maximum number of
 464  *        re-transmissions reached for a RLC AM entity.
 465  *
 466  *  @param[in] pst         Post structure
 467  *  @param[in] suId        Service User SAP ID
 468  *  @param[in] staInd      RLC Entity Id
 469  *
 470  *  @return  S16
 471  *      -# ROK
 472  *      -# RFAILED
 473  */
 474 #ifdef ANSI
 475 PUBLIC S16 KwUiKwuReEstCmpInd
 476 (
 477 Pst               *pst,
 478 SuId              suId,
 479 CmLteRlcId        rlcId
 480 )
 481 #else
 482 PUBLIC S16 KwUiKwuReEstCmpInd(pst, suId, rlcId)
 483 Pst               *pst;
 484 SuId              suId;
 485 CmLteRlcId        rlcId;
 486 #endif
 487 {
 488    TRC3(KwUiKwuReEstCmpInd)
 489    RLOG0(L_DEBUG, "In KwUiKwuReEstCmpInd");
 490
 491    /* jump to specific primitive depending on configured selector */
 492    (*kwUiKwuReEstCmpIndMt[pst->selector])(pst, suId, rlcId);
 493
 494    RETVALUE(ROK);
 495
 496 } /* end of KwUiKwuReEstCmpInd */
 497 /* kw005.201 added support for L2 Measurement */
 498 \f
 499 /**
 500  *
 501  * @brief
 502  *
 503  *        Handler for sending the Sdu Disc Cfm  to the upper layer.
 504  *
 505  * @b Description:
 506  *
 507  *       This function confirms the discard of an SDU .
 508  *
 509  *  @param[in] pst         Post structure
 510  *  @param[in] suId        Service User SAP ID
 511  *  @param[in] discCfm     Disc information.
 512  *
 513  *  @return  S16
 514  *      -# ROK
 515  *      -# RFAILED
 516  */
 517 #ifdef ANSI
 518 PUBLIC S16 KwUiKwuDiscSduCfm
 519 (
 520 Pst               *pst,
 521 SuId              suId,
 522 KwuDiscSduInfo    *discCfm
 523 )
 524 #else
 525 PUBLIC S16 KwUiKwuDiscSduCfm(pst, suId, discCfm)
 526 Pst               *pst;
 527 SuId              suId;
 528 KwuDiscSduInfo    *discCfm;
 529 #endif
 530 {
 531    TRC3(KwUiKwuDiscSduCfm)
 532
 533    /* jump to specific primitive depending on configured selector */
 534    (*kwUiKwuDiscSduCfmMt[pst->selector])(pst, suId, discCfm);
 535
 536    RETVALUE(ROK);
 537
 538 } /* end of KwUiKwuDiscSduCfm */
 539
 540 /**
 541  *
 542  * @brief
 543  *
 544  *        Handler for sending Flow indication to the upper layer.
 545  *
 546  * @b Description:
 547  *
 548  *       This function indicates to PDCP if packets need to be stopped or
 549  *       started for a particular RB
 550  *
 551  *  @param[in] pst                Post structure
 552  *  @param[in] suId               Service User SAP ID
 553  *  @param[in] flowCntrlIndInfo   Flow control information.
 554  *
 555  *  @return  S16
 556  *      -# ROK
 557  *      -# RFAILED
 558  */
 559 #ifdef ANSI
 560 PUBLIC S16 KwUiKwuFlowCntrlInd
 561 (
 562 Pst                   *pst,
 563 SuId                  suId,
 564 KwuFlowCntrlIndInfo   *flowCntrlIndInfo
 565 )
 566 #else
 567 PUBLIC S16 KwUiKwuFlowCntrlInd(pst, suId, flowCntrlIndInfo)
 568 Pst                   *pst;
 569 SuId                  suId;
 570 KwuFlowCntrlIndInfo   *flowCntrlIndInfo;
 571 #endif
 572 {
 573    TRC3(KwUiKwuFlowCntrlInd)
 574
 575    /* jump to specific primitive depending on configured selector */
 576    (*kwUiKwuFlowCntrlIndMt[pst->selector])(pst, suId, flowCntrlIndInfo);
 577
 578    RETVALUE(ROK);
 579
 580 } /* end of KwUiKwuFlowCntrlInd */
 581 #ifdef LTE_L2_MEAS
 582 \f
 583 /**
 584  *
 585  * @brief
 586  *
 587  *        Handler for sending the Data ack indication  to the upper layer.
 588  *
 589  * @b Description:
 590  *
 591  *       This function confirms the succesfull transmission of SDU
 592  *
 593  *  @param[in] pst         Post structure
 594  *  @param[in] suId        Service User SAP ID
 595  *  @param[in] datAckInd   DatAckInd
 596  *
 597  *  @return  S16
 598  *      -# ROK
 599  *      -# RFAILED
 600  */
 601 #ifdef ANSI
 602 PUBLIC S16 KwUiKwuDatAckInd
 603 (
 604 Pst               *pst,
 605 SuId              suId,
 606 KwuDatAckInfo     *datAckInd
 607 )
 608 #else
 609 PUBLIC S16 KwUiKwuDatAckInd(pst, suId, datAckInd)
 610 Pst               *pst;
 611 SuId              suId;
 612 KwuDatAckInfo     *datAckInd;
 613 #endif
 614 {
 615    TRC3(KwUiKwuDatAckInd)
 616
 617    /* jump to specific primitive depending on configured selector */
 618    (*kwUiKwuDatAckIndMt[pst->selector])(pst, suId, datAckInd);
 619
 620    RETVALUE(ROK);
 621
 622 } /* end of KwUiKwuDatAckInd */
 623 #endif /* LTE_L2_MEAS */
 624 #endif /* KW_PDCP */
 625
 626
 627 \f
 628 /*********************************************************************
 629  *             Primitives for CKW interface
 630  ********************************************************************/
 631
 632 /* CKW Bind Confirm primitive */
 633
 634 PUBLIC CkwBndCfm kwUiCkwBndCfmMt[] =
 635 {
 636 #ifdef LCKWUICKW
 637    cmPkCkwBndCfm,            /* 0 - loosely coupled */
 638 #endif /* LCCKUICKW */
 639 #ifdef NH
 640    NhLiCkwBndCfm,            /* 1 - tightly coupled, RRC  */
 641 #endif /* NH */
 642 };
 643
 644 /* CKW Configuration confirm primitive */
 645
 646 PUBLIC CkwCfgCfm kwUiCkwCfgCfmMt[] =
 647 {
 648 #ifdef LCKWUICKW
 649    cmPkCkwCfgCfm,            /* 0 - loosely coupled */
 650 #endif /* LCKWUICKW */
 651 #ifdef NH
 652    NhLiCkwCfgCfm,            /* 1 - tightly coupled, RRC  */
 653 #endif /* NH */
 654 };
 655
 656 PUBLIC CkwUeIdChgCfm kwUiCkwUeIdChgCfmMt[] =
 657 {
 658 #ifdef LCKWUICKW
 659    cmPkCkwUeIdChgCfm,            /* 0 - loosely coupled */
 660 #endif /* LCKWUICKW */
 661 #ifdef NH
 662    NhLiCkwUeIdChgCfm,            /* 1 - tightly coupled, RRC  */
 663 #endif /* NH */
 664 };
 665
 666
 667 \f
 668 /****************************************************************************
 669  *                         CKW Interface Mt functions
 670  ***************************************************************************/
 671 /**
 672  *
 673  * @brief
 674  *
 675  *        Handler for confirming  the bind request received from CKW
 676  *        interface.
 677  *
 678  * @b Description:
 679  *
 680  *        This function send the bind confirm primitive to the RLC user,
 681  *        when it receives a bind request from its service user.
 682  *
 683  *  @param[in] pst      - Post structure
 684  *  @param[in] suId     - Service user SAP ID
 685  *  @param[in] status   - Status
 686  *
 687  *  @return  S16
 688  *      -# ROK
 689  */
 690 #ifdef ANSI
 691 PUBLIC S16 KwUiCkwBndCfm
 692 (
 693 Pst *pst,                       /* post structure */
 694 SuId suId,                      /* Service User Id */
 695 U8   status                     /* Status */
 696 )
 697 #else
 698 PUBLIC S16 KwUiCkwBndCfm(pst, suId, status)
 699 Pst *pst;                       /* post structure */
 700 SuId suId;                      /* Service User Id */
 701 U8   status;                    /* Status */
 702 #endif
 703 {
 704    TRC3(KwUiCkwBndCfm)
 705
 706    /* jump to specific primitive depending on configured selector */
 707    (*kwUiCkwBndCfmMt[pst->selector])(pst, suId, status);
 708
 709    RETVALUE(ROK);
 710
 711 } /* end of KwUiCkwBndCfm */
 712
 713 \f
 714 /**
 715  *
 716  * @brief
 717  *
 718  *        Handler for sending a configuration confirm to RRC.
 719  *
 720  * @b Description:
 721  *
 722  *        This function is used by RLC user to send a configuration
 723  *        confirmation to RRC after configuring(add/delete/modify)
 724  *        the RLC entities.
 725  *
 726  *  @param[in] pst      Post structure
 727  *  @param[in] transId  Transaction Id
 728  *  @param[in] cfmInfo  Config Confirmation Info
 729  *
 730  *  @return  S16
 731  *      -# ROK
 732  *
 733  */
 734 #ifdef ANSI
 735 PUBLIC S16 KwUiCkwCfgCfm
 736 (
 737 Pst            *pst,                      /* post structure */
 738 SuId           suId,                      /* Service User Id */
 739 CkwCfgCfmInfo  *cfmInfo                    /* Configuration Confirm */
 740 )
 741 #else
 742 PUBLIC S16 KwUiCkwCfgCfm(pst, suId, cfmInfo)
 743 Pst            *pst;                      /* post structure */
 744 SuId           suId;                      /* Service User Id */
 745 CkwCfgCfmInfo  *cfmInfo;                   /* Configuration Confirm */
 746 #endif
 747 {
 748    TRC3(KwUiCkwCfgCfm)
 749
 750    /* jump to specific primitive depending on configured selector */
 751    (*kwUiCkwCfgCfmMt[pst->selector])(pst, suId, cfmInfo);
 752
 753    RETVALUE(ROK);
 754
 755 } /* end of KwUiCkwCfgCfm */
 756
 757 \f
 758 /**
 759  *
 760  * @brief
 761  *
 762  *        Handler for sending a configuration for UE ID change.
 763  *
 764  * @b Description:
 765  *
 766  *        This function is used by RLC to send a configuration
 767  *        confirm for UE ID change.
 768  *
 769  *  @param[in] pst      Post structure
 770  *  @param[in] suId     Service User Id
 771  *  @param[in] transId  Transaction Id
 772  *  @param[in] cfmInfo  Config Confirmation Info
 773  *
 774  *  @return  S16
 775  *      -# ROK
 776  *
 777  */
 778 #ifdef ANSI
 779 PUBLIC S16 KwUiCkwUeIdChgCfm
 780 (
 781 Pst            *pst,                      /* post structure */
 782 SuId           suId,                      /* Service User Id */
 783 U32            transId,
 784 CkwUeInfo      *ueInfo,
 785 CmStatus       status
 786 )
 787 #else
 788 PUBLIC S16 KwUiCkwUeIdChgCfm(pst, suId, transId,ueInfo,status)
 789 Pst            *pst;                      /* post structure */
 790 SuId           suId;                      /* Service User Id */
 791 U32            transId;
 792 CkwUeInfo      *ueInfo;
 793 CmStatus       status;
 794 #endif
 795 {
 796    TRC3(KwUiCkwUeIdChgCfm)
 797
 798    /* jump to specific primitive depending on configured selector */
 799    (*kwUiCkwUeIdChgCfmMt[pst->selector])(pst, suId, transId, ueInfo, status);
 800
 801    RETVALUE(ROK);
 802
 803 } /* end of KwUiCkwCfgCfm */
 804
 805
 806 #if (defined(L2_L3_SPLIT) && defined(ICC_RECV_TSK_RBUF))
 807 /**
 808  *
 809  * @brief
 810  *
 811  *        kwDlBatchProcSplit- process rbug messages
 812  *
 813  *  @return  S16
 814  *      -# ROK
 815  */
 816 #ifdef ANSI
 817 PUBLIC S16 kwDlBatchProcSplit
 818 (
 819 Void
 820 )
 821 #else
 822 PUBLIC S16 kwDlBatchProcSplit()
 823 Void;
 824 #endif
 825 {
 826
 827 /* Read from Ring Buffer and process PDCP packets */
 828    Void *elmIndx = NULLP;
 829    RxmBufReq *datReq = NULLP;
 830 #ifdef LTE_ADV
 831    U32 dlPktCount = 0;
 832 #endif
 833    U8 rngBufDeqIndx = 0;
 834    U32 rngBufDeqMaxCnt;
 835    U32 rngBufCurrCnt;
 836
 837    rngBufDeqMaxCnt = SS_RNG_MAX_DLPDCP_TO_DLRLC_DQ_CNT;
 838 #ifdef TENB_T2K3K_SPECIFIC_CHANGES
 839    rngBufCurrCnt = SGetNumElemInRng(SS_RNG_BUF_RX_TO_DLRLC);
 840    if ( rngBufCurrCnt > (3 * SS_RNG_MAX_DLPDCP_TO_DLRLC_DQ_CNT))
 841    {
 842       if ( rngBufCurrCnt > (6 * SS_RNG_MAX_DLPDCP_TO_DLRLC_DQ_CNT))
 843       {
 844          /* Restablishment scenario */
 845          rngBufDeqMaxCnt = (4 * SS_RNG_MAX_DLPDCP_TO_DLRLC_DQ_CNT);
 846       }
 847       else
 848       {
 849          rngBufDeqMaxCnt = (3 * SS_RNG_MAX_DLPDCP_TO_DLRLC_DQ_CNT)/2;
 850       }
 851    }
 852 #endif
 853    elmIndx = SRngGetRIndx(SS_RNG_BUF_RX_TO_DLRLC);
 854    while(NULLP != elmIndx)
 855    {
 856       datReq = (RxmBufReq *)elmIndx;
 857       if(datReq->mBuf != NULLP)
 858       {
 859         cmUnpkKwuDatReq(KwUiKwuDatReq, &datReq->pst, datReq->mBuf);
 860       }
 861       else
 862       {
 863          RLOG0(L_ERROR, "mBuf is NULL");
 864          if(datReq->mBuf)
 865           cmUnpkKwuDatReq(KwUiKwuDatReq, &datReq->pst, datReq->mBuf);
 866
 867       }
 868       SsRngInfoTbl[SS_RNG_BUF_RX_TO_DLRLC].nPktProc++;//Number of pkt processed in tti
 869       datReq->mBuf = NULLP;
 870       SRngIncrRIndx(SS_RNG_BUF_RX_TO_DLRLC);
 871       rngBufDeqIndx++;
 872       if(rngBufDeqIndx >= rngBufDeqMaxCnt)
 873       {
 874          break;
 875       }
 876 #ifdef LTE_ADV
 877       {
 878         dlPktCount++;
 879         if(dlPktCount > 75)
 880         {
 881            break;
 882         }
 883       }
 884 #endif
 885       if((elmIndx = SRngGetRIndx(SS_RNG_BUF_RX_TO_DLRLC)) == NULLP)
 886       {
 887          break;
 888       }
 889    }
 890
 891    RETVALUE(ROK);
 892 }
 893 #endif
 894
 895 #if defined(PDCP_RLC_DL_RBUF) || defined(SS_RBUF)
 896 #ifdef ANSI
 897 PUBLIC S16 kwDlBatchProc
 898 (
 899 Void
 900 )
 901 #else
 902 PUBLIC S16 kwDlBatchProc()
 903 Void;
 904 #endif
 905 {
 906 /* Read from Ring Buffer and process PDCP packets */
 907
 908    U8 rngBufDeqIndx = 0;
 909    U32 rngBufDeqMaxCnt;
 910 #ifdef TENB_T2K3K_SPECIFIC_CHANGES
 911    U32 rngBufCurrCnt;
 912 #endif
 913    /* Memory regions different for BRCM and Intel */
 914    /*dstProcId,srcProcId,dstEnt,dstInst,srcEnt,srcInst,prior,route,event,region,pool,selector*/
 915 #ifdef SS_RBUF
 916    PRIVATE Pst rlcDlRbfuPst ={1,1,ENTKW,1,ENTPJ,1,PRIOR0,RTESPEC,KWU_EVT_DAT_REQ,1,1,0,0};
 917 #else
 918    PRIVATE Pst rlcDlRbfuPst ={1,1,ENTKW,1,ENTPJ,1,PRIOR0,RTESPEC,KWU_EVT_DAT_REQ,2,1,0,0};
 919 #endif
 920    Void *elmIndx = NULLP;
 921    KwuDatReqDetl *kwuDatReqDetl = NULLP;
 922    KwuDatReqInfo datReq;
 923
 924    rngBufDeqMaxCnt = SS_RNG_MAX_DLPDCP_TO_DLRLC_DQ_CNT;
 925 #ifdef TENB_T2K3K_SPECIFIC_CHANGES
 926    rngBufCurrCnt = SGetNumElemInRng(SS_RNG_BUF_DLPDCP_TO_DLRLC);
 927    if ( rngBufCurrCnt > (3 * SS_RNG_MAX_DLPDCP_TO_DLRLC_DQ_CNT))
 928    {
 929       if ( rngBufCurrCnt > (5 * SS_RNG_MAX_DLPDCP_TO_DLRLC_DQ_CNT))
 930       {
 931          /* Restablishment scenario */
 932          rngBufDeqMaxCnt = (4 * SS_RNG_MAX_DLPDCP_TO_DLRLC_DQ_CNT);
 933       }
 934       else
 935       {
 936          rngBufDeqMaxCnt = (2 * SS_RNG_MAX_DLPDCP_TO_DLRLC_DQ_CNT);
 937       }
 938    }
 939 #endif
 940    elmIndx = SRngGetRIndx(SS_RNG_BUF_DLPDCP_TO_DLRLC);
 941    while(NULLP != elmIndx)
 942    {
 943       kwuDatReqDetl = (KwuDatReqDetl *)elmIndx;
 944       datReq.rlcId = kwuDatReqDetl->rlcId;
 945       datReq.sduId = kwuDatReqDetl->sduId;
 946       datReq.lcType = kwuDatReqDetl->lcType;
 947       SsRngInfoTbl[SS_RNG_BUF_DLPDCP_TO_DLRLC].nPktProc++;;//Number of pkt processed in tti
 948       if(kwuDatReqDetl->mBuf != NULLP)
 949       {
 950          KwUiKwuDatReq(&rlcDlRbfuPst, kwuDatReqDetl->spId, &datReq, kwuDatReqDetl->mBuf);
 951       }
 952       SRngIncrRIndx(SS_RNG_BUF_DLPDCP_TO_DLRLC);
 953       rngBufDeqIndx++;
 954
 955       if(rngBufDeqIndx >= rngBufDeqMaxCnt)
 956       {
 957          break;
 958       }
 959       elmIndx = (Void *)SRngGetRIndx(SS_RNG_BUF_DLPDCP_TO_DLRLC);
 960    }
 961
 962    RETVALUE(ROK);
 963 }
 964
 965
 966 #ifdef ANSI
 967 PUBLIC S16 kwUtlDlBatchProcPkts
 968 (
 969 Void
 970 )
 971 #else
 972 PUBLIC S16 kwUtlDlBatchProcPkts
 973 Void;
 974 #endif
 975 {
 976     kwDlBatchProc();
 977 #ifdef SS_RBUF
 978 #ifdef LTE_L2_MEAS
 979     kwUtlDlBatchProcHqStaInd();
 980 #endif
 981     kwUtlFreeDlMem();
 982 #endif
 983     RETVALUE(ROK);
 984 }
 985
 986
 987 #ifdef ANSI
 988 PUBLIC S16 kwUtlDlFreeRlcRBuf
 989 (
 990 Void
 991 )
 992 #else
 993 PUBLIC S16 kwUtlDlFreeRlcRBuf
 994 Void;
 995 #endif
 996 {
 997 /* Read from Ring Buffer and process PDCP packets */
 998    Void *elmIndx = NULLP;
 999    KwuDatReqDetl *kwuDatReqDetl = NULLP;
1000    /* Free SS_RNG_BUF_DLPDCP_TO_DLRLC  */
1001    elmIndx = SRngGetRIndx(SS_RNG_BUF_DLPDCP_TO_DLRLC);
1002    while(NULLP != elmIndx)
1003    {
1004       kwuDatReqDetl = (KwuDatReqDetl *)elmIndx;
1005       SRngIncrRIndx(SS_RNG_BUF_DLPDCP_TO_DLRLC);
1006       SsRngInfoTbl[SS_RNG_BUF_DLPDCP_TO_DLRLC].nPktProc++;
1007       SPutMsg(kwuDatReqDetl->mBuf);
1008       elmIndx = NULLP;
1009       kwuDatReqDetl = NULLP;
1010       if((elmIndx = SRngGetRIndx(SS_RNG_BUF_DLPDCP_TO_DLRLC)) == NULLP)
1011       break;
1012    }
1013    RETVALUE(ROK);
1014 }
1015
1016
1017 #endif
1018 #ifdef __cplusplus
1019 }
1020 #endif /* __cplusplus */
1021 /********************************************************************30**
1022          End of file
1023 **********************************************************************/