Commit dd43752b authored by Laurent's avatar Laurent

add thread pool init

parent 910a130e
...@@ -2145,6 +2145,11 @@ set (GTPV1U_SRC ...@@ -2145,6 +2145,11 @@ set (GTPV1U_SRC
add_library(GTPV1U ${GTPV1U_SRC}) add_library(GTPV1U ${GTPV1U_SRC})
add_dependencies(GTPV1U rrc_flag) add_dependencies(GTPV1U rrc_flag)
add_library (GTPV1U_OCP
${OPENAIR3_DIR}/ocp-gtp/gtp_itf.cpp
)
include_directories(${OPENAIR3_DIR}/ocp-gtp)
#NR case #NR case
set (NR_GTPV1U_SRC set (NR_GTPV1U_SRC
${NR_RRC_DIR}/rrc_gNB_GTPV1U.c ${NR_RRC_DIR}/rrc_gNB_GTPV1U.c
......
...@@ -258,6 +258,12 @@ void init_gNB_proc(int inst) { ...@@ -258,6 +258,12 @@ void init_gNB_proc(int inst) {
proc->RU_mask_tx = (1<<gNB->num_RU)-1; proc->RU_mask_tx = (1<<gNB->num_RU)-1;
proc->RU_mask_prach =0; proc->RU_mask_prach =0;
pthread_mutex_init( &gNB->UL_INFO_mutex, NULL); pthread_mutex_init( &gNB->UL_INFO_mutex, NULL);
gNB->threadPool = (tpool_t*)malloc(sizeof(tpool_t));
gNB->respDecode = (notifiedFIFO_t*) malloc(sizeof(notifiedFIFO_t));
char ul_pool[] = "-1,-1";
initTpool(ul_pool, gNB->threadPool, false);
initNotifiedFIFO(gNB->respDecode);
} }
/// eNB kept in function name for nffapi calls, TO FIX /// eNB kept in function name for nffapi calls, TO FIX
......
...@@ -32,7 +32,9 @@ ...@@ -32,7 +32,9 @@
#ifndef __PHY_DEFS_NB_IOT__H__ #ifndef __PHY_DEFS_NB_IOT__H__
#define __PHY_DEFS_NB_IOT__H__ #define __PHY_DEFS_NB_IOT__H__
#ifndef _GNU_SOURCE
#define _GNU_SOURCE #define _GNU_SOURCE
#endif
#include <stdio.h> #include <stdio.h>
#include <stdlib.h> #include <stdlib.h>
#include <malloc.h> #include <malloc.h>
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment