test/abstract_execution_base.cpp

Go to the documentation of this file.

#include <gtest/gtest.h>
#include <mbf_abstract_nav/abstract_execution_base.h>
 
#include <boost/chrono.hpp>
 
using namespace mbf_abstract_nav;
 
// our dummy implementation of the AbstractExecutionBase
// it basically runs until we cancel it.
struct DummyExecutionBase : public AbstractExecutionBase
{
  DummyExecutionBase(const std::string& _name) : AbstractExecutionBase(_name)
  {
  }
 
  // implement the required interfaces
  bool cancel()
  {
    cancel_ = true;
    condition_.notify_all();
    return true;
  }
 
protected:
  void run()
  {
    boost::mutex mutex;
    boost::unique_lock<boost::mutex> lock(mutex);
 
    // wait until someone says we are done (== cancel or stop)
    // we set a timeout, since we might miss the cancel call (especially if we
    // run on an environment with high CPU load)
    condition_.wait_for(lock, boost::chrono::seconds(1));
    outcome_ = 0;
  }
};
 
// shortcuts...
using testing::Test;
 
// the fixture owning the instance of the DummyExecutionBase
struct AbstractExecutionFixture : public Test
{
  DummyExecutionBase impl_;
 
  AbstractExecutionFixture() : impl_("foo")
  {
  }
};
 
TEST_F(AbstractExecutionFixture, timeout)
{
  // start the thread
  impl_.start();
 
  // make sure that we timeout and dont alter the outcome
  EXPECT_EQ(impl_.waitForStateUpdate(boost::chrono::microseconds(60)), boost::cv_status::timeout);
  EXPECT_EQ(impl_.getOutcome(), 255);
}
 
TEST_F(AbstractExecutionFixture, success)
{
  // start the thread
  impl_.start();
  EXPECT_EQ(impl_.waitForStateUpdate(boost::chrono::microseconds(60)), boost::cv_status::timeout);
 
  // cancel, so we set the outcome to 0
  impl_.cancel();
  impl_.join();
  EXPECT_EQ(impl_.getOutcome(), 0);
}
 
TEST_F(AbstractExecutionFixture, restart)
{
  // call start multiple times without waiting for its termination
  for (size_t ii = 0; ii != 10; ++ii)
    impl_.start();
}
 
TEST_F(AbstractExecutionFixture, stop)
{
  // call stop/terminate multiple times. this should be a noop
  for (size_t ii = 0; ii != 10; ++ii)
  {
    impl_.stop();
    impl_.join();
  }
}
 
int main(int argc, char** argv)
{
  testing::InitGoogleTest(&argc, argv);
  return RUN_ALL_TESTS();
}