Start PDCP task

openair2/LAYER2/PDCP_v10.1.0/pdcp.c

@@ -1006,13 +1006,15 @@ void pdcp_update_stats(const protocol_ctxt_t* const  ctxt_pP){
 
 #if defined(ENABLE_ITTI)
 //-----------------------------------------------------------------------------
-void
+void *
 pdcp_task(void *arg)
 {
 //-----------------------------------------------------------------------------
   MessageDef      *msg_p;
   int              result;
   instance_t       instance;
+  /* mark in context whether it is an UE or eNodeB */
+  ctxt.enb_flag = *(int *)arg;
 
   LOG_I(PDCP, "Starting PDCP task\n");
   itti_mark_task_ready(TASK_PDCP);

openair2/LAYER2/PDCP_v10.1.0/pdcp.h

@@ -366,14 +366,14 @@ boolean_t pdcp_remove_UE(
 */
 //void rrc_pdcp_config_release ( const protocol_ctxt_t* const  ctxt_pP, rb_id_t);
 
-/*! \fn void pdcp_task(void *args)
+/*! \fn void *pdcp_task(void *args)
 * \brief Runs PDCP task to let it handle incoming/outgoing SDUs
 * \param[in]  args initial args
 * \return none
 * \note None
 * @ingroup _pdcp
 */
-void pdcp_task(void *args);
+void *pdcp_task(void *args);
 int pdcp_module_init     (void);
 void pdcp_module_cleanup (void);
 void pdcp_layer_init     (void);

targets/COMMON/create_tasks.c

@@ -40,6 +40,7 @@
 # include "f1ap_cu_task.h"
 # include "f1ap_du_task.h"
 # include "enb_app.h"
+# include "pdcp.h"
 
 extern RAN_CONTEXT_t RC;
 extern int emulate_rf;
@@ -85,10 +86,9 @@ int create_tasks(uint32_t enb_nb)
     if (enb_nb > 0) {
       rc = itti_create_task(TASK_CU_F1, F1AP_CU_task, NULL);
       AssertFatal(rc >= 0, "Create task for CU F1AP failed\n");
-      //RS/BK: Fix me!
-      rc = itti_create_task (TASK_L2L1, l2l1_task, NULL);
-      AssertFatal(rc >= 0, "Create task for L2L1 failed\n");
-
+      int is_enb = 1;
+      rc = itti_create_task (TASK_PDCP, pdcp_task, &is_enb);
+      AssertFatal(rc >= 0, "Create task for PDCP failed\n");
     }
     /* fall through */
   case ngran_eNB:

targets/COMMON/create_tasks_ue.c

@@ -39,6 +39,7 @@
 #   include "RRC/LTE/rrc_defs.h"
 # endif
 # include "enb_app.h"
+# include "pdcp.h"
 
 int create_tasks_ue(uint32_t ue_nb)
 {
@@ -49,6 +50,11 @@ int create_tasks_ue(uint32_t ue_nb)
     LOG_E(PDCP, "Create task for L2L1 failed\n");
     return -1;
   }
+  int is_enb = 0;
+  if (itti_create_task (TASK_PDCP, pdcp_task, &is_enb) < 0) {
+    LOG_E(PDCP, "Create task for PDCP failed\n");
+    return -1;
+  }
 
 #      if defined(ENABLE_USE_MME)
 #      if defined(NAS_BUILT_IN_UE)
@@ -77,4 +83,4 @@ int create_tasks_ue(uint32_t ue_nb)
 
   return 0;
 }
-#endif
+#endif
\ No newline at end of file