SysSignalFlag.cpp

См. документацию.

/*
 * CntmLib - Подсчет ссылок, потоки, синхронизация, асинхронные процедуры, события
 * Copyright (c) 2005, Овсеевич Роман, CntmLib@mail.ru
 * _______________________________________________________________________________
 * Разрешено свободное использование, копирование, распространение, изменение
 * (изменение сведений об авторских правах запрещено). Запрещена продажа и 
 * включение всей библиотеки или ее частей в другие библиотеки. В сведениях об
 * авторских правах на программу (или сведениях о программе, об авторах, 
 * использованных средствах разработки и т.д.) должна быть указана информация
 * о библиотеке CntmLib, ее авторе и, возможно, сайте или email'е.
 * Библиотека поставляется "как есть", без каких-либо гарантий со стороны автора.
 */ 

#include <errno.h>
#include <Cntm/Exceptions/SystemException.h>
#include <Cntm/SystemUtils/SysSignalFlag.h>

Cntm::SpecUtils::SysSignalFlag::SysSignalFlag(bool AutoReset, bool Init): 
        autoReset(AutoReset), mutex(false), flag(Init)
{
        pthread_cond_init(&cond, NULL); 
}

Cntm::SpecUtils::SysSignalFlag::~SysSignalFlag()
{
        pthread_cond_destroy(&cond);
}

bool Cntm::SpecUtils::SysSignalFlag::Wait(bool Infinite, uint MSecTimeOut)
{
        SysCriticalSection::Lock lock(mutex);
        
        bool res = true;
        if (Infinite)
        {
                while (!flag) pthread_cond_wait(&cond, mutex.PthreadMutex());
        }
        else
        {
                timeval now;
                timespec tm;
                gettimeofday(&now, NULL);
                tm.tv_nsec = now.tv_usec * 1000 + (MSecTimeOut % 1000) * 1000000;
                tm.tv_sec = now.tv_sec + MSecTimeOut / 1000;
                tm.tv_sec += tm.tv_nsec / 1000000000;
                tm.tv_nsec = tm.tv_nsec % 1000000000;
                
                int err = 0;
                while (!flag && err != ETIMEDOUT)
                        err = pthread_cond_timedwait(&cond, mutex.PthreadMutex(), &tm);
                
                res = flag;
        }

        if (autoReset) flag = false;
        
        return res;
}

void Cntm::SpecUtils::SysSignalFlag::Set()
{
        SysCriticalSection::Lock lock(mutex);
        flag = true;
        SignalCond();
}

void Cntm::SpecUtils::SysSignalFlag::Reset()
{
        SysCriticalSection::Lock lock(mutex);
        flag = false;
}

void Cntm::SpecUtils::SysSignalFlag::SignalCond()
{
        if ((autoReset? pthread_cond_signal(&cond) : pthread_cond_broadcast(&cond)) != 0)
                throw SystemException("Cntm::SpecUtils::SignalImpl::SignalCond", "cond_signal");
}

---