mirrors/Atmosphere
1
0
Fork 0
mirror of https://github.com/Atmosphere-NX/Atmosphere.git synced 2024-11-15 00:16:48 +00:00
Code Issues Releases Activity

fs: fix missing mutex acquire in compressed storage invalidate/find

Browse source
This commit is contained in:
Michael Scire 2022-03-12 13:35:30 -08:00
parent 1d0c9ae71a
commit d76e678da2
1 changed files with 10 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
libraries/libstratosphere/include/stratosphere/fssystem/fssystem_compressed_storage.hpp
View file

@ -893,6 +893,10 @@ namespace ams::fssystem {
} }
void Invalidate() { void Invalidate() {
/* Acquire exclusive access to our manager. */
std::scoped_lock lk(m_mutex);
/* Invalidate all entries. */
return m_block_cache_manager.Invalidate(); return m_block_cache_manager.Invalidate();
} }
@ -1095,11 +1099,17 @@ namespace ams::fssystem {
AMS_ASSERT(out != nullptr); AMS_ASSERT(out != nullptr);
AMS_ASSERT(out_entry != nullptr); AMS_ASSERT(out_entry != nullptr);
/* Acquire exclusive access to our entries. */
std::scoped_lock lk(m_mutex);
/* Find the buffer. */ /* Find the buffer. */
R_RETURN(this->FindBufferImpl(out, out_entry, offset)); R_RETURN(this->FindBufferImpl(out, out_entry, offset));
} }
Result FindBufferImpl(fs::IBufferManager::MemoryRange *out, CacheEntry *out_entry, s64 offset) { Result FindBufferImpl(fs::IBufferManager::MemoryRange *out, CacheEntry *out_entry, s64 offset) {
/* Check pre-conditions. */
AMS_ASSERT(m_mutex.IsLockedByCurrentThread());
/* Get our block cache count */ /* Get our block cache count */
const auto count = m_block_cache_manager.GetCount(); const auto count = m_block_cache_manager.GetCount();