From 7ee008e150bc5bcf76082d726f719ee0fdfda982 Mon Sep 17 00:00:00 2001 From: SulfurNitride Date: Wed, 11 Feb 2026 02:37:39 -0600 Subject: Fluorine Manager: full Linux port of Mod Organizer 2 Complete native Linux port with FUSE-based virtual filesystem, Proton/umu-run integration, and Flatpak packaging. Key features: - FUSE VFS replacing Windows USVFS (in-process + standalone helper for Flatpak) - Proton/GE-Proton/umu-run launcher with env var forwarding - Flatpak support (sandbox-aware VFS, NXM handler, umu-run) - Wine prefix management UI - Case-insensitive path resolution for Linux filesystems - QSettings-safe INI handling (avoids Bethesda INI corruption) - Portable instance support with auto-generated launcher scripts Co-Authored-By: Claude Opus 4.6 --- libs/usvfs/src/usvfs_dll/semaphore.cpp | 57 ++++++++++++++++++++++++++++++++++ 1 file changed, 57 insertions(+) create mode 100644 libs/usvfs/src/usvfs_dll/semaphore.cpp (limited to 'libs/usvfs/src/usvfs_dll/semaphore.cpp') diff --git a/libs/usvfs/src/usvfs_dll/semaphore.cpp b/libs/usvfs/src/usvfs_dll/semaphore.cpp new file mode 100644 index 0000000..609b2f5 --- /dev/null +++ b/libs/usvfs/src/usvfs_dll/semaphore.cpp @@ -0,0 +1,57 @@ +#include "semaphore.h" +#include "exceptionex.h" + +RecursiveBenaphore::RecursiveBenaphore() : m_Counter(0), m_OwnerId(0UL), m_Recursion(0) +{ + m_Semaphore = ::CreateSemaphore(nullptr, 1, 1, nullptr); +} + +RecursiveBenaphore::~RecursiveBenaphore() +{ + ::CloseHandle(m_Semaphore); +} + +void RecursiveBenaphore::wait(DWORD timeout) +{ + DWORD tid = ::GetCurrentThreadId(); + + if (::_InterlockedIncrement(&m_Counter) > 1) { + if (tid != m_OwnerId) { + int tries = 3; + while (::WaitForSingleObject(m_Semaphore, timeout) != WAIT_OBJECT_0) { + HANDLE owner = ::OpenThread(SYNCHRONIZE, FALSE, m_OwnerId); + ON_BLOCK_EXIT([owner]() { + ::CloseHandle(owner); + }); + if ((tries <= 0) || (::WaitForSingleObject(owner, 0) == WAIT_OBJECT_0)) { + // owner has quit without releasing the semaphore! + m_Recursion = 0; + spdlog::get("usvfs")->error("thread {} never released the mutex", m_OwnerId); + break; + } else { + --tries; + } + } + } + } + m_OwnerId = tid; + ++m_Recursion; +} + +void RecursiveBenaphore::signal() +{ + if (m_Recursion == 0) { + return; + } + // no validation the signaling thread is the one owning the lock + DWORD recursion = --m_Recursion; + if (recursion == 0) { + m_OwnerId = 0; + } + DWORD result = ::_InterlockedDecrement(&m_Counter); + if (result > 0) { + if (recursion == 0) { + ::ReleaseSemaphore(m_Semaphore, 1, nullptr); + } + } +} -- cgit v1.3.1