From: cedric Date: Mon, 4 Oct 2010 15:24:34 +0000 (+0000) Subject: * ecore: remove thread from the correct list. X-Git-Tag: build/2012-07-04.173327~1628 X-Git-Url: http://review.tizen.org/git/?a=commitdiff_plain;h=8d2e518aee1316e647dd1ed171fbac4af3f30d24;p=profile%2Fivi%2Fecore.git * ecore: remove thread from the correct list. git-svn-id: http://svn.enlightenment.org/svn/e/trunk/ecore@53029 7cbeb6ba-43b4-40fd-8cce-4c39aea84d33 --- diff --git a/src/lib/ecore/ecore_thread.c b/src/lib/ecore/ecore_thread.c index c8a5daf..3dcf78c 100644 --- a/src/lib/ecore/ecore_thread.c +++ b/src/lib/ecore/ecore_thread.c @@ -504,30 +504,49 @@ ecore_thread_cancel(Ecore_Thread *thread) #ifdef EFL_HAVE_PTHREAD Ecore_Pthread_Worker *work = (Ecore_Pthread_Worker *)thread; Eina_List *l; - + if (!work) - return EINA_TRUE; - + return EINA_TRUE; + if (work->cancel) + return EINA_FALSE; + pthread_mutex_lock(&_ecore_pending_job_threads_mutex); - + if ((have_main_loop_thread) && (pthread_equal(main_loop_thread, pthread_self()))) { - EINA_LIST_FOREACH(_ecore_pending_job_threads, l, work) - { - if ((void *) work == (void *) thread) - { - _ecore_pending_job_threads = eina_list_remove_list(_ecore_pending_job_threads, l); - - pthread_mutex_unlock(&_ecore_pending_job_threads_mutex); - - if (work->func_cancel) - work->func_cancel((void *) work->data); - free(work); - - return EINA_TRUE; - } - } + if (!work->feedback_run) + EINA_LIST_FOREACH(_ecore_pending_job_threads, l, work) + { + if ((void *) work == (void *) thread) + { + _ecore_pending_job_threads = eina_list_remove_list(_ecore_pending_job_threads, l); + + pthread_mutex_unlock(&_ecore_pending_job_threads_mutex); + + if (work->func_cancel) + work->func_cancel((void *) work->data); + free(work); + + return EINA_TRUE; + } + } + else + EINA_LIST_FOREACH(_ecore_pending_job_threads_feedback, l, work) + { + if ((void *) work == (void *) thread) + { + _ecore_pending_job_threads_feedback = eina_list_remove_list(_ecore_pending_job_threads_feedback, l); + + pthread_mutex_unlock(&_ecore_pending_job_threads_mutex); + + if (work->func_cancel) + work->func_cancel((void *) work->data); + free(work); + + return EINA_TRUE; + } + } } pthread_mutex_unlock(&_ecore_pending_job_threads_mutex);