#include "Mutex.hpp"

#include "Common.hpp"

#include <time.h>


pthread_mutex_t& MutexCtor( pthread_mutex_t& mutex )
{
  pthread_mutex_init( &mutex, 0 );
  return mutex;
}


Mutex::Mutex( int kind )
  : m_mutex( MutexCtor( m_mutex ) )
{
  TRACE;
  if ( kind != PTHREAD_MUTEX_DEFAULT ) {
    /// @bug passing local variables address
    pthread_mutexattr_t attr;
    pthread_mutexattr_init( &attr );
    pthread_mutexattr_settype( &attr, kind );
    pthread_mutex_init( &m_mutex, &attr );
  }
}


Mutex::~Mutex()
{
  TRACE;
  pthread_mutex_destroy ( &m_mutex );
}


int Mutex::lock()
{
  TRACE;
  return pthread_mutex_lock( &m_mutex );
}


int Mutex::unlock()
{
  TRACE;
  return pthread_mutex_unlock ( &m_mutex );
}


int Mutex::tryLock( const long int intervalSec, const long int intervalNSec )
{
  TRACE;
  if ( intervalSec == 0 and intervalNSec == 0 ) {
    return pthread_mutex_trylock( &m_mutex );
  } else {
    timespec tspec = addTotimespec( intervalSec, intervalSec );
    return pthread_mutex_timedlock( &m_mutex, &tspec );
  }
}


pthread_mutex_t* Mutex::getPThreadMutex()
{
  return &m_mutex;
}