test: threads: Add wait() timeout test

Add a test case to wait with a timeout, testing both a too short and a
long enough duration.

Signed-off-by: Laurent Pinchart <laurent.pinchart@ideasonboard.com>
Reviewed-by: Kieran Bingham <kieran.bingham@ideasonboard.com>
Reviewed-by: Niklas Söderlund <niklas.soderlund@ragnatech.se>
This commit is contained in:
Laurent Pinchart 2020-01-23 04:50:02 +02:00
parent 3f207e0b33
commit a6388e494e

View file

@ -15,24 +15,22 @@
using namespace std; using namespace std;
using namespace libcamera; using namespace libcamera;
class InstrumentedThread : public Thread class DelayThread : public Thread
{ {
public: public:
InstrumentedThread(unsigned int iterations) DelayThread(chrono::steady_clock::duration duration)
: iterations_(iterations) : duration_(duration)
{ {
} }
protected: protected:
void run() void run()
{ {
for (unsigned int i = 0; i < iterations_; ++i) { this_thread::sleep_for(duration_);
this_thread::sleep_for(chrono::milliseconds(50));
}
} }
private: private:
unsigned int iterations_; chrono::steady_clock::duration duration_;
}; };
class ThreadTest : public Test class ThreadTest : public Test
@ -82,6 +80,27 @@ protected:
delete thread; delete thread;
/* Test waiting for completion with a timeout. */
thread = new DelayThread(chrono::milliseconds(500));
thread->start();
thread->exit(0);
bool timeout = !thread->wait(chrono::milliseconds(100));
if (!timeout) {
cout << "Waiting for thread didn't time out" << endl;
return TestFail;
}
timeout = !thread->wait(chrono::milliseconds(1000));
if (timeout) {
cout << "Waiting for thread timed out" << endl;
return TestFail;
}
delete thread;
return TestPass; return TestPass;
} }