MCond.cc

/**************************************************************************
 * basf2 (Belle II Analysis Software Framework)                           *
 * Author: The Belle II Collaboration                                     *
 *                                                                        *
 * See git log for contributors and copyright holders.                    *
 * This file is licensed under LGPL-3.0, see LICENSE.md.                  *
 **************************************************************************/
#include "daq/slc/system/MCond.h"
 
#include <sys/time.h>
 
using namespace Belle2;
 
MCond::MCond() {}
 
MCond::MCond(const MCond& cond)
{
  *this = cond;
}
 
MCond::MCond(void* addr)
{
  set((pthread_cond_t*)addr);
}
 
MCond::~MCond() {}
 
bool MCond::init(void* addr)
{
  set(addr);
  init();
  return true;
}
 
bool MCond::init()
{
  pthread_condattr_t attr;
  pthread_condattr_init(&attr);
  pthread_condattr_setpshared(&attr, PTHREAD_PROCESS_SHARED);
  pthread_cond_init(m_cond, &attr);
  pthread_condattr_destroy(&attr);
  return true;
}
 
bool MCond::set(void* addr)
{
  m_cond = (pthread_cond_t*)addr;
  return true;
}
 
bool MCond::destroy()
{
  pthread_cond_destroy(m_cond);
  return true;
}
 
bool MCond::signal()
{
  if (pthread_cond_signal(m_cond) == 0) return true;
  else return false;
}
 
bool MCond::broadcast()
{
  if (pthread_cond_broadcast(m_cond) == 0) return true;
  else return false;
}
 
bool MCond::wait(MMutex& cond)
{
  if (pthread_cond_wait(m_cond, cond.m_mu) != 0) {
    return false;
  }
  return true;
}
 
bool MCond::wait(MMutex& mutex, const unsigned int sec,
                 const unsigned int msec)
{
  struct timeval now;
  struct timespec timeout;
 
  gettimeofday(&now, NULL);
  timeout.tv_sec = now.tv_sec + sec;
  timeout.tv_nsec = now.tv_usec * 1000 + msec;
  if (pthread_cond_timedwait(m_cond, mutex.m_mu, &timeout) != 0) {
    return false;
  }
  return true;
}
 
const MCond& MCond::operator=(const MCond& cond)
{
  m_cond = cond.m_cond;
  return *this;
}