xthread.cpp

/***************************************************************************
        Copyright (C) 2002-2015 Kentaro Kitagawa
                           kitagawa@phys.s.u-tokyo.ac.jp
        
        This program is free software; you can redistribute it and/or
        modify it under the terms of the GNU Library General Public
        License as published by the Free Software Foundation; either
        version 2 of the License, or (at your option) any later version.
        
        You should have received a copy of the GNU Library General 
        Public License and a list of authors along with this program; 
        see the files COPYING and AUTHORS.
***************************************************************************/
//---------------------------------------------------------------------------

#include "xthread.h"

//---------------------------------------------------------------------------

#ifdef USE_QTHREAD

XMutex::XMutex() {}
XMutex::~XMutex() {}

void XMutex::lock() {m_mutex.lock();}

void XMutex::unlock() {m_mutex.unlock();}

bool XMutex::trylock() {return m_mutex.tryLock();}

XCondition::XCondition() : XMutex() {
}
XCondition::~XCondition() {
}

int XCondition::wait(int usec) {
    bool ret;
    if(usec)
        ret = m_cond.wait( &m_mutex, usec / 1000);
    else
        ret = m_cond.wait( &m_mutex);
    return ret ? 0 : 1;
}

void XCondition::signal() {
    m_cond.wakeOne();
}

void XCondition::broadcast() {
    m_cond.wakeAll();
}


#else
    #ifdef USE_PTHREAD

    #include <assert.h>
    #include <errno.h>
    #include <algorithm>
    #include <sys/time.h>

    XMutex::XMutex() {
        pthread_mutexattr_t attr;
        int ret;
        ret = pthread_mutexattr_init( &attr);
        if(DEBUG_XTHREAD) assert( !ret);

        ret = pthread_mutex_init( &m_mutex, &attr);
        if(DEBUG_XTHREAD) assert( !ret);

        ret = pthread_mutexattr_destroy( &attr);
        if(DEBUG_XTHREAD) assert( !ret);
    }

    XMutex::~XMutex() {
        int ret = pthread_mutex_destroy( &m_mutex);
        if(DEBUG_XTHREAD) assert( !ret);
    }
    void
    XMutex::lock() {
        int ret = pthread_mutex_lock( &m_mutex);
        if(DEBUG_XTHREAD) assert( !ret);
    }
    bool
    XMutex::trylock() {
        int ret = pthread_mutex_trylock(&m_mutex);
        if(DEBUG_XTHREAD) assert(ret != EINVAL);
        return (ret == 0);
    }
    void
    XMutex::unlock() {
        int ret = pthread_mutex_unlock( &m_mutex);
        if(DEBUG_XTHREAD) assert( !ret);
    }

    XCondition::XCondition() : XMutex() {
        int ret = pthread_cond_init( &m_cond, NULL);
        if(DEBUG_XTHREAD) assert( !ret);
    }
    XCondition::~XCondition() {
        int ret = pthread_cond_destroy( &m_cond);
        if(DEBUG_XTHREAD) assert( !ret);
    }
    int
    XCondition::wait(int usec) {
        int ret;
        if(usec > 0) {
            struct timespec abstime;
            timeval tv;
            long nsec;
            gettimeofday(&tv, NULL);
            abstime.tv_sec = tv.tv_sec;
            nsec = (tv.tv_usec + usec) * 1000;
            if(nsec >= 1000000000) {
                nsec -= 1000000000; abstime.tv_sec++;
            }
            abstime.tv_nsec = nsec;
            ret = pthread_cond_timedwait(&m_cond, &m_mutex, &abstime);
        }
        else {
            ret = pthread_cond_wait(&m_cond, &m_mutex);
        }
        return ret;
    }
    void
    XCondition::signal() {
        int ret = pthread_cond_signal( &m_cond);
        if(DEBUG_XTHREAD) assert( !ret);
    }
    void
    XCondition::broadcast() {
        int ret = pthread_cond_broadcast( &m_cond);
        if(DEBUG_XTHREAD) assert( !ret);
    }
    #endif // USE_PTHREAD
#endif // USE_QTHREAD