rlc.c 33.8 KB
Newer Older
1
/*******************************************************************************
gauthier's avatar
gauthier committed
2 3
    OpenAirInterface
    Copyright(c) 1999 - 2014 Eurecom
4

gauthier's avatar
gauthier committed
5 6 7 8
    OpenAirInterface is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.
9 10


gauthier's avatar
gauthier committed
11 12 13 14
    OpenAirInterface is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.
15

gauthier's avatar
gauthier committed
16 17
    You should have received a copy of the GNU General Public License
    along with OpenAirInterface.The full GNU General Public License is
18 19
    included in this distribution in the file called "COPYING". If not,
    see <http://www.gnu.org/licenses/>.
20

gauthier's avatar
gauthier committed
21 22 23 24 25
  Contact Information
  OpenAirInterface Admin: openair_admin@eurecom.fr
  OpenAirInterface Tech : openair_tech@eurecom.fr
  OpenAirInterface Dev  : openair4g-devel@eurecom.fr

ghaddab's avatar
ghaddab committed
26
  Address      : Eurecom, Campus SophiaTech, 450 Route des Chappes, CS 50193 - 06904 Biot Sophia Antipolis cedex, FRANCE
gauthier's avatar
gauthier committed
27 28

 *******************************************************************************/
gauthier's avatar
gauthier committed
29 30 31 32 33 34 35
/*
                                rlc.c
                             -------------------
  AUTHOR  : Lionel GAUTHIER
  COMPANY : EURECOM
  EMAIL   : Lionel.Gauthier at eurecom dot fr
*/
36 37 38 39 40
#define RLC_C
#include "rlc.h"
#include "mem_block.h"
#include "../MAC/extern.h"
#include "UTIL/LOG/log.h"
gauthier's avatar
gauthier committed
41
#include "UTIL/OCG/OCG_vars.h"
42
#include "UTIL/LOG/vcd_signal_dumper.h"
43 44 45

#include "assertions.h"

46
extern boolean_t pdcp_data_ind(
47 48 49 50 51 52
                const protocol_ctxt_t* const ctxt_pP,
                const srb_flag_t srb_flagP,
                const MBMS_flag_t MBMS_flagP,
                const rb_id_t rb_idP,
                const sdu_size_t sdu_buffer_sizeP,
                mem_block_t* const sdu_buffer_pP);
53

54 55
#define DEBUG_RLC_PDCP_INTERFACE 1
//#define DEBUG_RLC_PAYLOAD 1
gauthier's avatar
gauthier committed
56
#define DEBUG_RLC_DATA_REQ 1
57

58
#if defined(DEBUG_RLC_PAYLOAD)
59
//-----------------------------------------------------------------------------
60
void rlc_util_print_hex_octets(comp_name_t componentP, unsigned char* dataP, const signed long sizeP)
61 62 63 64 65 66 67 68 69
//-----------------------------------------------------------------------------
{
  unsigned long octet_index = 0;

  if (dataP == NULL) {
    return;
  }


70 71 72 73 74


  LOG_T(componentP, "+-----+-------------------------------------------------+\n");
  LOG_T(componentP, "|     |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |\n");
  LOG_T(componentP, "+-----+-------------------------------------------------+\n");
75 76 77
  for (octet_index = 0; octet_index < sizeP; octet_index++) {
    if ((octet_index % 16) == 0){
      if (octet_index != 0) {
78
        LOG_T(componentP, " |\n");
79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98
      }
      LOG_T(componentP, " %04d |", octet_index);
    }
    /*
     * Print every single octet in hexadecimal form
     */
    LOG_T(componentP, " %02x", dataP[octet_index]);
    /*
     * Align newline and pipes according to the octets in groups of 2
     */
  }

  /*
   * Append enough spaces and put final pipe
   */
  unsigned char index;
  for (index = octet_index; index < 16; ++index)
    LOG_T(componentP, "   ");
  LOG_T(componentP, " |\n");
}
99
#endif
100
//-----------------------------------------------------------------------------
gauthier's avatar
gauthier committed
101
rlc_op_status_t rlc_stat_req     (
102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131
                const protocol_ctxt_t* const ctxtP,
                const srb_flag_t    srb_flagP,
                const rb_id_t       rb_idP,
                unsigned int* stat_tx_pdcp_sdu,
                unsigned int* stat_tx_pdcp_bytes,
                unsigned int* stat_tx_pdcp_sdu_discarded,
                unsigned int* stat_tx_pdcp_bytes_discarded,
                unsigned int* stat_tx_data_pdu,
                unsigned int* stat_tx_data_bytes,
                unsigned int* stat_tx_retransmit_pdu_by_status,
                unsigned int* stat_tx_retransmit_bytes_by_status,
                unsigned int* stat_tx_retransmit_pdu,
                unsigned int* stat_tx_retransmit_bytes,
                unsigned int* stat_tx_control_pdu,
                unsigned int* stat_tx_control_bytes,
                unsigned int* stat_rx_pdcp_sdu,
                unsigned int* stat_rx_pdcp_bytes,
                unsigned int* stat_rx_data_pdus_duplicate,
                unsigned int* stat_rx_data_bytes_duplicate,
                unsigned int* stat_rx_data_pdu,
                unsigned int* stat_rx_data_bytes,
                unsigned int* stat_rx_data_pdu_dropped,
                unsigned int* stat_rx_data_bytes_dropped,
                unsigned int* stat_rx_data_pdu_out_of_window,
                unsigned int* stat_rx_data_bytes_out_of_window,
                unsigned int* stat_rx_control_pdu,
                unsigned int* stat_rx_control_bytes,
                unsigned int* stat_timer_reordering_timed_out,
                unsigned int* stat_timer_poll_retransmit_timed_out,
                unsigned int* stat_timer_status_prohibit_timed_out) {
132
//-----------------------------------------------------------------------------
133 134 135 136
    rlc_mode_t             rlc_mode        = RLC_MODE_NONE;
    rlc_union_t           *rlc_union_p     = NULL;
    hash_key_t             key             = HASHTABLE_QUESTIONABLE_KEY_VALUE;
    hashtable_rc_t         h_rc;
gauthier's avatar
gauthier committed
137 138

#ifdef OAI_EMU
139 140
    if (ctxtP->enb_flag) {
        AssertFatal ((ctxtP->enb_module_id >= oai_emulation.info.first_enb_local) && (oai_emulation.info.nb_enb_local > 0),
141
            "eNB module id is too low (%u/%d)!\n",
142
            ctxtP->enb_module_id,
143
            oai_emulation.info.first_enb_local);
144
        AssertFatal ((ctxtP->enb_module_id < (oai_emulation.info.first_enb_local + oai_emulation.info.nb_enb_local)) && (oai_emulation.info.nb_enb_local > 0),
145
            "eNB module id is too high (%u/%d)!\n",
146
            ctxtP->enb_module_id,
147
            oai_emulation.info.first_enb_local + oai_emulation.info.nb_enb_local);
148
        AssertFatal (ctxtP->ue_module_id  < NB_UE_INST,
149
            "UE module id is too high (%u/%d)!\n",
150
            ctxtP->ue_module_id,
151 152
            oai_emulation.info.first_ue_local + oai_emulation.info.nb_ue_local);
    } else {
153
        AssertFatal (ctxtP->ue_module_id  < (oai_emulation.info.first_ue_local + oai_emulation.info.nb_ue_local),
154
            "UE module id is too high (%u/%d)!\n",
155
            ctxtP->ue_module_id,
156
            oai_emulation.info.first_ue_local + oai_emulation.info.nb_ue_local);
157
        AssertFatal (ctxtP->ue_module_id  >= oai_emulation.info.first_ue_local,
158
            "UE module id is too low (%u/%d)!\n",
159
            ctxtP->ue_module_id,
160 161
            oai_emulation.info.first_ue_local);
    }
gauthier's avatar
gauthier committed
162 163
#endif
    AssertFatal (rb_idP < NB_RB_MAX, "RB id is too high (%u/%d)!\n", rb_idP, NB_RB_MAX);
164
    key = RLC_COLL_KEY_VALUE(ctxtP->enb_module_id, ctxtP->ue_module_id, ctxtP->enb_flag, rb_idP, srb_flagP);
165 166 167
    h_rc = hashtable_get(rlc_coll_p, key, (void**)&rlc_union_p);
    if (h_rc == HASH_TABLE_OK) {
        rlc_mode = rlc_union_p->mode;
gauthier's avatar
gauthier committed
168 169
    }
    switch (rlc_mode) {
gauthier's avatar
gauthier committed
170
        case RLC_MODE_NONE:
gauthier's avatar
gauthier committed
171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200
            *stat_tx_pdcp_sdu                     = 0;
            *stat_tx_pdcp_bytes                   = 0;
            *stat_tx_pdcp_sdu_discarded           = 0;
            *stat_tx_pdcp_bytes_discarded         = 0;
            *stat_tx_data_pdu                     = 0;
            *stat_tx_data_bytes                   = 0;
            *stat_tx_retransmit_pdu_by_status     = 0;
            *stat_tx_retransmit_bytes_by_status   = 0;
            *stat_tx_retransmit_pdu               = 0;
            *stat_tx_retransmit_bytes             = 0;
            *stat_tx_control_pdu                  = 0;
            *stat_tx_control_bytes                = 0;
            *stat_rx_pdcp_sdu                     = 0;
            *stat_rx_pdcp_bytes                   = 0;
            *stat_rx_data_pdus_duplicate          = 0;
            *stat_rx_data_bytes_duplicate         = 0;
            *stat_rx_data_pdu                     = 0;
            *stat_rx_data_bytes                   = 0;
            *stat_rx_data_pdu_dropped             = 0;
            *stat_rx_data_bytes_dropped           = 0;
            *stat_rx_data_pdu_out_of_window       = 0;
            *stat_rx_data_bytes_out_of_window     = 0;
            *stat_rx_control_pdu                  = 0;
            *stat_rx_control_bytes                = 0;
            *stat_timer_reordering_timed_out      = 0;
            *stat_timer_poll_retransmit_timed_out = 0;
            *stat_timer_status_prohibit_timed_out = 0;
            return RLC_OP_STATUS_BAD_PARAMETER;
            break;

gauthier's avatar
gauthier committed
201
        case RLC_MODE_AM:
202 203
            rlc_am_stat_req(ctxtP,
                            &rlc_union_p->rlc.am,
gauthier's avatar
gauthier committed
204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233
                            stat_tx_pdcp_sdu,
                            stat_tx_pdcp_bytes,
                            stat_tx_pdcp_sdu_discarded,
                            stat_tx_pdcp_bytes_discarded,
                            stat_tx_data_pdu,
                            stat_tx_data_bytes,
                            stat_tx_retransmit_pdu_by_status,
                            stat_tx_retransmit_bytes_by_status,
                            stat_tx_retransmit_pdu,
                            stat_tx_retransmit_bytes,
                            stat_tx_control_pdu,
                            stat_tx_control_bytes,
                            stat_rx_pdcp_sdu,
                            stat_rx_pdcp_bytes,
                            stat_rx_data_pdus_duplicate,
                            stat_rx_data_bytes_duplicate,
                            stat_rx_data_pdu,
                            stat_rx_data_bytes,
                            stat_rx_data_pdu_dropped,
                            stat_rx_data_bytes_dropped,
                            stat_rx_data_pdu_out_of_window,
                            stat_rx_data_bytes_out_of_window,
                            stat_rx_control_pdu,
                            stat_rx_control_bytes,
                            stat_timer_reordering_timed_out,
                            stat_timer_poll_retransmit_timed_out,
                            stat_timer_status_prohibit_timed_out);
                            return RLC_OP_STATUS_OK;
           break;

gauthier's avatar
gauthier committed
234
       case RLC_MODE_UM:
gauthier's avatar
gauthier committed
235 236 237 238 239 240 241 242 243 244 245 246
           *stat_tx_retransmit_pdu_by_status     = 0;
           *stat_tx_retransmit_bytes_by_status   = 0;
           *stat_tx_retransmit_pdu               = 0;
           *stat_tx_retransmit_bytes             = 0;
           *stat_tx_control_pdu                  = 0;
           *stat_tx_control_bytes                = 0;
           *stat_rx_data_pdu_dropped             = 0;
           *stat_rx_data_bytes_dropped           = 0;
           *stat_rx_data_pdu_out_of_window       = 0;
           *stat_rx_data_bytes_out_of_window     = 0;
           *stat_timer_poll_retransmit_timed_out = 0;
           *stat_timer_status_prohibit_timed_out = 0;
247 248
           rlc_um_stat_req (ctxtP,
                            &rlc_union_p->rlc.um,
gauthier's avatar
gauthier committed
249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268
                              stat_tx_pdcp_sdu,
                              stat_tx_pdcp_bytes,
                              stat_tx_pdcp_sdu_discarded,
                              stat_tx_pdcp_bytes_discarded,
                              stat_tx_data_pdu,
                              stat_tx_data_bytes,
                              stat_rx_pdcp_sdu,
                              stat_rx_pdcp_bytes,
                              stat_rx_data_pdus_duplicate,
                              stat_rx_data_bytes_duplicate,
                              stat_rx_data_pdu,
                              stat_rx_data_bytes,
                              stat_rx_data_pdu_dropped,
                              stat_rx_data_bytes_dropped,
                              stat_rx_data_pdu_out_of_window,
                              stat_rx_data_bytes_out_of_window,
                              stat_timer_reordering_timed_out);
           return RLC_OP_STATUS_OK;
           break;

gauthier's avatar
gauthier committed
269
       case RLC_MODE_TM:
gauthier's avatar
gauthier committed
270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329
           *stat_tx_pdcp_sdu                     = 0;
           *stat_tx_pdcp_bytes                   = 0;
           *stat_tx_pdcp_sdu_discarded           = 0;
           *stat_tx_pdcp_bytes_discarded         = 0;
           *stat_tx_data_pdu                     = 0;
           *stat_tx_data_bytes                   = 0;
           *stat_tx_retransmit_pdu_by_status     = 0;
           *stat_tx_retransmit_bytes_by_status   = 0;
           *stat_tx_retransmit_pdu               = 0;
           *stat_tx_retransmit_bytes             = 0;
           *stat_tx_control_pdu                  = 0;
           *stat_tx_control_bytes                = 0;
           *stat_rx_pdcp_sdu                     = 0;
           *stat_rx_pdcp_bytes                   = 0;
           *stat_rx_data_pdus_duplicate          = 0;
           *stat_rx_data_bytes_duplicate         = 0;
           *stat_rx_data_pdu                     = 0;
           *stat_rx_data_bytes                   = 0;
           *stat_rx_data_pdu_dropped             = 0;
           *stat_rx_data_bytes_dropped           = 0;
           *stat_rx_data_pdu_out_of_window       = 0;
           *stat_rx_data_bytes_out_of_window     = 0;
           *stat_rx_control_pdu                  = 0;
           *stat_rx_control_bytes                = 0;
           *stat_timer_reordering_timed_out      = 0;
           *stat_timer_poll_retransmit_timed_out = 0;
           *stat_timer_status_prohibit_timed_out = 0;
           return RLC_OP_STATUS_BAD_PARAMETER;
           break;

       default:
           *stat_tx_pdcp_sdu                     = 0;
           *stat_tx_pdcp_bytes                   = 0;
           *stat_tx_pdcp_sdu_discarded           = 0;
           *stat_tx_pdcp_bytes_discarded         = 0;
           *stat_tx_data_pdu                     = 0;
           *stat_tx_data_bytes                   = 0;
           *stat_tx_retransmit_pdu_by_status     = 0;
           *stat_tx_retransmit_bytes_by_status   = 0;
           *stat_tx_retransmit_pdu               = 0;
           *stat_tx_retransmit_bytes             = 0;
           *stat_tx_control_pdu                  = 0;
           *stat_tx_control_bytes                = 0;
           *stat_rx_pdcp_sdu                     = 0;
           *stat_rx_pdcp_bytes                   = 0;
           *stat_rx_data_pdus_duplicate          = 0;
           *stat_rx_data_bytes_duplicate         = 0;
           *stat_rx_data_pdu                     = 0;
           *stat_rx_data_bytes                   = 0;
           *stat_rx_data_pdu_dropped             = 0;
           *stat_rx_data_bytes_dropped           = 0;
           *stat_rx_data_pdu_out_of_window       = 0;
           *stat_rx_data_bytes_out_of_window     = 0;
           *stat_rx_control_pdu                  = 0;
           *stat_rx_control_bytes                = 0;

           *stat_timer_poll_retransmit_timed_out = 0;
           *stat_timer_status_prohibit_timed_out = 0;
           return RLC_OP_STATUS_BAD_PARAMETER;
    }
330
}
331

332
//-----------------------------------------------------------------------------
333
rlc_op_status_t rlc_data_req     (const protocol_ctxt_t* const ctxtP,
334 335 336 337
                                  const srb_flag_t   srb_flagP,
                                  const MBMS_flag_t  MBMS_flagP,
                                  const rb_id_t      rb_idP,
                                  const mui_t        muiP,
338 339
                                  confirm_t    confirmP,
                                  sdu_size_t   sdu_sizeP,
gauthier's avatar
gauthier committed
340
                                  mem_block_t *sdu_pP) {
341
//-----------------------------------------------------------------------------
342
  mem_block_t           *new_sdu_p    = NULL;
gauthier's avatar
gauthier committed
343
  rlc_mode_t             rlc_mode     = RLC_MODE_NONE;
344 345 346 347
  rlc_union_t           *rlc_union_p = NULL;
  hash_key_t             key         = HASHTABLE_QUESTIONABLE_KEY_VALUE;
  hashtable_rc_t         h_rc;

348
#ifdef Rel10
349 350
  rlc_mbms_id_t         *mbms_id_p  = NULL;
  logical_chan_id_t      log_ch_id  = 0;
351 352
#endif
#ifdef DEBUG_RLC_DATA_REQ
gauthier's avatar
gauthier committed
353
  LOG_D(RLC,"rlc_data_req: %s enb id  %u  ue id %u, rb_id %u (MAX %d), muip %d, confirmP %d, sud_sizeP %d, sdu_pP %p\n",
354 355 356
        (ctxtP->enb_flag) ? "eNB" : "UE",
        ctxtP->enb_module_id,
        ctxtP->ue_module_id,
gauthier's avatar
gauthier committed
357 358 359 360 361 362
        rb_idP,
        NB_RAB_MAX,
        muiP,
        confirmP,
        sdu_sizeP,
        sdu_pP);
363
#endif
364 365
#ifdef Rel10
#else
gauthier's avatar
gauthier committed
366
  AssertFatal(MBMS_flagP == 0, "MBMS_flagP %u", MBMS_flagP);
367
#endif
gauthier's avatar
gauthier committed
368
#ifdef OAI_EMU
369 370
  if (ctxtP->enb_flag) {
      AssertFatal ((ctxtP->enb_module_id >= oai_emulation.info.first_enb_local) && (oai_emulation.info.nb_enb_local > 0),
371
          "eNB module id is too low (%u/%d)!\n",
372
          ctxtP->enb_module_id,
373
          oai_emulation.info.first_enb_local);
374
      AssertFatal ((ctxtP->enb_module_id < (oai_emulation.info.first_enb_local + oai_emulation.info.nb_enb_local)) && (oai_emulation.info.nb_enb_local > 0),
375
          "eNB module id is too high (%u/%d)!\n",
376
          ctxtP->enb_module_id,
377
          oai_emulation.info.first_enb_local + oai_emulation.info.nb_enb_local);
378
      AssertFatal (ctxtP->ue_module_id  < NB_UE_INST,
379
          "UE module id is too high (%u/%d)!\n",
380
          ctxtP->ue_module_id,
381 382
          oai_emulation.info.first_ue_local + oai_emulation.info.nb_ue_local);
  } else {
383
      AssertFatal (ctxtP->ue_module_id  < (oai_emulation.info.first_ue_local + oai_emulation.info.nb_ue_local),
384
          "UE module id is too high (%u/%d)!\n",
385
          ctxtP->ue_module_id,
386
          oai_emulation.info.first_ue_local + oai_emulation.info.nb_ue_local);
387
      AssertFatal (ctxtP->ue_module_id  >= oai_emulation.info.first_ue_local,
388
          "UE module id is too low (%u/%d)!\n",
389
          ctxtP->ue_module_id,
390 391
          oai_emulation.info.first_ue_local);
  }
gauthier's avatar
gauthier committed
392
#endif
393 394 395 396 397
  if (MBMS_flagP) {
      AssertFatal (rb_idP < NB_RB_MBMS_MAX, "RB id is too high (%u/%d)!\n", rb_idP, NB_RB_MBMS_MAX);
  } else {
      AssertFatal (rb_idP < NB_RB_MAX, "RB id is too high (%u/%d)!\n", rb_idP, NB_RB_MAX);
  }
gauthier's avatar
gauthier committed
398
  DevAssert(sdu_pP != NULL);
399 400 401 402 403 404
  DevCheck(sdu_sizeP > 0, sdu_sizeP, 0, 0);

#ifndef Rel10
  DevCheck(MBMS_flagP == 0, MBMS_flagP, 0, 0);
#endif

405 406
  vcd_signal_dumper_dump_function_by_name(VCD_SIGNAL_DUMPER_FUNCTIONS_RLC_DATA_REQ,VCD_FUNCTION_IN);

407 408
#ifdef Rel10
  if (MBMS_flagP == TRUE) {
409 410 411
      if (ctxtP->enb_flag) {
            log_ch_id = rlc_mbms_enb_get_lcid_by_rb_id(ctxtP->enb_module_id,rb_idP);
            mbms_id_p = &rlc_mbms_lcid2service_session_id_eNB[ctxtP->enb_module_id][log_ch_id];
412
      } else {
413 414
            log_ch_id = rlc_mbms_ue_get_lcid_by_rb_id(ctxtP->ue_module_id,rb_idP);
            mbms_id_p = &rlc_mbms_lcid2service_session_id_ue[ctxtP->ue_module_id][log_ch_id];
gauthier's avatar
gauthier committed
415
      }
416
      key = RLC_COLL_KEY_MBMS_VALUE(ctxtP->enb_module_id, ctxtP->ue_module_id, ctxtP->enb_flag, mbms_id_p->service_id, mbms_id_p->session_id);
417 418 419
  } else
#endif
  {
420
      key = RLC_COLL_KEY_VALUE(ctxtP->enb_module_id, ctxtP->ue_module_id, ctxtP->enb_flag, rb_idP, srb_flagP);
421 422 423 424 425 426 427
  }

  h_rc = hashtable_get(rlc_coll_p, key, (void**)&rlc_union_p);
  if (h_rc == HASH_TABLE_OK) {
      rlc_mode = rlc_union_p->mode;
  } else {
      rlc_mode = RLC_MODE_NONE;
thomasl's avatar
thomasl committed
428
      AssertFatal (0 , "RLC not configured key %ju\n", key);
gauthier's avatar
gauthier committed
429 430
  }

431
  if (MBMS_flagP == 0) {
gauthier's avatar
gauthier committed
432
      LOG_D(RLC, "[FRAME %5u][%s][RLC][INST %u/%u][RB %u] Display of rlc_data_req:\n",
433 434 435 436
          ctxtP->frame,
          (ctxtP->enb_flag) ? "eNB" : "UE",
          ctxtP->enb_module_id,
          ctxtP->ue_module_id,
gauthier's avatar
gauthier committed
437
          rb_idP);
438
#if defined(DEBUG_RLC_PAYLOAD)
gauthier's avatar
gauthier committed
439
      rlc_util_print_hex_octets(RLC, (unsigned char*)sdu_pP->data, sdu_sizeP);
440
#endif
441 442

#ifdef DEBUG_RLC_DATA_REQ
gauthier's avatar
gauthier committed
443
      LOG_D(RLC,"RLC_TYPE : %d ",rlc_mode);
444
#endif
gauthier's avatar
gauthier committed
445
      switch (rlc_mode) {
gauthier's avatar
gauthier committed
446
          case RLC_MODE_NONE:
gauthier's avatar
gauthier committed
447
              free_mem_block(sdu_pP);
gauthier's avatar
gauthier committed
448
              LOG_E(RLC, "Received RLC_MODE_NONE as rlc_type for %s eNB id  %u, ue id %u, rb_id %u\n",
449 450 451
                    (ctxtP->enb_flag) ? "eNB" : "UE",
                    ctxtP->enb_module_id,
                    ctxtP->ue_module_id,
gauthier's avatar
gauthier committed
452
                    rb_idP);
453
              vcd_signal_dumper_dump_function_by_name(VCD_SIGNAL_DUMPER_FUNCTIONS_RLC_DATA_REQ,VCD_FUNCTION_OUT);
gauthier's avatar
gauthier committed
454
              return RLC_OP_STATUS_BAD_PARAMETER;
455

gauthier's avatar
gauthier committed
456
          case RLC_MODE_AM:
457
#ifdef DEBUG_RLC_DATA_REQ
gauthier's avatar
gauthier committed
458
              msg("RLC_MODE_AM\n");
459
#endif
460
              new_sdu_p = get_free_mem_block (sdu_sizeP + sizeof (struct rlc_am_data_req_alloc));
gauthier's avatar
gauthier committed
461

462
              if (new_sdu_p != NULL) {
gauthier's avatar
gauthier committed
463
                  // PROCESS OF COMPRESSION HERE:
464 465
                  memset (new_sdu_p->data, 0, sizeof (struct rlc_am_data_req_alloc));
                  memcpy (&new_sdu_p->data[sizeof (struct rlc_am_data_req_alloc)], &sdu_pP->data[0], sdu_sizeP);
gauthier's avatar
gauthier committed
466

467 468 469 470
                  ((struct rlc_am_data_req *) (new_sdu_p->data))->data_size = sdu_sizeP;
                  ((struct rlc_am_data_req *) (new_sdu_p->data))->conf = confirmP;
                  ((struct rlc_am_data_req *) (new_sdu_p->data))->mui  = muiP;
                  ((struct rlc_am_data_req *) (new_sdu_p->data))->data_offset = sizeof (struct rlc_am_data_req_alloc);
gauthier's avatar
gauthier committed
471 472 473
                  free_mem_block(sdu_pP);
                  LOG_D(RLC, "%s\n",RLC_FG_BRIGHT_COLOR_RED);

474
                  LOG_D(RLC, "[FRAME %5u][%s][%s][INST %u/%u][%s %u][--- RLC_AM_DATA_REQ/%d Bytes --->][RLC_AM][INST %u/%u][%s %u]\n",
475 476
                          ctxtP->frame,
                          (ctxtP->enb_flag) ? "eNB" : "UE",
477
                          (srb_flagP) ? "RRC" : "PDCP",
478 479
                          ctxtP->enb_module_id,
                          ctxtP->ue_module_id,
480
                          (srb_flagP) ? "SRB" : "DRB",
gauthier's avatar
gauthier committed
481 482
                          rb_idP,
                          sdu_sizeP,
483 484
                          ctxtP->enb_module_id,
                          ctxtP->ue_module_id,
485
                          (srb_flagP) ? "SRB" : "DRB",
gauthier's avatar
gauthier committed
486 487
                          rb_idP);
                  LOG_D(RLC, "%s\n",RLC_FG_COLOR_DEFAULT);
488 489
                  rlc_am_data_req(ctxtP, &rlc_union_p->rlc.am, new_sdu_p);
                  vcd_signal_dumper_dump_function_by_name(VCD_SIGNAL_DUMPER_FUNCTIONS_RLC_DATA_REQ,VCD_FUNCTION_OUT);
gauthier's avatar
gauthier committed
490 491
                  return RLC_OP_STATUS_OK;
              } else {
492
                  vcd_signal_dumper_dump_function_by_name(VCD_SIGNAL_DUMPER_FUNCTIONS_RLC_DATA_REQ,VCD_FUNCTION_OUT);
gauthier's avatar
gauthier committed
493 494 495 496
                  return RLC_OP_STATUS_INTERNAL_ERROR;
              }
              break;

gauthier's avatar
gauthier committed
497
          case RLC_MODE_UM:
498
            new_sdu_p = get_free_mem_block (sdu_sizeP + sizeof (struct rlc_um_data_req_alloc));
gauthier's avatar
gauthier committed
499

500
              if (new_sdu_p != NULL) {
gauthier's avatar
gauthier committed
501
                  // PROCESS OF COMPRESSION HERE:
502 503
                  memset (new_sdu_p->data, 0, sizeof (struct rlc_um_data_req_alloc));
                  memcpy (&new_sdu_p->data[sizeof (struct rlc_um_data_req_alloc)], &sdu_pP->data[0], sdu_sizeP);
gauthier's avatar
gauthier committed
504

505 506
                  ((struct rlc_um_data_req *) (new_sdu_p->data))->data_size = sdu_sizeP;
                  ((struct rlc_um_data_req *) (new_sdu_p->data))->data_offset = sizeof (struct rlc_um_data_req_alloc);
gauthier's avatar
gauthier committed
507 508
                  free_mem_block(sdu_pP);

509
                  //LOG_D(RLC, "%s\n",RLC_FG_BRIGHT_COLOR_RED);
510
                  LOG_D(RLC, "[FRAME %5u][%s][%s][INST %u/%u][%s %u][--- RLC_UM_DATA_REQ/%d Bytes --->][RLC_UM][INST %u/%u][%s %u]\n",
511 512
                          ctxtP->frame,
                          (ctxtP->enb_flag) ? "eNB" : "UE",
513
                          (srb_flagP) ? "RRC" : "PDCP",
514 515
                          ctxtP->enb_module_id,
                          ctxtP->ue_module_id,
516
                          (srb_flagP) ? "SRB" : "DRB",
gauthier's avatar
gauthier committed
517 518
                          rb_idP,
                          sdu_sizeP,
519 520
                          ctxtP->enb_module_id,
                          ctxtP->ue_module_id,
521
                          (srb_flagP) ? "SRB" : "DRB",
gauthier's avatar
gauthier committed
522
                          rb_idP);
523
                  //LOG_D(RLC, "%s\n",RLC_FG_COLOR_DEFAULT);
524
                  rlc_um_data_req(ctxtP, &rlc_union_p->rlc.um, new_sdu_p);
525

gauthier's avatar
gauthier committed
526
                  //free_mem_block(new_sdu);
527
                  vcd_signal_dumper_dump_function_by_name(VCD_SIGNAL_DUMPER_FUNCTIONS_RLC_DATA_REQ,VCD_FUNCTION_OUT);
gauthier's avatar
gauthier committed
528 529
                  return RLC_OP_STATUS_OK;
              } else {
530 531
                  vcd_signal_dumper_dump_function_by_name(VCD_SIGNAL_DUMPER_FUNCTIONS_RLC_DATA_REQ,VCD_FUNCTION_OUT);
                  return RLC_OP_STATUS_INTERNAL_ERROR;
gauthier's avatar
gauthier committed
532 533 534
              }
              break;

gauthier's avatar
gauthier committed
535
          case RLC_MODE_TM:
536
            new_sdu_p = get_free_mem_block (sdu_sizeP + sizeof (struct rlc_tm_data_req_alloc));
gauthier's avatar
gauthier committed
537

538
              if (new_sdu_p != NULL) {
gauthier's avatar
gauthier committed
539
                  // PROCESS OF COMPRESSION HERE:
540 541
                  memset (new_sdu_p->data, 0, sizeof (struct rlc_tm_data_req_alloc));
                  memcpy (&new_sdu_p->data[sizeof (struct rlc_tm_data_req_alloc)], &sdu_pP->data[0], sdu_sizeP);
gauthier's avatar
gauthier committed
542

543 544
                  ((struct rlc_tm_data_req *) (new_sdu_p->data))->data_size = sdu_sizeP;
                  ((struct rlc_tm_data_req *) (new_sdu_p->data))->data_offset = sizeof (struct rlc_tm_data_req_alloc);
gauthier's avatar
gauthier committed
545 546
                  free_mem_block(sdu_pP);
                  LOG_D(RLC, "%s\n",RLC_FG_BRIGHT_COLOR_RED);
547
                  LOG_D(RLC, "[FRAME %5u][%s][%s][INST %u/%u][%s %u][--- RLC_TM_DATA_REQ/%d Bytes --->][RLC_TM][INST %u/%u][%s %u]\n",
548 549
                                 ctxtP->frame,
                                 (ctxtP->enb_flag) ? "eNB" : "UE",
550
                                 (srb_flagP) ? "RRC" : "PDCP",
551 552
                                 ctxtP->enb_module_id,
                                 ctxtP->ue_module_id,
553
                                 (srb_flagP) ? "SRB" : "DRB",
gauthier's avatar
gauthier committed
554 555
                                 rb_idP,
                                 sdu_sizeP,
556 557
                                 ctxtP->enb_module_id,
                                 ctxtP->ue_module_id,
558
                                 (srb_flagP) ? "SRB" : "DRB",
gauthier's avatar
gauthier committed
559 560
                                 rb_idP);
                  LOG_D(RLC, "%s\n",RLC_FG_COLOR_DEFAULT);
561
                  rlc_tm_data_req(ctxtP, &rlc_union_p->rlc.tm, new_sdu_p);
562
                  vcd_signal_dumper_dump_function_by_name(VCD_SIGNAL_DUMPER_FUNCTIONS_RLC_DATA_REQ,VCD_FUNCTION_OUT);
gauthier's avatar
gauthier committed
563 564 565
                  return RLC_OP_STATUS_OK;
              } else {
                  //handle_event(ERROR,"FILE %s FONCTION rlc_data_req() LINE %s : out of memory\n", __FILE__, __LINE__);
566 567
                  vcd_signal_dumper_dump_function_by_name(VCD_SIGNAL_DUMPER_FUNCTIONS_RLC_DATA_REQ,VCD_FUNCTION_OUT);
                  return RLC_OP_STATUS_INTERNAL_ERROR;
gauthier's avatar
gauthier committed
568 569 570 571 572
              }
              break;

          default:
              free_mem_block(sdu_pP);
573
              vcd_signal_dumper_dump_function_by_name(VCD_SIGNAL_DUMPER_FUNCTIONS_RLC_DATA_REQ,VCD_FUNCTION_OUT);
gauthier's avatar
gauthier committed
574 575 576
              return RLC_OP_STATUS_INTERNAL_ERROR;

      }
577

578
#ifdef Rel10
579
  } else { /* MBMS_flag != 0 */
580
	  //  LOG_I(RLC,"DUY rlc_data_req: mbms_rb_id in RLC instant is: %d\n", mbms_rb_id);
gauthier's avatar
gauthier committed
581
          if (sdu_pP != NULL) {
582 583
              if (sdu_sizeP > 0) {
                  LOG_I(RLC,"received a packet with size %d for MBMS \n", sdu_sizeP);
584 585
                  new_sdu_p = get_free_mem_block (sdu_sizeP + sizeof (struct rlc_um_data_req_alloc));
                  if (new_sdu_p != NULL) {
586
                      // PROCESS OF COMPRESSION HERE:
587 588 589 590
                      memset (new_sdu_p->data, 0, sizeof (struct rlc_um_data_req_alloc));
                      memcpy (&new_sdu_p->data[sizeof (struct rlc_um_data_req_alloc)], &sdu_pP->data[0], sdu_sizeP);
                      ((struct rlc_um_data_req *) (new_sdu_p->data))->data_size = sdu_sizeP;
                      ((struct rlc_um_data_req *) (new_sdu_p->data))->data_offset = sizeof (struct rlc_um_data_req_alloc);
gauthier's avatar
gauthier committed
591
                      free_mem_block(sdu_pP);
592
                      LOG_D(RLC, "%s\n",RLC_FG_BRIGHT_COLOR_RED);
593
                          LOG_D(RLC, "[FRAME %5u][%s][%s][INST %u/%u][RB %u][--- RLC_UM_DATA_REQ/%d Bytes (MBMS) --->][RLC_UM][INST %u/%u][RB %u]\n",
594 595
                            ctxtP->frame,
                            (ctxtP->enb_flag) ? "eNB" : "UE",
596
                            (srb_flagP) ? "RRC" : "PDCP",
597 598
                            ctxtP->enb_module_id,
                            ctxtP->ue_module_id,
gauthier's avatar
gauthier committed
599 600
                            rb_idP,
                            sdu_sizeP,
601 602
                            ctxtP->enb_module_id,
                            ctxtP->ue_module_id,
603
                            rb_idP);
604
                      LOG_D(RLC, "%s\n",RLC_FG_COLOR_DEFAULT);
605
                      rlc_um_data_req(ctxtP, &rlc_union_p->rlc.um, new_sdu_p);
606 607

                      //free_mem_block(new_sdu);
608
                      vcd_signal_dumper_dump_function_by_name(VCD_SIGNAL_DUMPER_FUNCTIONS_RLC_DATA_REQ,VCD_FUNCTION_OUT);
609 610
                      return RLC_OP_STATUS_OK;
                  } else {
611
                      vcd_signal_dumper_dump_function_by_name(VCD_SIGNAL_DUMPER_FUNCTIONS_RLC_DATA_REQ,VCD_FUNCTION_OUT);
612 613 614
                      return RLC_OP_STATUS_BAD_PARAMETER;
                  }
              } else {
615
                  vcd_signal_dumper_dump_function_by_name(VCD_SIGNAL_DUMPER_FUNCTIONS_RLC_DATA_REQ,VCD_FUNCTION_OUT);
616 617 618
                  return RLC_OP_STATUS_BAD_PARAMETER;
              }
          } else {
619
              vcd_signal_dumper_dump_function_by_name(VCD_SIGNAL_DUMPER_FUNCTIONS_RLC_DATA_REQ,VCD_FUNCTION_OUT);
620 621
              return RLC_OP_STATUS_BAD_PARAMETER;
          }
622 623 624
  }
#else
  } else {/* MBMS_flag != 0 */
gauthier's avatar
gauthier committed
625
    free_mem_block(sdu_pP);
626
    LOG_E(RLC, "MBMS_flag != 0 while Rel10 is not defined...\n");
627
    //handle_event(ERROR,"FILE %s FONCTION rlc_data_req() LINE %s : parameter module_id out of bounds :%d\n", __FILE__, __LINE__, module_idP);
628
    vcd_signal_dumper_dump_function_by_name(VCD_SIGNAL_DUMPER_FUNCTIONS_RLC_DATA_REQ,VCD_FUNCTION_OUT);
629
    return RLC_OP_STATUS_BAD_PARAMETER;
630
  }
631
#endif
632 633 634
}

//-----------------------------------------------------------------------------
635
void rlc_data_ind     (
636 637 638 639 640 641
                const protocol_ctxt_t* const ctxtP,
                const srb_flag_t  srb_flagP,
                const MBMS_flag_t MBMS_flagP,
                const rb_id_t     rb_idP,
                const sdu_size_t  sdu_sizeP,
                mem_block_t      *sdu_pP) {
642
//-----------------------------------------------------------------------------
gauthier's avatar
gauthier committed
643 644


645
#if defined(DEBUG_RLC_PAYLOAD)
646
  LOG_D(RLC, "[FRAME %5u][%s][RLC][INST %u/%u][%s %u] Display of rlc_data_ind: size %u\n",
647 648 649 650
        ctxtP->frame,
        (ctxtP->enb_flag) ? "eNB" : "UE",
        ctxtP->enb_module_id,
        ctxtP->ue_module_id,
651
        (srb_flagP) ? "SRB" : "DRB",
gauthier's avatar
gauthier committed
652 653 654 655
        rb_idP,
        sdu_sizeP);

  rlc_util_print_hex_octets(RLC, (unsigned char*)sdu_pP->data, sdu_sizeP);
656
#endif
657
  LOG_D(RLC, "[FRAME %5u][%s][RLC][INST %u/%u][%s %u][--- RLC_DATA_IND/%d Bytes --->][PDCP][INST %u/%u][%s %u]\n",
658 659 660 661
      ctxtP->frame,
      (ctxtP->enb_flag) ? "eNB" : "UE",
      ctxtP->enb_module_id,
      ctxtP->ue_module_id,
662 663 664
      (srb_flagP) ? "SRB" : "DRB",
      rb_idP,
      sdu_sizeP,
665 666
      ctxtP->enb_module_id,
      ctxtP->ue_module_id,
667 668 669 670
      (srb_flagP) ? "SRB" : "DRB",
      rb_idP);

  pdcp_data_ind (
671
      ctxtP,
672 673 674 675 676
      srb_flagP,
      MBMS_flagP,
      rb_idP,
      sdu_sizeP,
      sdu_pP);
677 678
}
//-----------------------------------------------------------------------------
679
void rlc_data_conf     (const protocol_ctxt_t* const ctxtP,
680 681 682 683
                        const srb_flag_t      srb_flagP,
                        const rb_id_t         rb_idP,
                        const mui_t           muiP,
                        const rlc_tx_status_t statusP) {
684
//-----------------------------------------------------------------------------
685 686

    if (srb_flagP) {
687 688
        if (rlc_rrc_data_conf != NULL) {
            LOG_D(RLC, "%s\n",RLC_FG_BRIGHT_COLOR_RED);
689
            LOG_D(RLC, "[FRAME %5u][%s][RLC_AM][INST %u/%u][%s %u][--- RLC_DATA_CONF /MUI %d --->][%s][INST %u/%u][][RLC_DATA_CONF/ MUI %d]\n",
690 691 692 693
                ctxtP->frame,
                (ctxtP->enb_flag) ? "eNB" : "UE",
                ctxtP->enb_module_id,
                ctxtP->ue_module_id,
694 695 696 697
                (srb_flagP) ? "SRB" : "DRB",
                rb_idP,
                muiP,
                (srb_flagP) ? "RRC" : "PDCP",
698 699
                ctxtP->enb_module_id,
                ctxtP->ue_module_id,
700 701
                muiP);

702
            LOG_D(RLC, "%s\n",RLC_FG_COLOR_DEFAULT);
703
            rlc_rrc_data_conf (ctxtP, rb_idP , muiP, statusP);
704 705 706 707 708
        }
    }
}
//-----------------------------------------------------------------------------
int
709
rlc_module_init (void)
710 711
{
//-----------------------------------------------------------------------------
gauthier's avatar
gauthier committed
712 713 714
   int          k;
   module_id_t  module_id1;

715 716 717
   LOG_D(RLC, "MODULE INIT\n");
   rlc_rrc_data_ind  = NULL;
   rlc_rrc_data_conf = NULL;
gauthier's avatar
gauthier committed
718

719 720
   rlc_coll_p = hashtable_create ((maxDRB + 2) * 16, NULL, rb_free_rlc_union);
   AssertFatal(rlc_coll_p != NULL, "UNRECOVERABLE error, RLC hashtable_create failed");
gauthier's avatar
gauthier committed
721 722

   for (module_id1=0; module_id1 < NUMBER_OF_UE_MAX; module_id1++) {
gauthier's avatar
gauthier committed
723
#if defined(Rel10)
724 725 726 727
      for (k=0; k < RLC_MAX_MBMS_LC; k++) {
          rlc_mbms_lcid2service_session_id_ue[module_id1][k].service_id = 0;
          rlc_mbms_lcid2service_session_id_ue[module_id1][k].session_id = 0;
      }
728 729 730
      for (k=0; k < NB_RB_MBMS_MAX; k++) {
          rlc_mbms_rbid2lcid_eNB[module_id1][k] = RLC_LC_UNALLOCATED;
      }
gauthier's avatar
gauthier committed
731
#endif
732
   }
gauthier's avatar
gauthier committed
733 734

   for (module_id1=0; module_id1 < NUMBER_OF_eNB_MAX; module_id1++) {
gauthier's avatar
gauthier committed
735
#if defined(Rel10)
736 737 738 739
      for (k=0; k < RLC_MAX_MBMS_LC; k++) {
          rlc_mbms_lcid2service_session_id_eNB[module_id1][k].service_id = 0;
          rlc_mbms_lcid2service_session_id_eNB[module_id1][k].session_id = 0;
      }
740 741 742
      for (k=0; k < NB_RB_MBMS_MAX; k++) {
          rlc_mbms_rbid2lcid_ue[module_id1][k] = RLC_LC_UNALLOCATED;
      }
gauthier's avatar
gauthier committed
743
#endif
gauthier's avatar
gauthier committed
744 745
   }

746 747 748 749 750 751
   pool_buffer_init();

   return(0);
}
//-----------------------------------------------------------------------------
void
752
rlc_module_cleanup (void)
753 754
//-----------------------------------------------------------------------------
{
755
    hashtable_destroy(rlc_coll_p);
756 757 758
}
//-----------------------------------------------------------------------------
void
759
rlc_layer_init (void)
760 761 762 763 764
{
//-----------------------------------------------------------------------------
}
//-----------------------------------------------------------------------------
void
765
rlc_layer_cleanup (void)
766 767 768 769
//-----------------------------------------------------------------------------
{
}