random_utils/include/random_utils/ThreadSafeObject.h

Go to the documentation of this file.

#ifndef _RU_THREADSAFEOBJECT_H_
#define _RU_THREADSAFEOBJECT_H_

#include <SDL_thread.h>
#include <iostream>

namespace random_utils
{

class ThreadSafeObject
{
    SDL_mutex*  m_mutexMutex;
    
    SDL_mutex*  m_syncMutex;

    unsigned int m_lockCount;

public:
    ThreadSafeObject();

    virtual ~ThreadSafeObject();

    inline int lock()
    {
        int sdlReturnValue = SDL_LockMutex(m_syncMutex);

        if(SDL_LockMutex(m_mutexMutex) == -1)
            std::cerr << "ERROR: cannot lock mutex protection" << std::endl;

        if(sdlReturnValue == -1)
            std::cerr << "ERROR: cannot lock mutex " 
                    << m_syncMutex << std::endl;

        m_lockCount++;
        
        if(SDL_UnlockMutex(m_mutexMutex) == -1)
            std::cerr << "ERROR: cannot unlock mutex protection" << std::endl;
        
        return sdlReturnValue;
    }

    inline int unlock()
    {
        if(SDL_LockMutex(m_mutexMutex) == -1)
            std::cerr << "ERROR: cannot lock mutex protection" << std::endl;

        if(--m_lockCount == 0)
        {
            if(SDL_UnlockMutex(m_mutexMutex) == -1)
                std::cerr << "ERROR: cannot unlock mutex protection" 
                        << std::endl;

            int sdlReturnValue = SDL_UnlockMutex(m_syncMutex);

            if(sdlReturnValue == -1)
                std::cerr << "ERROR: cannot unlock mutex " 
                        << m_syncMutex << std::endl;

            return sdlReturnValue;
        }
        else
        {
            if(SDL_UnlockMutex(m_mutexMutex) == -1)
                std::cerr << "ERROR: cannot unlock mutex protection" 
                        << std::endl;

            return 0;
        }
    }

    inline bool isLocked()
    {
        return m_lockCount != 0;
    }

    inline SDL_mutex* mutex()
    {
        return m_syncMutex;
    }

    inline unsigned int lockCount()
    {
        return m_lockCount;
    }
};

} // namespace random_utils


#endif // _RU_THREADSAFEOBJECT_H_

---