Feature/rialto hdmi issue

.github/workflows/native_rialto_build.yml

@@ -36,25 +36,11 @@ jobs:
 
       - name: Install Dependencies
         run: |
-          sudo apt-get update
-          sudo apt-get install build-essential
-          sudo apt-get install cmake
-          sudo apt-get install libunwind-dev libgstreamer-plugins-base1.0-dev libgstreamer-plugins-bad1.0-dev libgstreamer1.0-dev
-
-      - name: Install protobuf
-        run: |
-          sudo apt-get install protobuf-compiler
+          sudo sh -x install_dependencies_for_native_build.sh
 
       - name: Build Rialto
         run: |
-          cmake . -B build -DNATIVE_BUILD=ON -DRIALTO_BUILD_TYPE="Debug" &> output_file.txt
-          if [ $? -eq 0 ]
-          then
-            make -C build &>> output_file.txt
-          else
-            exit 1
-          fi
-
+          sh -x build_native.sh &> output_file.txt
 
       - name: Report Build Status Success
         if: success()

build_native.sh

@@ -0,0 +1,29 @@
+#!/bin/bash
+
+# If not stated otherwise in this file or this component's LICENSE file the
+# following copyright and licenses apply:
+#
+# Copyright 2026 Sky UK
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+# Script for building the Rialto Native.
+
+cmake . -B build -DNATIVE_BUILD=ON -DRIALTO_BUILD_TYPE="Debug"
+if [ $? -eq 0 ]
+then
+    make -C build -j$(nproc)
+else
+    exit 1
+fi

common/CMakeLists.txt

@@ -31,6 +31,7 @@ add_library(
         source/EventThread.cpp
         source/LinuxUtils.cpp
         source/Timer.cpp
+        source/Profiler.cpp
     )
 
 set_property (

common/include/Profiler.h

@@ -0,0 +1,69 @@
+/*
+ * If not stated otherwise in this file or this component's LICENSE file the
+ * following copyright and licenses apply:
+ *
+ * Copyright 2026 Sky UK
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef FIREBOLT_RIALTO_COMMON_PROFILER_H_
+#define FIREBOLT_RIALTO_COMMON_PROFILER_H_
+
+#include "IProfiler.h"
+
+#include <chrono>
+#include <memory>
+#include <mutex>
+#include <optional>
+#include <string>
+#include <vector>
+
+namespace firebolt::rialto::common
+{
+class ProfilerFactory : public IProfilerFactory
+{
+public:
+    std::unique_ptr<IProfiler> createProfiler(std::string moduleName) const override;
+};
+
+class Profiler final : public IProfiler
+{
+public:
+    explicit Profiler(std::string module);
+
+    bool isEnabled() const noexcept override;
+
+    std::optional<RecordId> record(const std::string &stage) override;
+    std::optional<RecordId> record(const std::string &stage, const std::string &info) override;
+
+    void log(const RecordId id) override;
+
+    bool dumpToFile() const override;
+    std::vector<Record> getRecords() const override;
+
+private:
+    std::optional<Record> findById(RecordId id) const;
+
+    std::string m_module;
+    bool m_enabled;
+    std::optional<std::string> m_dumpFileName;
+
+    mutable std::mutex m_mutex;
+    RecordId m_id{1};
+    std::vector<Record> m_records;
+};
+
+}; // namespace firebolt::rialto::common
+
+#endif // FIREBOLT_RIALTO_COMMON_PROFILER_H_

common/interface/IProfiler.h

@@ -0,0 +1,136 @@
+/*
+ * If not stated otherwise in this file or this component's LICENSE file the
+ * following copyright and licenses apply:
+ *
+ * Copyright 2026 Sky UK
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef FIREBOLT_RIALTO_COMMON_I_PROFILER_H_
+#define FIREBOLT_RIALTO_COMMON_I_PROFILER_H_
+
+#include <chrono>
+#include <cstdint>
+#include <functional>
+#include <memory>
+#include <optional>
+#include <string>
+#include <vector>
+
+namespace firebolt::rialto::common
+{
+class IProfiler;
+
+/**
+ * @brief IProfiler factory class, returns a concrete implementation of IProfiler
+ */
+class IProfilerFactory
+{
+public:
+    IProfilerFactory() = default;
+    virtual ~IProfilerFactory() = default;
+
+    /**
+     * @brief Creates a IProfilerFactory instance.
+     *
+     * @retval the factory instance or null on error.
+     */
+    static std::shared_ptr<IProfilerFactory> createFactory();
+
+    /**
+     * @brief Creates an IProfiler object.
+     *
+     * @param[in] moduleName    : The name of the module
+     *
+     * @retval the new profiler instance or null on error.
+     */
+    virtual std::unique_ptr<IProfiler> createProfiler(std::string moduleName) const = 0;
+};
+
+class IProfiler
+{
+public:
+    using RecordId = std::uint64_t;
+    using Clock = std::chrono::system_clock;
+
+    struct Record
+    {
+        std::string moduleName;
+        uint64_t id{0};
+        std::string stage;
+        std::string info;
+        Clock::time_point time;
+    };
+
+    virtual ~IProfiler() = default;
+
+    IProfiler(const IProfiler &) = delete;
+    IProfiler &operator=(const IProfiler &) = delete;
+    IProfiler(IProfiler &&) = delete;
+    IProfiler &operator=(IProfiler &&) = delete;
+
+    /**
+     * @brief Checks if profiler is enabled.
+     *
+     * @retval true if profiler is enabled, false otherwise.
+     */
+    virtual bool isEnabled() const noexcept = 0;
+
+    /**
+     * @brief Creates a record for given stage.
+     *
+     * @param[in] stage : Stage name used for record creation
+     *
+     * @retval Record identifier for created record or std::nullopt.
+     */
+    virtual std::optional<RecordId> record(const std::string &stage) = 0;
+
+    /**
+     * @brief Creates a record for given stage and info.
+     *
+     * @param[in] stage : Stage name used for record creation
+     * @param[in] info  : Additional information used for record creation
+     *
+     * @retval Record identifier for created record or std::nullopt.
+     */
+    virtual std::optional<RecordId> record(const std::string &stage, const std::string &info) = 0;
+
+    /**
+     * @brief Logs a record for given identifier.
+     *
+     * @param[in] id : Record identifier
+     */
+    virtual void log(RecordId id) = 0;
+
+    /**
+     * @brief Dumps all records into pre-configured file.
+     *
+     * @retval true if file is created and records are dumped, false otherwise.
+     */
+    virtual bool dumpToFile() const = 0;
+
+    /**
+     * @brief Retrieves existing records.
+     *
+     * @retval Snapshot copy of existing records.
+     */
+    virtual std::vector<Record> getRecords() const = 0;
+
+protected:
+    IProfiler() = default;
+};
+
+} // namespace firebolt::rialto::common
+
+#endif // FIREBOLT_RIALTO_COMMON_I_PROFILER_H_

common/source/EventThread.cpp

@@ -54,13 +54,11 @@ EventThread::EventThread(std::string threadName) : m_kThreadName(std::move(threa
 
 EventThread::~EventThread()
 {
-    std::unique_lock<std::mutex> locker(m_lock);
-
-    m_shutdown = true;
-
-    m_cond.notify_all();
-
-    locker.unlock();
+    {
+        std::lock_guard<std::mutex> locker(m_lock);
+        m_shutdown = true;
+        m_cond.notify_all();
+    }
 
     if (m_thread.joinable())
         m_thread.join();