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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
|
//
// Copyright 2017 Ettus Research, a National Instruments Company
//
// SPDX-License-Identifier: GPL-3.0
//
#ifndef INCLUDED_MPMD_IMPL_HPP
#define INCLUDED_MPMD_IMPL_HPP
#include "mpmd_xport_mgr.hpp"
#include "../../utils/rpc.hpp"
#include "../device3/device3_impl.hpp"
#include <uhd/stream.hpp>
#include <uhd/types/device_addr.hpp>
#include <uhd/types/dict.hpp>
#include <uhd/utils/tasks.hpp>
#include <uhd/transport/muxed_zero_copy_if.hpp>
#include <map>
#include <memory>
namespace uhd { namespace mpmd {
/*! Stores all attributes specific to a single MPM device
*/
class mpmd_mboard_impl
{
public:
/*** Types ***************************************************************/
using uptr = std::unique_ptr<mpmd_mboard_impl>;
using dev_info = std::map<std::string, std::string>;
/*** Structors ***********************************************************/
/*!
* \param mb_args Device args that pertain to this motherboard
* \param ip_addr RPC client will attempt to connect to this IP address
*/
mpmd_mboard_impl(
const uhd::device_addr_t &mb_args,
const std::string& ip_addr
);
~mpmd_mboard_impl();
/*** Factory *************************************************************/
/*!
* \param mb_args Device args that pertain to this motherboard
* \param ip_addr RPC client will attempt to connect to this IP address
*/
static uptr make(
const uhd::device_addr_t &mb_args,
const std::string& addr
);
/*** Public attributes ***************************************************/
//! These are the args given by the user, with some filtering/preprocessing
uhd::device_addr_t mb_args;
//! Device information is read back via MPM and stored here.
uhd::device_addr_t device_info;
//! Dboard info is read back via MPM and stored here. There will be one
// dictionary per dboard; but there's no requirement for the dictionary
// to be populated at all.
std::vector<uhd::device_addr_t> dboard_info;
//! Number of RFNoC crossbars on this device
size_t num_xbars = 0;
/*! Reference to the RPC client for this motherboard
*
* We store a shared ptr, because we might share it with some of the RFNoC
* blocks.
*/
uhd::rpc_client::sptr rpc;
/*************************************************************************
* API
************************************************************************/
//! Configure a crossbar to have a certain local address
void set_xbar_local_addr(const size_t xbar_index, const size_t local_addr);
//! Return the local address of a given crossbar
size_t get_xbar_local_addr(const size_t xbar_index) const {
return xbar_local_addrs.at(xbar_index);
}
//! Device-specific make_transport implementation
//
// A major difference to the mpmd_impl::make_transport() is the meaning of
// the first argument (\p sid). mpmd_impl::make_transport() will add a
// source part to the SID which needs to be taken into account in this
// function.
//
// \param sid The full SID of this transport (UHD to device)
// \param xport_type Transport type (CTRL, RX_DATA, ...)
// \param args Any kind of args passed in via get_?x_stream()
uhd::both_xports_t make_transport(
const sid_t& sid,
usrp::device3_impl::xport_type_t xport_type,
const uhd::device_addr_t& args
);
size_t get_mtu(const uhd::direction_t dir) const;
uhd::device_addr_t get_rx_hints() const;
uhd::device_addr_t get_tx_hints() const;
//! Set the RPC call timeout to the default value
void set_timeout_default();
private:
/*************************************************************************
* Private methods
************************************************************************/
/*! Renew the claim onto the device.
*
* This is meant to be called repeatedly, e.g., using a UHD task. See also
* _claimer_task.
*/
bool claim();
uhd::task::sptr claim_device_and_make_task(
uhd::rpc_client::sptr rpc,
const uhd::device_addr_t mb_args
);
/*************************************************************************
* Private attributes
************************************************************************/
//! Stores a list of local addresses of the crossbars. The local address is
// what we use when addressing a crossbar in a CHDR header.
std::vector<size_t> xbar_local_addrs;
/*! Continuously reclaims the device.
*/
uhd::task::sptr _claimer_task;
uhd::mpmd::xport::mpmd_xport_mgr::uptr _xport_mgr;
};
/*! Parent class of an MPM device
*
* An MPM device is a USRP running MPM. Because most of the hardware controls
* are taken care of by MPM itself, it is not necessary to write a specific
* derived class for every single type of MPM device.
*/
class mpmd_impl : public uhd::usrp::device3_impl
{
public:
//! Port on which the discovery process is listening (default value, it is
// user-overridable)
static const size_t MPM_DISCOVERY_PORT;
//! Device arg key to override the discovery port
static const std::string MPM_DISCOVERY_PORT_KEY;
//! Port on which the RPC process is listening (default value, it is user-
// overridable)
static const size_t MPM_RPC_PORT;
//! Device arg key to override the RPC port
static const std::string MPM_RPC_PORT_KEY;
//! This is the command that needs to be sent to the discovery port to
// trigger a response.
static const std::string MPM_DISCOVERY_CMD;
//! This is the command that will let you measure ping responses from the
// device via the discovery process. Useful for MTU discovery.
static const std::string MPM_ECHO_CMD;
//! This is the RPC command that will return the last known error from MPM.
static const std::string MPM_RPC_GET_LAST_ERROR_CMD;
/**************************************************************************
* Structors
************************************************************************/
mpmd_impl(const uhd::device_addr_t& device_addr);
~mpmd_impl();
/**************************************************************************
* API
************************************************************************/
uhd::both_xports_t make_transport(const uhd::sid_t&,
uhd::usrp::device3_impl::xport_type_t,
const uhd::device_addr_t&);
private:
uhd::device_addr_t get_rx_hints(size_t mb_index);
uhd::device_addr_t get_tx_hints(size_t mb_index);
/*************************************************************************
* Private methods/helpers
************************************************************************/
/*! Initialize a single motherboard
*
* - See mpmd_mboard_impl ctor for details
* - Also allocates the local crossbar addresses
*/
mpmd_mboard_impl::uptr setup_mb(
const size_t mb_i,
const uhd::device_addr_t& dev_addr
);
//! Setup all RFNoC blocks running on mboard \p mb_i
void setup_rfnoc_blocks(
const size_t mb_i,
const uhd::device_addr_t& block_args
);
//! Configure all blocks that require access to an RPC client
void setup_rpc_blocks(
const uhd::device_addr_t &block_args,
const bool serialize_init
);
/*! Returns a valid local address for a crossbar
*
* \returns Valid local address
* \throws uhd::runtime_error if there are no more local addresses
*/
size_t allocate_xbar_local_addr();
/*! Return the index of the motherboard given the local address of a
* crossbar
*/
size_t identify_mboard_by_xbar_addr(const size_t xbar_addr) const;
/*************************************************************************
* Private attributes
************************************************************************/
//! Stores the args with which the device was originally initialized
uhd::device_addr_t _device_args;
//! Stores a list of mboard references
std::vector<mpmd_mboard_impl::uptr> _mb;
//! A counter for distributing local addresses to crossbars
// No-one touches this except allocate_xbar_local_addr(), gotcha?
size_t _xbar_local_addr_ctr = 2;
};
}} /* namespace uhd::mpmd */
uhd::device_addrs_t mpmd_find(const uhd::device_addr_t& hint_);
#endif /* INCLUDED_MPMD_IMPL_HPP */
// vim: sw=4 expandtab:
|
