Xargon/Duckstation
1
0
Fork 0
mirror of https://github.com/RetroDECK/Duckstation.git synced 2024-11-25 23:25:41 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

INISettingsInterface: Use FileSystem atomic update routines

Browse source
This commit is contained in:
Stenzek 2024-09-03 20:43:42 +10:00
parent 0ceeddbfe7
commit 9e67a7f3cc
No known key found for this signature in database
1 changed files with 6 additions and 57 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

63
src/util/ini_settings_interface.cpp
View file

@ -15,55 +15,10 @@
Log_SetChannel(INISettingsInterface); Log_SetChannel(INISettingsInterface);
#ifdef _WIN32
#include <io.h> // _mktemp_s
#else
#include <stdlib.h> // mktemp
#include <unistd.h>
#endif
// To prevent races between saving and loading settings, particularly with game settings, // To prevent races between saving and loading settings, particularly with game settings,
// we only allow one ini to be parsed at any point in time. // we only allow one ini to be parsed at any point in time.
static std::mutex s_ini_load_save_mutex; static std::mutex s_ini_load_save_mutex;
static std::FILE* GetTemporaryFile(std::string* temporary_filename, const std::string& original_filename,
const char* mode, Error* error)
{
temporary_filename->clear();
temporary_filename->reserve(original_filename.length() + 8);
temporary_filename->append(original_filename);
#ifdef _WIN32
temporary_filename->append(".XXXXXXX");
const errno_t err = _mktemp_s(temporary_filename->data(), temporary_filename->length() + 1);
if (err != 0)
{
Error::SetErrno(error, "_mktemp_s() failed: ", err);
return nullptr;
}
return FileSystem::OpenCFile(temporary_filename->c_str(), mode, error);
#else
temporary_filename->append(".XXXXXX");
const int fd = mkstemp(temporary_filename->data());
if (fd < 0)
{
Error::SetErrno(error, "mkstemp() failed: ", errno);
return nullptr;
}
std::FILE* fp = fdopen(fd, mode);
if (!fp)
{
Error::SetErrno(error, "mkstemp() failed: ", errno);
close(fd);
return nullptr;
}
return fp;
#endif
}
INISettingsInterface::INISettingsInterface(std::string filename) : m_filename(std::move(filename)), m_ini(true, true) INISettingsInterface::INISettingsInterface(std::string filename) : m_filename(std::move(filename)), m_ini(true, true)
{ {
} }
@ -104,26 +59,20 @@ bool INISettingsInterface::Save(Error* error /* = nullptr */)
} }
std::unique_lock lock(s_ini_load_save_mutex); std::unique_lock lock(s_ini_load_save_mutex);
std::string temp_filename; FileSystem::AtomicRenamedFile fp = FileSystem::CreateAtomicRenamedFile(m_filename, error);
std::FILE* fp = GetTemporaryFile(&temp_filename, m_filename, "wb", error);
SI_Error err = SI_FAIL; SI_Error err = SI_FAIL;
if (fp) if (fp)
{ {
err = m_ini.SaveFile(fp, false); err = m_ini.SaveFile(fp.get(), false);
std::fclose(fp);
if (err != SI_OK) if (err != SI_OK)
{ {
Error::SetStringFmt(error, "INI SaveFile() failed: {}", static_cast<int>(err));
// remove temporary file // remove temporary file
FileSystem::DeleteFile(temp_filename.c_str()); Error::SetStringFmt(error, "INI SaveFile() failed: {}", static_cast<int>(err));
FileSystem::DiscardAtomicRenamedFile(fp);
} }
else if (!FileSystem::RenamePath(temp_filename.c_str(), m_filename.c_str(), error)) else
{ {
Error::AddPrefixFmt(error, "Failed to rename '{}' to '{}': ", temp_filename, m_filename); err = FileSystem::CommitAtomicRenamedFile(fp, error) ? SI_OK : SI_FAIL;
FileSystem::DeleteFile(temp_filename.c_str());
return false;
} }
} }