feat: add rt_prio support to Python binding

Author: patrislav1

pyudmaio/pyudmaio/binding.pyi

@@ -1,5 +1,4 @@
 from __future__ import annotations
-import numpy
 import typing
 __all__ = ['ConfigBase', 'ConfigUio', 'ConfigXdma', 'DEBUG', 'DataHandler', 'DmaBufferAbstract', 'FATAL', 'FpgaMemBufferOverAxi', 'FpgaMemBufferOverXdma', 'FrameFormat', 'HwAccessor', 'INFO', 'LogLevel', 'TRACE', 'UDmaBuf', 'UioAxiDmaIf', 'UioDeviceLocation', 'UioIf', 'UioMemSgdma', 'UioRegion', 'set_logging_level']
 class ConfigBase:
@@ -35,7 +34,7 @@ class DataHandler:
     @staticmethod
     def _pybind11_conduit_v1_(*args, **kwargs):
         ...
-    def __init__(self, dma: UioAxiDmaIf, desc: UioMemSgdma, mem: DmaBufferAbstract, receive_packets: bool = True, queue_size: int = 64) -> None:
+    def __init__(self, dma: UioAxiDmaIf, desc: UioMemSgdma, mem: DmaBufferAbstract, receive_packets: bool = True, queue_size: int = 64, rt_prio: bool = False) -> None:
         ...
     def read(self, ms_timeout: int) -> numpy.ndarray[numpy.uint8]:
         ...

pyudmaio/src/DataHandlerPython.cpp

@@ -17,13 +17,15 @@ DataHandlerPython::DataHandlerPython(std::shared_ptr<UioAxiDmaIf> dma_ptr,
                                      std::shared_ptr<UioMemSgdma> desc_ptr,
                                      std::shared_ptr<DmaBufferAbstract> mem_ptr,
                                      bool receive_packets,
-                                     size_t queue_size)
+                                     size_t queue_size,
+                                     bool rt_prio)
     : DataHandlerSync("DataHandlerPython",
                       *dma_ptr,
                       *desc_ptr,
                       *mem_ptr,
                       receive_packets,
-                      queue_size)
+                      queue_size,
+                      rt_prio)
     , _dma_ptr(dma_ptr)
     , _desc_ptr(desc_ptr)
     , _mem_ptr(mem_ptr) {}

pyudmaio/src/DataHandlerPython.hpp

@@ -31,7 +31,8 @@ class DataHandlerPython : public DataHandlerSync {
                       std::shared_ptr<UioMemSgdma>,
                       std::shared_ptr<DmaBufferAbstract>,
                       bool receive_packets = true,
-                      size_t queue_size = 64);
+                      size_t queue_size = 64,
+                      bool rt_prio = false);
 
     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

@@ -168,12 +168,14 @@ PYBIND11_MODULE(binding, m) {
                       std::shared_ptr<udmaio::UioMemSgdma>,
                       std::shared_ptr<udmaio::DmaBufferAbstract>,
                       bool,
-                      size_t>(),
+                      size_t,
+                      bool>(),
              py::arg("dma"),
              py::arg("desc"),
              py::arg("mem"),
              py::arg("receive_packets") = bool(true),
-             py::arg("queue_size") = size_t(64))
+             py::arg("queue_size") = size_t(64),
+             py::arg("rt_prio") = bool(false))
         .def("start",
              &udmaio::DataHandlerPython::start,
              py::arg("nr_pkts"),