summaryrefslogtreecommitdiff
path: root/test/message.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'test/message.cpp')
-rw-r--r--test/message.cpp88
1 files changed, 88 insertions, 0 deletions
diff --git a/test/message.cpp b/test/message.cpp
new file mode 100644
index 00000000..de98da3e
--- /dev/null
+++ b/test/message.cpp
@@ -0,0 +1,88 @@
+/* SPDX-License-Identifier: GPL-2.0-or-later */
+/*
+ * Copyright (C) 2019, Google Inc.
+ *
+ * message.cpp - Messages test
+ */
+
+#include <chrono>
+#include <iostream>
+#include <thread>
+
+#include "message.h"
+#include "thread.h"
+#include "test.h"
+#include "utils.h"
+
+using namespace std;
+using namespace libcamera;
+
+class MessageReceiver : public Object
+{
+public:
+ enum Status {
+ NoMessage,
+ InvalidThread,
+ MessageReceived,
+ };
+
+ MessageReceiver()
+ : status_(NoMessage)
+ {
+ }
+
+ Status status() const { return status_; }
+ void reset() { status_ = NoMessage; }
+
+protected:
+ void message(Message *msg)
+ {
+ if (thread() != Thread::current())
+ status_ = InvalidThread;
+ else
+ status_ = MessageReceived;
+ }
+
+private:
+ Status status_;
+};
+
+class MessageTest : public Test
+{
+protected:
+ int run()
+ {
+ MessageReceiver receiver;
+ receiver.moveToThread(&thread_);
+
+ thread_.start();
+
+ receiver.postMessage(utils::make_unique<Message>(Message::None));
+
+ this_thread::sleep_for(chrono::milliseconds(100));
+
+ switch (receiver.status()) {
+ case MessageReceiver::NoMessage:
+ cout << "No message received" << endl;
+ return TestFail;
+ case MessageReceiver::InvalidThread:
+ cout << "Message received in incorrect thread" << endl;
+ return TestFail;
+ default:
+ break;
+ }
+
+ return TestPass;
+ }
+
+ void cleanup()
+ {
+ thread_.exit(0);
+ thread_.wait();
+ }
+
+private:
+ Thread thread_;
+};
+
+TEST_REGISTER(MessageTest)