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

push save state into background for cores that need the emulator to be running to correctly save states

Browse Source
This commit is contained in:
Sven 2018-08-30 11:21:31 -04:00
parent 977eac2601
commit b8ab6c1e74
1 changed files with 82 additions and 64 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

146
tasks/task_save.c
View File

@ -555,6 +555,33 @@ static void task_save_handler_finished(retro_task_t *task,
free(state);
}
void* get_serialized_data(const char *path, size_t serial_size)
{
retro_ctx_serialize_info_t serial_info;
bool ret = false;
void *data = NULL;
data = malloc(serial_size);
if (!data)
return NULL;
RARCH_LOG("%s: %d %s.\n",
msg_hash_to_str(MSG_STATE_SIZE),
(int)serial_size,
msg_hash_to_str(MSG_BYTES));
serial_info.data = data;
serial_info.size = serial_size;
ret = core_serialize(&serial_info);
if ( !ret )
{
free(data) ;
return NULL ;
}
return data ;
}
/**
* task_save_handler:
* @task : the task being worked on
@ -576,9 +603,22 @@ static void task_save_handler(retro_task_t *task)
return;
}
if (!state->data)
{
state->data = get_serialized_data(state->path, state->size) ;
}
remaining = MIN(state->size - state->written, SAVE_STATE_CHUNK);
written = (int)intfstream_write(state->file,
(uint8_t*)state->data + state->written, remaining);
if ( state->data )
{
written = (int)intfstream_write(state->file,
(uint8_t*)state->data + state->written, remaining);
}
else
{
written = 0 ;
}
state->written += written;
@ -1134,6 +1174,7 @@ error:
free(task);
}
/**
* content_save_state:
* @path : path of saved state that shall be written to.
@ -1144,85 +1185,62 @@ error:
**/
bool content_save_state(const char *path, bool save_to_disk, bool autosave)
{
retro_ctx_serialize_info_t serial_info;
//retro_ctx_serialize_info_t serial_info;
retro_ctx_size_info_t info;
bool ret = false;
void *data = NULL;
core_serialize_size(&info);
RARCH_LOG("%s: \"%s\".\n",
msg_hash_to_str(MSG_SAVING_STATE),
path);
if (info.size == 0)
return false;
data = malloc(info.size);
if (!data)
return false;
RARCH_LOG("%s: %d %s.\n",
msg_hash_to_str(MSG_STATE_SIZE),
(int)info.size,
msg_hash_to_str(MSG_BYTES));
serial_info.data = data;
serial_info.size = info.size;
ret = core_serialize(&serial_info);
if (ret)
if (save_to_disk)
{
if (save_to_disk)
if (filestream_exists(path) && !autosave)
{
if (filestream_exists(path) && !autosave)
{
/* Before overwritting the savestate file, load it into a buffer
to allow undo_save_state() to work */
/* TODO/FIXME - Use msg_hash_to_str here */
RARCH_LOG("%s ...\n",
msg_hash_to_str(MSG_FILE_ALREADY_EXISTS_SAVING_TO_BACKUP_BUFFER));
/* Before overwritting the savestate file, load it into a buffer
to allow undo_save_state() to work */
/* TODO/FIXME - Use msg_hash_to_str here */
RARCH_LOG("%s ...\n",
msg_hash_to_str(MSG_FILE_ALREADY_EXISTS_SAVING_TO_BACKUP_BUFFER));
task_push_load_and_save_state(path, data, info.size, true, autosave);
}
else
task_push_save_state(path, data, info.size, autosave);
task_push_load_and_save_state(path, data, info.size, true, autosave);
}
else
{
/* save_to_disk is false, which means we are saving the state
in undo_load_buf to allow content_undo_load_state() to restore it */
/* If we were holding onto an old state already, clean it up first */
if (undo_load_buf.data)
{
free(undo_load_buf.data);
undo_load_buf.data = NULL;
}
undo_load_buf.data = malloc(info.size);
if (!undo_load_buf.data)
{
free(data);
return false;
}
memcpy(undo_load_buf.data, data, info.size);
free(data);
undo_load_buf.size = info.size;
strlcpy(undo_load_buf.path, path, sizeof(undo_load_buf.path));
}
task_push_save_state(path, data, info.size, autosave);
}
else
{
data = get_serialized_data(path, info.size) ;
if ( data == NULL )
{
RARCH_ERR("%s \"%s\".\n",
msg_hash_to_str(MSG_FAILED_TO_SAVE_STATE_TO),
path);
return false ;
}
/* save_to_disk is false, which means we are saving the state
in undo_load_buf to allow content_undo_load_state() to restore it */
/* If we were holding onto an old state already, clean it up first */
if (undo_load_buf.data)
{
free(undo_load_buf.data);
undo_load_buf.data = NULL;
}
undo_load_buf.data = malloc(info.size);
if (!undo_load_buf.data)
{
free(data);
return false;
}
memcpy(undo_load_buf.data, data, info.size);
free(data);
RARCH_ERR("%s \"%s\".\n",
msg_hash_to_str(MSG_FAILED_TO_SAVE_STATE_TO),
path);
undo_load_buf.size = info.size;
strlcpy(undo_load_buf.path, path, sizeof(undo_load_buf.path));
}
return ret;
return true;
}
/**