summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorLaurent Pinchart <laurent.pinchart@ideasonboard.com>2024-11-18 20:54:15 +0200
committerLaurent Pinchart <laurent.pinchart@ideasonboard.com>2024-11-26 19:05:19 +0200
commitb68d898909e346df6bfd02e516f101867ee6ed21 (patch)
tree420c431dc22e886e175ff0edc750ee7f5acc1fe7
parentbc10ffca97fffe6d5ee9a7a054fb05bba13607a8 (diff)
ipa: libipa: vector: Add scalar constructor
The default constructor leaves the vector data uninitialized. Add a constructor to fill the vector with copies of a scalar value, and fix the documentation of the default constructor. Signed-off-by: Laurent Pinchart <laurent.pinchart@ideasonboard.com> Reviewed-by: Milan Zamazal <mzamazal@redhat.com>
-rw-r--r--src/ipa/libipa/vector.cpp8
-rw-r--r--src/ipa/libipa/vector.h5
2 files changed, 12 insertions, 1 deletions
diff --git a/src/ipa/libipa/vector.cpp b/src/ipa/libipa/vector.cpp
index 0f0511da..5851b9ae 100644
--- a/src/ipa/libipa/vector.cpp
+++ b/src/ipa/libipa/vector.cpp
@@ -29,7 +29,13 @@ namespace ipa {
/**
* \fn Vector::Vector()
- * \brief Construct a zero vector
+ * \brief Construct an uninitialized vector
+ */
+
+/**
+ * \fn Vector::Vector(T scalar)
+ * \brief Construct a vector filled with a \a scalar value
+ * \param[in] scalar The scalar value
*/
/**
diff --git a/src/ipa/libipa/vector.h b/src/ipa/libipa/vector.h
index 3168835b..5fb7ad7c 100644
--- a/src/ipa/libipa/vector.h
+++ b/src/ipa/libipa/vector.h
@@ -35,6 +35,11 @@ class Vector
public:
constexpr Vector() = default;
+ constexpr explicit Vector(T scalar)
+ {
+ data_.fill(scalar);
+ }
+
constexpr Vector(const std::array<T, Rows> &data)
{
for (unsigned int i = 0; i < Rows; i++)
">; 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() : pipeline_(nullptr), libcameraSrc_(nullptr) { /* * 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() { g_clear_object(&pipeline_); g_clear_object(&libcameraSrc_); gst_deinit(); } int GstreamerTest::createPipeline() { libcameraSrc_ = gst_element_factory_make("libcamerasrc", "libcamera"); pipeline_ = gst_pipeline_new("test-pipeline"); if (!libcameraSrc_ || !pipeline_) { g_printerr("Unable to create create pipeline %p.%p\n", libcameraSrc_, pipeline_); return TestFail; } g_object_ref_sink(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<GstMessageType>(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"); }