1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 /* SPDX-License-Identifier: GPL-2.0-or-later */ /* * Copyright (C) 2019, Google Inc. * * stream_f/* SPDX-License-Identifier: GPL-2.0-or-later */ /* * Copyright (C) 2019, Google Inc. * * timer-thread.cpp - Threaded timer test */ #include <chrono> #include <iostream> #include <libcamera/event_dispatcher.h> #include <libcamera/timer.h> #include "test.h" #include "thread.h" using namespace std; using namespace libcamera; class TimeoutHandler : public Object { public: TimeoutHandler() : timer_(this), timeout_(false) { timer_.timeout.connect(this, &TimeoutHandler::timeoutHandler); timer_.start(100); } void restart() { timeout_ = false; timer_.start(100); } bool timeout() const { return timeout_; } private: void timeoutHandler(Timer *timer) { timeout_ = true; } Timer timer_; bool timeout_; }; class TimerThreadTest : public Test { protected: int init() { thread_.start(); timeout_.moveToThread(&thread_); return TestPass; } int run() { /* * Test that the timer expires and emits the timeout signal in * the thread it belongs to. */ this_thread::sleep_for(chrono::milliseconds(200)); if (!timeout_.timeout()) { cout << "Timer expiration test failed" << endl; return TestFail; } /* * Test that starting the timer from another thread fails. We * need to interrupt the event dispatcher to make sure we don't * succeed simply because the event dispatcher hasn't noticed * the timer restart. */ timeout_.restart(); thread_.eventDispatcher()->interrupt(); this_thread::sleep_for(chrono::milliseconds(200)); if (timeout_.timeout()) { cout << "Timer restart test failed" << endl; return TestFail; } return TestPass; } void cleanup() { /* Must stop thread before destroying timeout. */ thread_.exit(0); thread_.wait(); } private: TimeoutHandler timeout_; Thread thread_; }; TEST_REGISTER(TimerThreadTest)