feat(python): add queue_size arg to DataHandler

Author: patrislav1

pyudmaio/src/DataHandlerPython.cpp

@@ -16,8 +16,14 @@ namespace udmaio {
 DataHandlerPython::DataHandlerPython(std::shared_ptr<UioAxiDmaIf> dma_ptr,
                                      std::shared_ptr<UioMemSgdma> desc_ptr,
                                      std::shared_ptr<DmaBufferAbstract> mem_ptr,
-                                     bool receive_packets)
-    : DataHandlerSync("DataHandlerPython", *dma_ptr, *desc_ptr, *mem_ptr, receive_packets)
+                                     bool receive_packets,
+                                     size_t queue_size)
+    : DataHandlerSync("DataHandlerPython",
+                      *dma_ptr,
+                      *desc_ptr,
+                      *mem_ptr,
+                      receive_packets,
+                      queue_size)
     , _dma_ptr(dma_ptr)
     , _desc_ptr(desc_ptr)
     , _mem_ptr(mem_ptr) {}

pyudmaio/src/DataHandlerPython.hpp

@@ -30,7 +30,8 @@ class DataHandlerPython : public DataHandlerSync {
     DataHandlerPython(std::shared_ptr<UioAxiDmaIf>,
                       std::shared_ptr<UioMemSgdma>,
                       std::shared_ptr<DmaBufferAbstract>,
-                      bool receive_packets = true);
+                      bool receive_packets = true,
+                      size_t queue_size = 64);
 
     void start(int nr_pkts, size_t pkt_size, bool init_only = false);
     py::array_t<uint8_t> numpy_read(uint32_t ms_timeout = 0);

pyudmaio/src/PythonBinding.cpp

@@ -124,11 +124,13 @@ PYBIND11_MODULE(binding, m) {
         .def(py::init<std::shared_ptr<udmaio::UioAxiDmaIf>,
                       std::shared_ptr<udmaio::UioMemSgdma>,
                       std::shared_ptr<udmaio::DmaBufferAbstract>,
-                      bool>(),
+                      bool,
+                      size_t>(),
              py::arg("dma"),
              py::arg("desc"),
              py::arg("mem"),
-             py::arg("receive_packets") = bool(true))
+             py::arg("receive_packets") = bool(true),
+             py::arg("queue_size") = size_t(64))
         .def("start",
              &udmaio::DataHandlerPython::start,
              py::arg("nr_pkts"),