random_utils/src/SleepyObject.cpp

Go to the documentation of this file.

    
#include "random_utils/SleepyObject.h"
#include <iostream>

namespace random_utils
{

SleepyObject::SleepyObject()
{
    m_sleepRequested        = false;

    m_finishedUpdateCondition = SDL_CreateCond();
    m_finishedUpdateMutex = SDL_CreateMutex();
    m_wakeUpCondition = SDL_CreateCond();
    m_requestMutex = SDL_CreateMutex();
}

SleepyObject::~SleepyObject()
{
    SDL_DestroyCond(m_finishedUpdateCondition);
    SDL_DestroyMutex(m_finishedUpdateMutex);
    SDL_DestroyCond(m_wakeUpCondition);
    SDL_DestroyMutex(m_requestMutex);
}

void
SleepyObject::sleep()
{
    if(SDL_LockMutex(m_requestMutex) == -1)
        std::cerr << "ERROR: cannot lock request mutex" << std::endl;

    m_sleepRequested = true;

    if(SDL_CondWait(m_finishedUpdateCondition, m_requestMutex) == -1)
        std::cerr << "ERROR: cannot wait for update condition" << std::endl;

    if(SDL_UnlockMutex(m_requestMutex) == -1)
        std::cerr << "ERROR: cannot unlock request mutex" << std::endl;

    if(SDL_LockMutex(m_finishedUpdateMutex) == -1)
        std::cerr << "ERROR: cannot lock update mutex" << std::endl;
    if(SDL_UnlockMutex(m_finishedUpdateMutex) == -1)
        std::cerr << "ERROR: cannot unlock update mutex" << std::endl;
}

void
SleepyObject::runUpdate()
{
    update();

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

    if(m_sleepRequested)
    {
        m_sleepRequested = false;

        if(SDL_LockMutex(m_finishedUpdateMutex) == -1)
            std::cerr << "ERROR: cannot lock update mutex" << std::endl;;
        
        if(SDL_CondSignal(m_finishedUpdateCondition) == -1)
            std::cerr << "ERROR: cannot signal update condition" << std::endl;

        if(SDL_UnlockMutex(m_requestMutex) == -1)
            std::cerr << "ERROR: cannot unlock request mutex" << std::endl;;

        if(SDL_CondWait(m_wakeUpCondition, m_finishedUpdateMutex) == -1)
            std::cerr << "ERROR: cannot wait for wakeup" << std::endl;;

        if(SDL_UnlockMutex(m_finishedUpdateMutex) == -1)
            std::cerr << "ERROR: cannot unlock update mutex" << std::endl;;
    }
    else
    {
        if(SDL_UnlockMutex(m_requestMutex) == -1)
            std::cerr << "ERROR: cannot unlock request mutex" << std::endl;
    }
}

void
SleepyObject::wakeUp()
{
    if(SDL_CondSignal(m_wakeUpCondition) == -1)
        std::cerr << "ERROR: cannot signal wake up" << std::endl;
}

bool
SleepyObject::sleepRequested()
{
    bool ret;
    
    if(SDL_LockMutex(m_requestMutex) == -1)
        std::cerr << "ERROR: cannot lock request mutex" << std::endl;

    ret = m_sleepRequested;
    
    if(SDL_UnlockMutex(m_requestMutex) == -1)
        std::cerr << "ERROR: cannot unlock request mutex" << std::endl;

    return ret;
}

}

---