Sem.cpp

Go to the documentation of this file.

// this is for emacs file handling -*- mode: c++; indent-tabs-mode: nil -*-

// -- BEGIN LICENSE BLOCK ----------------------------------------------
// This file is part of FZIs ic_workspace.
//
// This program is free software licensed under the LGPL
// (GNU LESSER GENERAL PUBLIC LICENSE Version 3).
// You can find a copy of this license in LICENSE folder in the top
// directory of the source code.
//
// © Copyright 2016 FZI Forschungszentrum Informatik, Karlsruhe, Germany
//
// -- END LICENSE BLOCK ------------------------------------------------

//----------------------------------------------------------------------
//----------------------------------------------------------------------
#include "icl_core_thread/Sem.h"


#if defined _SYSTEM_LXRT_
# include "SemaphoreImplLxrt.h"
#endif

#if defined _SYSTEM_DARWIN_
# include "SemaphoreImplDarwin.h"
#elif defined _SYSTEM_POSIX_
# include "SemaphoreImplPosix.h"
#elif defined _SYSTEM_WIN32_
# include "SemaphoreImplWin32.h"
#else
# error "No semaphore implementation defined for this platform."
#endif

namespace icl_core {
namespace thread {

Semaphore::Semaphore(size_t initial_value)
  : m_impl(0)
{
#if defined _SYSTEM_LXRT_
  // Only create an LXRT implementation if the LXRT runtime system is
  // really available. Otherwise create an ACE or POSIX
  // implementation, depending on the system configuration.
  // Remark: This allows us to compile programs with LXRT support but
  // run them on systems on which no LXRT is installed and to disable
  // LXRT support at program startup on systems with installed LXRT!
  if (icl_core::os::isLxrtAvailable())
  {
    m_impl = new SemaphoreImplLxrt(initial_value);
  }
  else
  {
    m_impl = new SemaphoreImplPosix(initial_value);
  }

#elif defined _SYSTEM_DARWIN_
  m_impl = new SemaphoreImplDarwin(initial_value);

#elif defined _SYSTEM_POSIX_
  m_impl = new SemaphoreImplPosix(initial_value);

#elif defined _SYSTEM_WIN32_
  m_impl = new SemaphoreImplWin32(initial_value);

#endif
}

Semaphore::~Semaphore()
{
  delete m_impl;
  m_impl = 0;
}

void Semaphore::post()
{
  return m_impl->post();
}

bool Semaphore::tryWait()
{
  return m_impl->tryWait();
}

bool Semaphore::wait()
{
  return m_impl->wait();
}

bool Semaphore::wait(const icl_core::TimeSpan& timeout)
{
  return m_impl->wait(timeout);
}

bool Semaphore::wait(const icl_core::TimeStamp& timeout)
{
  return m_impl->wait(timeout);
}

#ifdef _IC_BUILDER_DEPRECATED_STYLE_

void Semaphore::Post()
{
  post();
}

bool Semaphore::TryWait()
{
  return tryWait();
}

bool Semaphore::Wait()
{
  return wait();
}

bool Semaphore::Wait(const icl_core::TimeSpan& timeout)
{
  return wait(timeout);
}

bool Semaphore::Wait(const icl_core::TimeStamp& timeout)
{
  return wait(timeout);
}

#endif

}
}