mirror/RetroArch
1
0
Fork 0
mirror of https://github.com/libretro/RetroArch synced 2025-03-30 16:20:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

add blocking task type that only allows one instance in the queue

Browse Source
This commit is contained in:
Brad Parker 2016-10-02 19:03:34 -04:00
parent 88d70d7da6
commit 795fd0cfa3
3 changed files with 38 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
libretro-common/include/queues/task_queue.h
View File

@ -32,6 +32,16 @@
RETRO_BEGIN_DECLS
enum task_type
{
TASK_TYPE_NONE,
/* Only one blocking task can exist in the queue at a time.
* Attempts to add a new one while another is running is
* ignored.
*/
TASK_TYPE_BLOCKING
};
enum task_queue_ctl_state
{
TASK_QUEUE_CTL_NONE = 0,
@ -158,6 +168,8 @@ struct retro_task
* free()d automatically if non-NULL. */
char *title;
enum task_type type;
/* don't touch this. */
retro_task_t *next;
};

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

@ -571,9 +571,30 @@ bool task_queue_ctl(enum task_queue_ctl_state state, void *data)
break;
case TASK_QUEUE_CTL_PUSH:
{
retro_task_t *task = (retro_task_t*)data;
/* Ignore this task if a related one is already running */
if (task->type == TASK_TYPE_BLOCKING)
{
retro_task_t *running = tasks_running.front;
bool found = false;
for (; running; running = running->next)
{
if (running->type == TASK_TYPE_BLOCKING)
{
found = true;
break;
}
}
/* skip this task, user must try again later */
if (found)
break;
}
/* The lack of NULL checks in the following functions
* is proposital to ensure correct control flow by the users. */
retro_task_t *task = (retro_task_t*)data;
impl_current->push_running(task);
break;
}

5
tasks/task_save.c
View File

@ -614,6 +614,7 @@ static void task_push_undo_save_state(const char *path, void *data, size_t size)
state->size = size;
state->undo_save = true;
task->type = TASK_TYPE_BLOCKING;
task->state = state;
task->handler = task_save_handler;
task->callback = undo_save_state_cb;
@ -945,6 +946,7 @@ static void task_push_save_state(const char *path, void *data, size_t size)
state->data = data;
state->size = size;
task->type = TASK_TYPE_BLOCKING;
task->state = state;
task->handler = task_save_handler;
task->title = strdup(msg_hash_to_str(MSG_SAVING_STATE));
@ -1001,7 +1003,7 @@ static void task_push_load_and_save_state(const char *path, void *data, size_t s
state->undo_data = data;
task->state = state;
task->type = TASK_TYPE_BLOCKING;
task->handler = task_load_handler;
task->callback = content_load_and_save_state_cb;
task->title = strdup(msg_hash_to_str(MSG_LOADING_STATE));
@ -1122,6 +1124,7 @@ bool content_load_state(const char *path, bool load_to_backup_buffer, bool autol
state->load_to_backup_buffer = load_to_backup_buffer;
state->autoload = autoload;
task->type = TASK_TYPE_BLOCKING;
task->state = state;
task->handler = task_load_handler;
task->callback = content_load_state_cb;