X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=resource%2Fcsdk%2Fconnectivity%2Fsrc%2Fcaqueueingthread.c;h=b41a73a2f16798ab0896d3472b05ad4ed32aae9d;hb=966700a71110e415e8d3049cbe59c624929a9dff;hp=c410be948f05e0d36801ab37181199b38870f073;hpb=84ddde8349acc67db8f013a2f3737669d986bffc;p=platform%2Fupstream%2Fiotivity.git diff --git a/resource/csdk/connectivity/src/caqueueingthread.c b/resource/csdk/connectivity/src/caqueueingthread.c index c410be9..b41a73a 100644 --- a/resource/csdk/connectivity/src/caqueueingthread.c +++ b/resource/csdk/connectivity/src/caqueueingthread.c @@ -60,17 +60,20 @@ static void CAQueueingThreadBaseRoutine(void *threadValue) 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;