1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
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
|
