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_single_stream_test.cpp | 145 ++++-------------------- 1 file changed, 24 insertions(+), 121 deletions(-) (limited to 'test/gstreamer/gstreamer_single_stream_test.cpp') diff --git a/test/gstreamer/gstreamer_single_stream_test.cpp b/test/gstreamer/gstreamer_single_stream_test.cpp index 4c8d4804..7292f328 100644 --- a/test/gstreamer/gstreamer_single_stream_test.cpp +++ b/test/gstreamer/gstreamer_single_stream_test.cpp @@ -14,104 +14,48 @@ #include +#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"; -} -} - -class GstreamerSingleStreamTest : public Test +class GstreamerSingleStreamTest : public GstreamerTest, public Test { +public: + GstreamerSingleStreamTest() + : GstreamerTest() + { + } + protected: int init() override { - /* - * 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"); + if (status_ != TestPass) + return status_; - return TestFail; - } + g_autoptr(GstElement) convert0 = gst_element_factory_make("videoconvert", "convert0"); + g_autoptr(GstElement) sink0 = gst_element_factory_make("fakesink", "sink0"); + g_object_ref_sink(convert0); + g_object_ref_sink(sink0); - /* - * Remove the system libcamera plugin, if any, and add the - * plugin from the build directory. - */ - GstRegistry *registry = gst_registry_get(); - GstPlugin *plugin = gst_registry_lookup(registry, "libgstlibcamera.so"); - if (plugin) { - gst_registry_remove_plugin(registry, plugin); - gst_object_unref(plugin); - } + if (!convert0 || !sink0) { + g_printerr("Not all elements could be created. %p.%p\n", + convert0, sink0); - 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"); - gst_deinit(); return TestFail; } - /* Create the elements */ - libcameraSrc_ = gst_element_factory_make("libcamerasrc", "libcamera"); - convert0_ = gst_element_factory_make("videoconvert", "convert0"); - sink0_ = gst_element_factory_make("fakesink", "sink0"); - - /* Create the empty pipeline_ */ - pipeline_ = gst_pipeline_new("test-pipeline"); - - if (!pipeline_ || !convert0_ || !sink0_ || !libcameraSrc_) { - g_printerr("Not all elements could be created. %p.%p.%p.%p\n", - pipeline_, convert0_, sink0_, libcameraSrc_); - if (pipeline_) - gst_object_unref(pipeline_); - if (convert0_) - gst_object_unref(convert0_); - if (sink0_) - gst_object_unref(sink0_); - if (libcameraSrc_) - gst_object_unref(libcameraSrc_); - gst_deinit(); + convert0_ = reinterpret_cast(g_steal_pointer(&convert0)); + sink0_ = reinterpret_cast(g_steal_pointer(&sink0)); + if (createPipeline() != TestPass) return TestFail; - } return TestPass; } - void cleanup() override - { - gst_object_unref(pipeline_); - gst_deinit(); - } - int run() override { - GstStateChangeReturn ret; - /* Build the pipeline */ gst_bin_add_many(GST_BIN(pipeline_), libcameraSrc_, convert0_, sink0_, NULL); if (gst_element_link_many(libcameraSrc_, convert0_, sink0_, NULL) != TRUE) { @@ -119,57 +63,16 @@ protected: return TestFail; } - /* 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"); + if (startPipeline() != TestPass) return TestFail; - } - /* 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: - gstreamer_print_error(msg); - break; - case GST_MESSAGE_EOS: - g_print("End-Of-Stream reached.\n"); - break; - default: - g_printerr("Unexpected message received.\n"); - break; - } + if (processEvent() != TestPass) + return TestFail; - return TestFail; + return TestPass; } private: - void gstreamer_print_error(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"); - } - - GstElement *pipeline_; - GstElement *libcameraSrc_; GstElement *convert0_; GstElement *sink0_; }; -- cgit v1.2.1