additional/synchronization/semaphore.cpp

Go to the documentation of this file.

#include <assert.h>
#include "semaphore.h"


//constructor
Semaphore::Semaphore( const char* name )
{
#ifdef WIN32
    semaphore = new CSemaphore( 1, 1, name, NULL );
    singleLock = new CSingleLock( semaphore );
    
    this->name = new char[ strlen( name ) + 1 ];
    strcpy( this->name, name );
#endif
}

Semaphore::Semaphore( const int guid )
{
#ifdef WIN32
    char name[ 256 ] = "";
    sprintf( name, "%x", guid );
    this->name = new char[ strlen( name ) + 1 ];
    strcpy( this->name, name );
    
    this->semaphore = new CSemaphore( 1, 1, name, NULL );
    singleLock = new CSingleLock( semaphore );
#endif
}

Semaphore::~Semaphore()
{
#ifdef WIN32
    delete singleLock;
    delete semaphore;
    delete [] name;
#endif
}

//locks the semaphore
void Semaphore::Lock()
{
#ifdef WIN32
    if( !singleLock->IsLocked() )
    {
        while( singleLock->Lock( 500 ) == false )
        {
            //assert( false );
            //return;
        }
    }
    else
    {
        assert( false );
    }
#endif
}

//unlocks the semaphore
void Semaphore::Unlock()
{
#ifdef WIN32
    singleLock->Unlock();
#endif
}

---