feat(DataHandlerSync): variable queue size

Author: patrislav1

inc/udmaio/ConcurrentQueue.hpp

@@ -11,6 +11,7 @@
 
 #pragma once
 
+#include <algorithm>
 #include <chrono>
 #include <condition_variable>
 #include <mutex>
@@ -51,7 +52,7 @@ class ConcurrentQueue {
     /// @param item Element to push to the queue
     void push(T item) {
         std::unique_lock<std::mutex> lock(_mutex);
-        if (_queue.size() >= MAX_ELEMS) {
+        if (_queue.size() >= _max_elems) {
             lock.unlock();
             throw std::runtime_error("libudmaio: ConcurrentQueue full");
         }
@@ -66,15 +67,15 @@ class ConcurrentQueue {
         _cond.notify_one();
     }
 
-    ConcurrentQueue() = default;
+    ConcurrentQueue(size_t max_elems = 64) : _max_elems{max_elems} {}
     ConcurrentQueue(const ConcurrentQueue&) = delete;
     ConcurrentQueue& operator=(const ConcurrentQueue&) = delete;
 
   private:
     std::queue<T> _queue;
     std::mutex _mutex;
     std::condition_variable _cond;
-    constexpr static size_t MAX_ELEMS = 64;
+    size_t _max_elems;
     bool _abort = false;
 };
 

inc/udmaio/DataHandlerSync.hpp

@@ -11,6 +11,8 @@
 
 #pragma once
 
+#include <cstddef>
+#include <iterator>
 #include <optional>
 #include <thread>
 
@@ -25,7 +27,14 @@ class DataHandlerSync : public DataHandlerAbstract {
     std::optional<std::thread> _ioThread;          ///< I/O thread
 
   public:
-    using DataHandlerAbstract::DataHandlerAbstract;
+    explicit DataHandlerSync(std::string name,
+                             UioAxiDmaIf& dma,
+                             UioMemSgdma& desc,
+                             DmaBufferAbstract& mem,
+                             bool receive_packets = true,
+                             size_t queue_size = 64)
+        : DataHandlerAbstract{name, dma, desc, mem, receive_packets}, _queue{queue_size} {}
+
     virtual ~DataHandlerSync();
 
     /// Run the data reception