mirror/RetroArch
1
0
Fork 0
mirror of https://github.com/libretro/RetroArch synced 2025-02-20 06:40:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Cleanups

Browse Source
This commit is contained in:
twinaphex 2016-05-08 16:25:26 +02:00
parent e2090dc02d
commit 60789e0141
1 changed files with 29 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
libretro-common/queues/task_queue.c
View File

@ -115,34 +115,6 @@ static retro_task_t *task_queue_get(task_queue_t *queue)
return task;
}
static void task_queue_remove(task_queue_t *queue, retro_task_t *task)
{
retro_task_t *t;
/* Remove first element if needed */
if (task == queue->front)
{
queue->front = task->next;
task->next = NULL;
return;
}
/* Parse queue */
t = queue->front;
while (t && t->next)
{
/* Remove task and update queue */
if (t->next == task)
{
t->next = task->next;
task->next = NULL;
break;
}
/* Update iterator */
t = t->next;
}
}
static void retro_task_internal_gather(void)
{
@ -294,6 +266,35 @@ static scond_t *worker_cond = NULL;
static sthread_t *worker_thread = NULL;
static bool worker_continue = true; /* use running_lock when touching it */
static void task_queue_remove(task_queue_t *queue, retro_task_t *task)
{
retro_task_t *t = NULL;
/* Remove first element if needed */
if (task == queue->front)
{
queue->front = task->next;
task->next = NULL;
return;
}
/* Parse queue */
t = queue->front;
while (t && t->next)
{
/* Remove task and update queue */
if (t->next == task)
{
t->next = task->next;
task->next = NULL;
break;
}
/* Update iterator */
t = t->next;
}
}
static void retro_task_threaded_push_running(retro_task_t *task)
{
slock_lock(running_lock);