From 39c2d5dc95e46b8c1659b721521e4e438ab7d8a3 Mon Sep 17 00:00:00 2001 From: Vedant Paranjape Date: Wed, 8 Sep 2021 13:24:42 +0530 Subject: test: gstreamer: Factor out code into a base class A lot of code used in the single stream test is boiler plate and common across every gstreamer test. Factor out this code into a base class called GstreamerTest. Also update the gstreamer_single_stream_test to use the GstreamerTest base class. Signed-off-by: Vedant Paranjape Reviewed-by: Nicolas Dufresne Reviewed-by: Paul Elder Signed-off-by: Paul Elder --- test/gstreamer/gstreamer_test.cpp | 155 ++++++++++++++++++++++++++++++++++++++ 1 file changed, 155 insertions(+) create mode 100644 test/gstreamer/gstreamer_test.cpp (limited to 'test/gstreamer/gstreamer_test.cpp') diff --git a/test/gstreamer/gstreamer_test.cpp b/test/gstreamer/gstreamer_test.cpp new file mode 100644 index 00000000..dbdcaec0 --- /dev/null +++ b/test/gstreamer/gstreamer_test.cpp @@ -0,0 +1,155 @@ +/* SPDX-License-Identifier: GPL-2.0-or-later */ +/* + * Copyright (C) 2021, Vedant Paranjape + * + * libcamera Gstreamer element API tests + */ + +#include "gstreamer_test.h" + +#include "test.h" + +using namespace std; + +extern "C" { +const char *__asan_default_options() +{ + /* + * Disable leak detection due to a known global variable initialization + * leak in glib's g_quark_init(). This should ideally be handled by + * using a suppression file instead of disabling leak detection. + */ + return "detect_leaks=false"; +} +} + +GstreamerTest::GstreamerTest() +{ + /* + * GStreamer by default spawns a process to run the + * gst-plugin-scanner helper. If libcamera is compiled with ASan + * enabled, and as GStreamer is most likely not, this causes the + * ASan link order check to fail when gst-plugin-scanner + * dlopen()s the plugin as many libraries will have already been + * loaded by then. Fix this issue by disabling spawning of a + * child helper process when scanning the build directory for + * plugins. + */ + gst_registry_fork_set_enabled(false); + + /* Initialize GStreamer */ + g_autoptr(GError) errInit = NULL; + if (!gst_init_check(nullptr, nullptr, &errInit)) { + g_printerr("Could not initialize GStreamer: %s\n", + errInit ? errInit->message : "unknown error"); + + status_ = TestFail; + return; + } + + /* + * Remove the system libcamera plugin, if any, and add the + * plugin from the build directory. + */ + GstRegistry *registry = gst_registry_get(); + g_autoptr(GstPlugin) plugin = gst_registry_lookup(registry, "libgstlibcamera.so"); + if (plugin) + gst_registry_remove_plugin(registry, plugin); + + std::string path = libcamera::utils::libcameraBuildPath() + "src/gstreamer"; + if (!gst_registry_scan_path(registry, path.c_str())) { + g_printerr("Failed to add plugin to registry\n"); + + status_ = TestFail; + return; + } + + status_ = TestPass; +} + +GstreamerTest::~GstreamerTest() +{ + if (libcameraSrc_ && + !gst_object_has_as_ancestor(GST_OBJECT(libcameraSrc_), + GST_OBJECT(pipeline_))) + gst_object_unref(libcameraSrc_); + if (pipeline_) + gst_object_unref(pipeline_); + + gst_deinit(); +} + +int GstreamerTest::createPipeline() +{ + g_autoptr(GstElement) libcameraSrc = gst_element_factory_make("libcamerasrc", "libcamera"); + pipeline_ = gst_pipeline_new("test-pipeline"); + g_object_ref_sink(libcameraSrc); + + if (!libcameraSrc || !pipeline_) { + g_printerr("Unable to create create pipeline %p.%p\n", + libcameraSrc, pipeline_); + + return TestFail; + } + + libcameraSrc_ = reinterpret_cast(g_steal_pointer(&libcameraSrc)); + + return TestPass; +} + +int GstreamerTest::startPipeline() +{ + GstStateChangeReturn ret; + + /* Start playing */ + ret = gst_element_set_state(pipeline_, GST_STATE_PLAYING); + if (ret == GST_STATE_CHANGE_FAILURE) { + g_printerr("Unable to set the pipeline to the playing state.\n"); + return TestFail; + } + + return TestPass; +} + +int GstreamerTest::processEvent() +{ + /* Wait until error or EOS or timeout after 2 seconds */ + constexpr GstMessageType msgType = + static_cast(GST_MESSAGE_ERROR | GST_MESSAGE_EOS); + constexpr GstClockTime timeout = 2 * GST_SECOND; + + g_autoptr(GstBus) bus = gst_element_get_bus(pipeline_); + g_autoptr(GstMessage) msg = gst_bus_timed_pop_filtered(bus, timeout, msgType); + + gst_element_set_state(pipeline_, GST_STATE_NULL); + + /* Parse error message */ + if (msg == NULL) + return TestPass; + + switch (GST_MESSAGE_TYPE(msg)) { + case GST_MESSAGE_ERROR: + printError(msg); + break; + case GST_MESSAGE_EOS: + g_print("End-Of-Stream reached.\n"); + break; + default: + g_printerr("Unexpected message received.\n"); + break; + } + + return TestFail; +} + +void GstreamerTest::printError(GstMessage *msg) +{ + g_autoptr(GError) err = NULL; + g_autofree gchar *debug_info = NULL; + + gst_message_parse_error(msg, &err, &debug_info); + g_printerr("Error received from element %s: %s\n", + GST_OBJECT_NAME(msg->src), err->message); + g_printerr("Debugging information: %s\n", + debug_info ? debug_info : "none"); +} -- cgit v1.2.1