| #ifndef _AOS_EVENTS_EVENT_LOOP_PARAM_TEST_H_ |
| #define _AOS_EVENTS_EVENT_LOOP_PARAM_TEST_H_ |
| |
| #include <vector> |
| |
| #include "aos/events/event-loop.h" |
| #include "gtest/gtest.h" |
| |
| namespace aos { |
| namespace testing { |
| |
| class EventLoopTestFactory { |
| public: |
| virtual ~EventLoopTestFactory() {} |
| |
| // Makes a connected event loop. |
| virtual std::unique_ptr<EventLoop> Make() = 0; |
| // Makes a primary event loop. This is the one the tests will try to use for |
| // anything blocking. |
| virtual std::unique_ptr<EventLoop> MakePrimary() = 0; |
| |
| // Runs the loops until they quit. |
| virtual void Run() = 0; |
| |
| // Quits the loops. |
| virtual void Exit() = 0; |
| |
| // Advances time by sleeping. Can't be called from inside a loop. |
| virtual void SleepFor(::std::chrono::nanoseconds duration) = 0; |
| }; |
| |
| class AbstractEventLoopTestBase |
| : public ::testing::TestWithParam<std::function<EventLoopTestFactory *()>> { |
| public: |
| AbstractEventLoopTestBase() { factory_.reset(GetParam()()); } |
| |
| ::std::unique_ptr<EventLoop> Make() { return factory_->Make(); } |
| ::std::unique_ptr<EventLoop> MakePrimary() { return factory_->MakePrimary(); } |
| |
| void Run() { return factory_->Run(); } |
| |
| void Exit() { return factory_->Exit(); } |
| |
| void SleepFor(::std::chrono::nanoseconds duration) { |
| return factory_->SleepFor(duration); |
| } |
| |
| // Ends the given event loop at the given time from now. |
| void EndEventLoop(EventLoop *loop, ::std::chrono::milliseconds duration) { |
| auto end_timer = loop->AddTimer([this]() { this->Exit(); }); |
| end_timer->Setup(loop->monotonic_now() + |
| ::std::chrono::milliseconds(duration)); |
| } |
| |
| // You can implement all the usual fixture class members here. |
| // To access the test parameter, call GetParam() from class |
| // TestWithParam<T>. |
| private: |
| ::std::unique_ptr<EventLoopTestFactory> factory_; |
| }; |
| |
| typedef AbstractEventLoopTestBase AbstractEventLoopDeathTest; |
| typedef AbstractEventLoopTestBase AbstractEventLoopTest; |
| |
| } // namespace testing |
| } // namespace aos |
| |
| #endif // _AOS_EVENTS_EVENT_LOOP_PARAM_TEST_H_ |