SimWorkItem.cpp

#include "Headers.h"
#include "SimWorkItem.h"
#include "ExceptionSignal.h"
#include "ExceptionMutex.h"

CSimWorkItem::CSimWorkItem()
{
    // Set initial work item state
    this->state = PENDING;

    // Create work item signal
#ifdef WIN32
    // Initialize the work item event
    if(NULL == (this->evt = CreateEvent(
        NULL,   // default security attributes
        false,  // manual reset
        false,  // initial state (true is signaled)
        NULL    // event name
        ))) throw CExceptionSignal("create work item signal failed", __FILE__, __LINE__);
#elif POSIX
    // Initialize the work item mutex
    if(pthread_mutex_init(&this->mutex, NULL)) throw CExceptionMutex("create work item mutex failed", __FILE__, __LINE__);
    // Initialize the work item condition
    if(pthread_cond_init(&this->cond, NULL)) throw CExceptionSignal("create work item signal failed", __FILE__, __LINE__);
    // Lock the mutex
    if(pthread_mutex_lock(&this->mutex)) throw CExceptionSignal("locking work item mutex failed", __FILE__, __LINE__);
#endif
}

CSimWorkItem::~CSimWorkItem()
{
#ifdef WIN32
    // Delete the work item event
    if(!CloseHandle(this->evt)) throw CExceptionSignal("close work item signal failed", __FILE__, __LINE__);
#elif POSIX
    // Unlock the mutex
    if(pthread_mutex_unlock(&this->mutex)) throw CExceptionSignal("unlocking work item mutex failed", __FILE__, __LINE__);
    // Delete the work item condition
    if(pthread_cond_destroy(&this->cond)) throw CExceptionSignal("close work item signal failed", __FILE__, __LINE__);
    // Delete the work item mutex
    if(pthread_mutex_destroy(&this->mutex)) throw CExceptionMutex("close work item mutex failed", __FILE__, __LINE__);
#endif
}

void CSimWorkItem::Signal(EWorkItemState state)
{
    this->state = state;

    // Signal the completion of the work item
#ifdef WIN32
    if(!SetEvent(this->evt)) throw CExceptionSignal("set work item signal to signaled state failed", __FILE__, __LINE__);
#elif POSIX
    // Lock the mutex
    if(pthread_mutex_lock(&this->mutex)) throw CExceptionSignal("locking work item mutex failed", __FILE__, __LINE__);
    // Signal the condition
    if(pthread_cond_signal(&this->cond)) throw CExceptionSignal("set work item signal to signaled state failed", __FILE__, __LINE__);
    // Unlock the mutex
    if(pthread_mutex_unlock(&this->mutex)) throw CExceptionSignal("unlocking work item mutex failed", __FILE__, __LINE__);
#endif
}

void CSimWorkItem::Wait()
{
#ifdef WIN32
    if(WAIT_FAILED == WaitForSingleObject(this->evt, INFINITE)) throw CExceptionSignal("waiting for work item signal failed", __FILE__, __LINE__);
#elif POSIX
    if(pthread_cond_wait(&this->cond, &this->mutex)) throw CExceptionSignal("waiting for work item signal failed", __FILE__, __LINE__);
#endif
}