@@ -126,7 +126,7 @@ static retro_task_t *task_queue_get(task_queue_t *queue)
126126 if (task )
127127 {
128128 queue -> front = task -> next ;
129- task -> next = NULL ;
129+ task -> next = NULL ;
130130 }
131131
132132 return task ;
@@ -208,13 +208,8 @@ static void retro_task_regular_reset(void)
208208 task -> cancelled = true;
209209}
210210
211- static void retro_task_regular_init (void )
212- {
213- }
214-
215- static void retro_task_regular_deinit (void )
216- {
217- }
211+ static void retro_task_regular_init (void ) { }
212+ static void retro_task_regular_deinit (void ) { }
218213
219214static bool retro_task_regular_find (retro_task_finder_t func , void * user_data )
220215{
@@ -407,7 +402,7 @@ static bool retro_task_threaded_find(
407402 retro_task_finder_t func , void * user_data )
408403{
409404 retro_task_t * task = NULL ;
410- bool result = false;
405+ bool result = false;
411406
412407 slock_lock (running_lock );
413408 for (task = tasks_running .front ; task ; task = task -> next )
@@ -442,7 +437,7 @@ static void threaded_worker(void *userdata)
442437 for (;;)
443438 {
444439 retro_task_t * task = NULL ;
445- bool finished = false;
440+ bool finished = false;
446441
447442 if (!worker_continue )
448443 break ; /* should we keep running until all tasks finished? */
@@ -598,7 +593,7 @@ void task_queue_check(void)
598593{
599594#ifdef HAVE_THREADS
600595 bool current_threaded = (impl_current == & impl_threaded );
601- bool want_threaded = task_queue_is_threaded () ;
596+ bool want_threaded = task_threaded_enable ;
602597
603598 if (want_threaded != current_threaded )
604599 task_queue_deinit ();
@@ -616,7 +611,7 @@ bool task_queue_push(retro_task_t *task)
616611 if (task -> type == TASK_TYPE_BLOCKING )
617612 {
618613 retro_task_t * running = NULL ;
619- bool found = false;
614+ bool found = false;
620615
621616 SLOCK_LOCK (queue_lock );
622617 running = tasks_running .front ;
@@ -669,7 +664,7 @@ void *task_queue_retriever_info_next(task_retriever_info_t **link)
669664 /* Grab data and move to next link */
670665 if (* link )
671666 {
672- data = (* link )-> data ;
667+ data = (* link )-> data ;
673668 * link = (* link )-> next ;
674669 }
675670
0 commit comments