From 980d1ee0c0e15fc3c8332138f9e39f3b2df1ea9c Mon Sep 17 00:00:00 2001 From: Laurent Pinchart Date: Sun, 11 Aug 2019 18:51:48 +0300 Subject: test: Add Object class thread affinity test MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit The test verifies thread affinity and thread move notifications. Signed-off-by: Laurent Pinchart Reviewed-by: Jacopo Mondi Reviewed-by: Niklas Söderlund --- test/meson.build | 1 + test/object.cpp | 88 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 89 insertions(+) create mode 100644 test/object.cpp diff --git a/test/meson.build b/test/meson.build index 7c9abc63..c6601813 100644 --- a/test/meson.build +++ b/test/meson.build @@ -24,6 +24,7 @@ public_tests = [ internal_tests = [ ['camera-sensor', 'camera-sensor.cpp'], ['message', 'message.cpp'], + ['object', 'object.cpp'], ['object-invoke', 'object-invoke.cpp'], ['signal-threads', 'signal-threads.cpp'], ['threads', 'threads.cpp'], diff --git a/test/object.cpp b/test/object.cpp new file mode 100644 index 00000000..3f1f700d --- /dev/null +++ b/test/object.cpp @@ -0,0 +1,88 @@ +/* SPDX-License-Identifier: GPL-2.0-or-later */ +/* + * Copyright (C) 2019, Google Inc. + * + * object.cpp - Object tests + */ + +#include + +#include + +#include "message.h" +#include "thread.h" + +#include "test.h" + +using namespace std; +using namespace libcamera; + +class InstrumentedObject : public Object +{ +public: + enum Status { + NoMessage, + MessageReceived, + }; + + InstrumentedObject() + : status_(NoMessage) + { + } + + Status status() const { return status_; } + void reset() { status_ = NoMessage; } + +protected: + void message(Message *msg) override + { + if (msg->type() == Message::ThreadMoveMessage) + status_ = MessageReceived; + + Object::message(msg); + } + +private: + Status status_; +}; + +class ObjectTest : public Test +{ +protected: + int init() + { + a_ = new InstrumentedObject(); + return TestPass; + } + + int run() + { + /* Verify that moving an object to a different thread succeeds. */ + a_->moveToThread(&thread_); + + if (a_->thread() != &thread_ || a_->thread() == Thread::current()) { + cout << "Failed to move object to thread" << endl; + return TestFail; + } + + /* Verify that objects receive a ThreadMoveMessage when moved. */ + if (a_->status() != InstrumentedObject::MessageReceived) { + cout << "Moving object didn't deliver ThreadMoveMessage" << endl; + return TestFail; + } + + return TestPass; + } + + void cleanup() + { + delete a_; + } + +private: + InstrumentedObject *a_; + + Thread thread_; +}; + +TEST_REGISTER(ObjectTest) -- cgit v1.2.1