ResourceLock.cpp

Go to the documentation of this file.

namespace krotos
{
    const int ResourceLock::DSP_THREAD_WAIT_MAX_MS{3000};
 
    bool ResourceLock::requestAccess(const StringRef id)
    {
        const ScopedLock myScopedLock(objectLock);
        if (m_isAccessible)
        {
#ifdef USE_DEBUG_LOGGING
            auto added = m_clientList.addIfNotAlreadyThere(id);
            if (added)
            {
                Logger::getCurrentLogger()->writeToLog("Granted       " + id +
                                                       " - Users: " + String(m_clientList.size()));
            }
            else
            {
                Logger::getCurrentLogger()->writeToLog("Granted Again " + id +
                                                       " - Users: " + String(m_clientList.size()));
            }
        }
        else
        {
            Logger::getCurrentLogger()->writeToLog("Not Granted   " + id + " - Users: " + String(m_clientList.size()));
#else
            m_clientList.addIfNotAlreadyThere(id);
#endif
        }
        return m_isAccessible;
    }
 
    bool ResourceLock::hasAccess(const StringRef id) const { return m_clientList.contains(id); }
 
    void ResourceLock::finishedAccessing(const StringRef id)
    {
        const ScopedLock myScopedLock(objectLock);
 
        auto index = m_clientList.indexOf(id);
        jassert(index >= 0); // A client which had not been granted access attempted to finishedAccessing()
 
        m_clientList.removeString(id);
 
#ifdef USE_DEBUG_LOGGING
        Logger::getCurrentLogger()->writeToLog("Finished      " + id + " - Users: " + String(m_clientList.size()));
#endif
 
        if (m_clientList.size() == 0) // If no client processblocks are processing, then ...
        {
            m_waitForZeroUsers.signal(); // ... release the requesting thread, in case it is waiting for us to complete
        }
    }
 
    void ResourceLock::setAccessible(bool isAccessible)
    {
        // No scoped lock on this method - because we need to be able to wait
        // here for other threads to fininsh - so we can't lock them out
 
#ifdef USE_DEBUG_LOGGING
        if (isAccessible)
        {
            Logger::getCurrentLogger()->writeToLog("Set Accesible True - Users: " + String(m_clientList.size()));
        }
        else
        {
            Logger::getCurrentLogger()->writeToLog("Set Accesible False - Users: " + String(m_clientList.size()));
        }
#endif
 
        if (!m_isAccessible)
        {
            jassert(m_clientList.size() == 0); // m_isAccessible should never be false if there are users
            if (!isAccessible)                 // If we are trying to set false and already false, then nothing to do
                return;
        }
 
        m_isAccessible = isAccessible; // grant or deny access to our client process blocks
        if (!isAccessible)
        {
            if (m_clientList.size() > 0)
            {
                // Wait, with large timeout
                bool timedOut = !m_waitForZeroUsers.wait(DSP_THREAD_WAIT_MAX_MS);
                jassert(timedOut == false); // Timed out waiting for resource to be released
            }
        }
    }
 
} // namespace krotos