OIC_LOG(DEBUG, TAG, "wake up..");
}
- // mutex unlock
- ca_mutex_unlock(thread->threadMutex);
+
// check stop flag
if (thread->isStop)
{
+ // mutex unlock
+ ca_mutex_unlock(thread->threadMutex);
continue;
}
// get data
u_queue_message_t *message = u_queue_get_element(thread->dataQueue);
+ // mutex unlock
+ ca_mutex_unlock(thread->threadMutex);
if (NULL == message)
{
continue;