[libcamera-devel,11/11] test: Add event notifier test

Message ID 20190106023328.10989-11-laurent.pinchart@ideasonboard.com
State Accepted
Headers show
Series
  • [libcamera-devel,01/11] libcamera: log: Add a LogFatal log level
Related show

Commit Message

Laurent Pinchart Jan. 6, 2019, 2:33 a.m. UTC
Signed-off-by: Laurent Pinchart <laurent.pinchart@ideasonboard.com>
---
 test/event.cpp   | 117 +++++++++++++++++++++++++++++++++++++++++++++++
 test/meson.build |   1 +
 2 files changed, 118 insertions(+)
 create mode 100644 test/event.cpp

Patch

diff --git a/test/event.cpp b/test/event.cpp
new file mode 100644
index 000000000000..52bc0c7e77f5
--- /dev/null
+++ b/test/event.cpp
@@ -0,0 +1,117 @@ 
+/* SPDX-License-Identifier: GPL-2.0-or-later */
+/*
+ * Copyright (C) 2019, Google Inc.
+ *
+ * event.cpp - Event test
+ */
+
+#include <iostream>
+#include <string.h>
+#include <unistd.h>
+
+#include <libcamera/camera_manager.h>
+#include <libcamera/event_dispatcher.h>
+#include <libcamera/event_notifier.h>
+#include <libcamera/timer.h>
+
+#include "test.h"
+
+using namespace std;
+using namespace libcamera;
+
+class EventTest : public Test
+{
+protected:
+	void readReady(EventNotifier *notifier)
+	{
+		size_ = read(notifier->fd(), data_, sizeof(data_));
+		notified_ = true;
+	}
+
+	int init()
+	{
+		return pipe(pipefd_);
+	}
+
+	int run()
+	{
+		EventDispatcher *dispatcher = CameraManager::instance()->eventDispatcher();
+		std::string data("H2G2");
+		Timer timeout;
+
+		EventNotifier readNotifier(pipefd_[0], EventNotifier::Read);
+		readNotifier.activated.connect(this, &EventTest::readReady);
+
+		/* Test read notification with data. */
+		memset(data_, 0, sizeof(data_));
+		size_ = 0;
+
+		write(pipefd_[1], data.data(), data.size());
+
+		timeout.start(100);
+		dispatcher->processEvents();
+		timeout.stop();
+
+		if (static_cast<size_t>(size_) != data.size()) {
+			cout << "Event notifier read ready test failed" << endl;
+			return TestFail;
+		}
+
+		/* Test read notification without data. */
+		notified_ = false;
+
+		timeout.start(100);
+		dispatcher->processEvents();
+		timeout.stop();
+
+		if (notified_) {
+			cout << "Event notifier read no ready test failed" << endl;
+			return TestFail;
+		}
+
+		/* Test read notifier disabling. */
+		notified_ = false;
+		readNotifier.setEnabled(false);
+
+		write(pipefd_[1], data.data(), data.size());
+
+		timeout.start(100);
+		dispatcher->processEvents();
+		timeout.stop();
+
+		if (notified_) {
+			cout << "Event notifier read disabling failed" << endl;
+			return TestFail;
+		}
+
+		/* Test read notifier enabling. */
+		notified_ = false;
+		readNotifier.setEnabled(true);
+
+		timeout.start(100);
+		dispatcher->processEvents();
+		timeout.stop();
+
+		if (!notified_) {
+			cout << "Event notifier read enabling test failed" << endl;
+			return TestFail;
+		}
+
+		return TestPass;
+	}
+
+	void cleanup()
+	{
+		close(pipefd_[0]);
+		close(pipefd_[1]);
+	}
+
+private:
+	int pipefd_[2];
+
+	bool notified_;
+	char data_[16];
+	ssize_t size_;
+};
+
+TEST_REGISTER(EventTest)
diff --git a/test/meson.build b/test/meson.build
index 12e7b30d4f73..e923404502b7 100644
--- a/test/meson.build
+++ b/test/meson.build
@@ -3,6 +3,7 @@  subdir('libtest')
 subdir('media_device')
 
 public_tests = [
+    ['event',           'event.cpp'],
     ['list-cameras',    'list.cpp'],
     ['signal',          'signal.cpp'],
     ['timer',           'timer.cpp'],