1 files changed, 79 insertions, 0 deletions
diff --git a/mpm/python/usrp_mpm/xports/xportmgr_liberio.py b/mpm/python/usrp_mpm/xports/xportmgr_liberio.py
new file mode 100644
index 000000000..29a3d6673
--- /dev/null
+++ b/mpm/python/usrp_mpm/xports/xportmgr_liberio.py
@@ -0,0 +1,79 @@
+#
+# Copyright 2017 Ettus Research, National Instruments Company
+#
+# SPDX-License-Identifier: GPL-3.0
+#
+"""
+Liberio Transport manager
+"""
+
+from builtins import object
+from usrp_mpm.liberiotable import LiberioDispatcherTable
+from usrp_mpm import libpyusrp_periphs as lib
+
+class XportMgrLiberio(object):
+    """
+    Transport manager for Liberio connections
+    """
+    # udev label for the UIO device that controls the DMA engine
+    liberio_label = 'liberio'
+    # Number of available DMA channels
+    max_chan = 4
+    # Crossbar to which the Liberio DMA engine is connected
+    xbar_dev = "/dev/crossbar0"
+    xbar_port = 2
+
+    def __init__(self, log):
+        self.log = log
+        self._dma_dispatcher = LiberioDispatcherTable(self.liberio_label)
+        self._data_chan_ctr = 0
+
+    def init(self, args):
+        """
+        Call this when the user calls 'init' on the periph manager
+        """
+        pass
+
+    def deinit(self):
+        " Clean up after a session terminates "
+        self._data_chan_ctr = 0
+
+    def request_xport(
+            self,
+            sid,
+            xport_type,
+        ):
+        """
+        Return liberio xport info
+        """
+        assert xport_type in ('CTRL', 'ASYNC_MSG', 'TX_DATA', 'RX_DATA')
+        if xport_type == 'CTRL':
+            chan = 0
+        elif xport_type == 'ASYNC_MSG':
+            chan = 1
+        else:
+            chan = 2 + self._data_chan_ctr
+            self._data_chan_ctr += 1
+        xport_info = {
+            'type': 'liberio',
+            'send_sid': str(sid),
+            'muxed': str(xport_type in ('CTRL', 'ASYNC_MSG')),
+            'dma_chan': str(chan),
+            'tx_dev': "/dev/tx-dma{}".format(chan),
+            'rx_dev': "/dev/rx-dma{}".format(chan),
+        }
+        self.log.trace("Liberio: Chan: {} TX Device: {} RX Device: {}".format(
+            chan, xport_info['tx_dev'], xport_info['rx_dev']))
+        self.log.trace("Liberio channel is muxed: %s",
+                       "Yes" if xport_info['muxed'] else "No")
+        return [xport_info]
+
+    def commit_xport(self, sid, xport_info):
+        " Commit liberio transport "
+        chan = int(xport_info['dma_chan'])
+        xbar_iface = lib.xbar.xbar.make(self.xbar_dev)
+        xbar_iface.set_route(sid.src_addr, self.xbar_port)
+        self._dma_dispatcher.set_route(sid.reversed(), chan)
+        self.log.trace("Liberio transport successfully committed!")
+        return True
+