Skip to content

O
OpenXG-RAN
Commit 18b3189d authored by Sakthivel Velumani's avatar Sakthivel Velumani
Browse files
Options

Fix to support subscribing event from external thread

parent 474cde3b
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 7 deletions
common/utils/ocp_itti/intertask_interface.cpp
View file @ 18b3189d
...@@ -274,16 +274,12 @@ extern "C" { ...@@ -274,16 +274,12 @@ extern "C" {
struct epoll_event events[t->nb_fd_epoll]; struct epoll_event events[t->nb_fd_epoll];
// Weird condition to deal with crap legacy itti interface // Weird condition to deal with crap legacy itti interface
if ( t->nb_fd_epoll == 1 ) { if (t->message_queue.empty()) {
while (t->message_queue.empty()) { do {
itti_get_events_locked(task_id, events, t->nb_fd_epoll);
pthread_mutex_lock(&t->queue_cond_lock);
}
} else {
if (t->message_queue.empty()) {
itti_get_events_locked(task_id, events, t->nb_fd_epoll); itti_get_events_locked(task_id, events, t->nb_fd_epoll);
pthread_mutex_lock(&t->queue_cond_lock); pthread_mutex_lock(&t->queue_cond_lock);
} }
while (t->message_queue.empty() && t->nb_fd_epoll == 1);
} }
// Legacy design: we return even if we have no message // Legacy design: we return even if we have no message
......
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