maki/openairinterface5g
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add external visibility for itti_create_queue

Browse Source
This commit is contained in:
Laurent
2020-12-23 14:29:40 +01:00
parent 42a110338c
commit a432feda3e
2 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/utils/ocp_itti/intertask_interface.cpp
+2 -1
View File
@@ -336,7 +336,7 @@ extern "C" {
usleep(100*1000); // Allow the tasks to receive the message before going returning to main thread usleep(100*1000); // Allow the tasks to receive the message before going returning to main thread
} }
void itti_create_queue(const task_info_t *task_info) { int itti_create_queue(const task_info_t *task_info) {
pthread_mutex_lock (&lock_nb_queues); pthread_mutex_lock (&lock_nb_queues);
int newQueue=nb_queues; int newQueue=nb_queues;
nb_queues++; nb_queues++;
@@ -351,6 +351,7 @@ extern "C" {
if (tasks[newQueue].admin.threadFunc != NULL) if (tasks[newQueue].admin.threadFunc != NULL)
itti_create_task((task_id_t)newQueue, tasks[newQueue].admin.threadFunc, NULL); itti_create_task((task_id_t)newQueue, tasks[newQueue].admin.threadFunc, NULL);
return newQueue;
} }
int itti_init(task_id_t task_max, int itti_init(task_id_t task_max,
common/utils/ocp_itti/intertask_interface.h
+2
View File
@@ -501,6 +501,8 @@ int itti_create_task(task_id_t task_id,
void *(*start_routine) (void *), void *(*start_routine) (void *),
void *args_p); void *args_p);
int itti_create_queue(const task_info_t *task_info);
/** \brief Exit the current task. /** \brief Exit the current task.
**/ **/
void itti_exit_task(void); void itti_exit_task(void);