mutex.cpp

Go to the documentation of this file.

/*****************************************************************************
 ** Platform Check
 *****************************************************************************/
#include <iostream>
#include <ecl/config/ecl.hpp>
#if defined(ECL_IS_POSIX)

/*****************************************************************************
 ** Includes
 *****************************************************************************/

#include <iostream>
#include <gtest/gtest.h>
#include <ecl/config/ecl.hpp>
#include <ecl/exceptions/standard_exception.hpp>
#include <ecl/time/timestamp.hpp>
#include "../../include/ecl/threads/mutex.hpp"

/*****************************************************************************
 ** Using
 *****************************************************************************/

using ecl::StandardException;
using ecl::Mutex;
using ecl::Duration;

/*****************************************************************************
 ** TESTS
 *****************************************************************************/

TEST(MutexTests,selfDestruct)
{
  #if defined(NDEBUG) || defined(ECL_NDEBUG)
    std::cout << "Skipping deadlock tests - posix doesn't help you in release mode." << std::endl;
    SUCCEED();
  #else
    // It will now attempt to self-destruct while locked and throw an exception.
    // This behaviour is only provided by posix in debug mode.
    Mutex mutex;
    mutex.lock();
    try {
      mutex.lock();
    } catch (StandardException &e) {
      SUCCEED();
    }
    mutex.unlock();
  #endif
}

TEST(MutexTests,tryLock)
{
  // It will now attempt to self-destruct while locked and throw an exception.
  Mutex mutex;
  mutex.trylock();
  EXPECT_FALSE(mutex.trylock());
  mutex.unlock();
}

TEST(MutexTests,timedLock)
{
  // It will now attempt to self-destruct while locked and throw an exception.
  // Trying to activate from the same thread will cause a deadlock
  // and thus exception. Need to make a test with different threads here.
  // Duration duration(1,500000000);
  // Mutex mutex;
  // mutex.lock();
  // mutex.timedlock(duration);
}

/*****************************************************************************
 ** Main program
 *****************************************************************************/

int main(int argc, char **argv)
{

  testing::InitGoogleTest(&argc, argv);
  return RUN_ALL_TESTS();
}

#else

/*****************************************************************************
 ** Alternative main
 *****************************************************************************/

int main(int argc, char **argv)
{

  std::cout << "Currently not supported on your platform." << std::endl;
}

#endif /* ECL_IS_POSIX */