fork(1) download

copy

 
class CMutexRW
{
protected:
    HANDLE        m_semReaders;
    HANDLE        m_semWriters;
    int        m_nReaders;
public:
    CMutexRW() :
        m_semReaders(NULL),
        m_semWriters(NULL),
        m_nReaders(0)
    {
        // initialize the Readers & Writers variables
        m_semReaders    = ::CreateSemaphore(NULL, 1, 1, NULL);
        m_semWriters    = ::CreateSemaphore(NULL, 1, 1, NULL);
        m_nReaders    = 0;
 
        if (m_semReaders == NULL || m_semWriters == NULL)
        {
            LPVOID lpMsgBuf;
            FormatMessage( 
                FORMAT_MESSAGE_ALLOCATE_BUFFER | 
                FORMAT_MESSAGE_FROM_SYSTEM | 
                FORMAT_MESSAGE_IGNORE_INSERTS,
                NULL,
                GetLastError(),
                MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
                (LPTSTR) &lpMsgBuf,
                0,
                NULL 
                );
            TRACE( "***** ERROR: CreateSemaphore: %s\n", (LPCTSTR)lpMsgBuf );
            LocalFree( lpMsgBuf );            
        }
    };
 
    virtual ~CMutexRW()
    {
        if (m_semWriters)
            VERIFY( ::CloseHandle(m_semWriters) );    
 
        m_semWriters = NULL;
        if (m_semReaders)
            VERIFY( ::CloseHandle(m_semReaders) );    
        m_semReaders = NULL;
    }
 
    inline void Lock_DataRead(){
        DWORD dwEvent = WAIT_TIMEOUT;
 
        // P( semReaders )
        dwEvent = ::WaitForSingleObject( m_semReaders, INFINITE );
        ASSERT(dwEvent == WAIT_OBJECT_0);
 
        m_nReaders++;
 
        if (m_nReaders == 1)
        {
            // P( semWriters )
            dwEvent = ::WaitForSingleObject( m_semWriters, INFINITE );
            ASSERT(dwEvent == WAIT_OBJECT_0);
        }
        // V( semReaders )
        VERIFY( ::ReleaseSemaphore( m_semReaders, 1, NULL ) );
    };
 
    inline void Unlock_DataRead(){
        DWORD dwEvent = WAIT_TIMEOUT;
        // P( semReaders )
        dwEvent = ::WaitForSingleObject( m_semReaders, INFINITE );
        ASSERT(dwEvent == WAIT_OBJECT_0);
 
        m_nReaders--;
 
        if (m_nReaders == 0)
        {
            // V( semWriters )
            VERIFY( ::ReleaseSemaphore(m_semWriters, 1, NULL) );
        }
        // V( semReaders )
        VERIFY( ::ReleaseSemaphore( m_semReaders, 1, NULL ) );
    };
 
    inline void Lock_DataWrite(){
        DWORD dwEvent = WAIT_TIMEOUT;
 
        // P( semWriters )
        dwEvent = ::WaitForSingleObject( m_semWriters, INFINITE );
        ASSERT(dwEvent == WAIT_OBJECT_0);
    }
 
    inline void Unlock_DataWrite(){
        // V( semWriters )
        VERIFY( ::ReleaseSemaphore(m_semWriters, 1, NULL) );
    };
 
};
 
 
class CReadLock
{
protected:
    CMutexRW* m_pMutexRW;
    bool      m_bIsLocked;
public:
    CReadLock(CMutexRW* pMutexRW, const bool bInitialLock = false) :
        m_pMutexRW(pMutexRW), m_bIsLocked(false)
    {
        ASSERT(m_pMutexRW);
        if (bInitialLock){
            m_pMutexRW->Lock_DataRead();
            m_bIsLocked = true;
        }
    };
 
    inline const bool& IsLocked() const{
        return m_bIsLocked;
    };

prog.cpp:5:5: error: unknown type name 'HANDLE'
    HANDLE        m_semReaders;
    ^
prog.cpp:6:5: error: unknown type name 'HANDLE'
    HANDLE        m_semWriters;
    ^
prog.cpp:10:22: error: use of undeclared identifier 'NULL'
        m_semReaders(NULL),
                     ^
prog.cpp:11:22: error: use of undeclared identifier 'NULL'
        m_semWriters(NULL),
                     ^
prog.cpp:15:29: error: no member named 'CreateSemaphore' in the global namespace
        m_semReaders    = ::CreateSemaphore(NULL, 1, 1, NULL);
                          ~~^
prog.cpp:15:45: error: use of undeclared identifier 'NULL'
        m_semReaders    = ::CreateSemaphore(NULL, 1, 1, NULL);
                                            ^
prog.cpp:15:57: error: use of undeclared identifier 'NULL'
        m_semReaders    = ::CreateSemaphore(NULL, 1, 1, NULL);
                                                        ^
prog.cpp:16:29: error: no member named 'CreateSemaphore' in the global namespace
        m_semWriters    = ::CreateSemaphore(NULL, 1, 1, NULL);
                          ~~^
prog.cpp:16:45: error: use of undeclared identifier 'NULL'
        m_semWriters    = ::CreateSemaphore(NULL, 1, 1, NULL);
                                            ^
prog.cpp:16:57: error: use of undeclared identifier 'NULL'
        m_semWriters    = ::CreateSemaphore(NULL, 1, 1, NULL);
                                                        ^
prog.cpp:19:29: error: use of undeclared identifier 'NULL'
        if (m_semReaders == NULL || m_semWriters == NULL)
                            ^
prog.cpp:19:53: error: use of undeclared identifier 'NULL'
        if (m_semReaders == NULL || m_semWriters == NULL)
                                                    ^
prog.cpp:21:13: error: unknown type name 'LPVOID'
            LPVOID lpMsgBuf;
            ^
prog.cpp:27:17: error: use of undeclared identifier 'GetLastError'
                GetLastError(),
                ^
prog.cpp:29:18: error: use of undeclared identifier 'LPTSTR'
                (LPTSTR) &lpMsgBuf,
                 ^
prog.cpp:23:17: error: use of undeclared identifier 'FORMAT_MESSAGE_ALLOCATE_BUFFER'
                FORMAT_MESSAGE_ALLOCATE_BUFFER | 
                ^
prog.cpp:24:17: error: use of undeclared identifier 'FORMAT_MESSAGE_FROM_SYSTEM'
                FORMAT_MESSAGE_FROM_SYSTEM | 
                ^
prog.cpp:25:17: error: use of undeclared identifier 'FORMAT_MESSAGE_IGNORE_INSERTS'
                FORMAT_MESSAGE_IGNORE_INSERTS,
                ^
prog.cpp:26:17: error: use of undeclared identifier 'NULL'
                NULL,
                ^
fatal error: too many errors emitted, stopping now [-ferror-limit=]
20 errors generated.

Standard output is empty