thread_test.cpp

Go to the documentation of this file.

#include <opc/common/thread.h>

#include <gmock/gmock.h>
#include <gtest/gtest.h>

using namespace testing;

namespace
{

  class TestThreadObserver : public Common::ThreadObserver
  {
  public:
    TestThreadObserver()
      : OnSuccessCallCount(0)
      , OnErrorCallCount(0)
    {
    }

    virtual void OnSuccess() override
    {
      ++OnSuccessCallCount;
    }

    virtual void OnError(const std::exception& exc) override
    {
      ++OnErrorCallCount;
    }

  public:
    volatile unsigned OnSuccessCallCount;
    volatile unsigned OnErrorCallCount;
  };

  void DoNothing()
  {
  }

  void ThrowsException()
  {
    throw std::logic_error("oppps!");
  }

}

TEST(Thread, CallsOnSuccess)
{
  TestThreadObserver observer;

  Common::Thread thread(std::function<void()>(DoNothing), &observer);
  thread.Join();
  EXPECT_EQ(observer.OnSuccessCallCount, 1);
  EXPECT_EQ(observer.OnErrorCallCount, 0);
}

TEST(Thread, CallsOnError)
{
  TestThreadObserver observer;

  Common::Thread thread(std::function<void()>(ThrowsException), &observer);
  thread.Join();
  EXPECT_EQ(observer.OnSuccessCallCount, 0);
  EXPECT_EQ(observer.OnErrorCallCount, 1);
}