bool event_driven_thread::push_thread_event(int type, void* data)
{
+ bool ret = false;
if (g_atomic_int_get(&thread_info.is_running)) {
event_message_s* event = new(std::nothrow) event_message_s;
IF_FAIL_RETURN_TAG(event, false, _E, "Memory allocation failed");
event->type = type;
event->data = data;
g_async_queue_push(thread_info.event_queue, event);
- return true;
+ ret = true;
} else {
// If failed, free the received data object & return false.
delete_thread_event(type, data);
- return false;
+ ret = false;
}
+ return ret;
}
gpointer event_driven_thread::thread_func_wrapper(gpointer func)