blob: 1afe5db8041f0eab99add68d7fda6f60eb956fee (
plain)
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
|
//
// Copyright 2019 Ettus Research, a National Instruments Brand
//
// SPDX-License-Identifier: GPL-3.0-or-later
//
#ifndef INCLUDED_LIBUHD_RFNOC_RX_STREAMER_HPP
#define INCLUDED_LIBUHD_RFNOC_RX_STREAMER_HPP
#include <uhd/rfnoc/node.hpp>
#include <uhdlib/rfnoc/chdr_rx_data_xport.hpp>
#include <uhdlib/transport/rx_streamer_impl.hpp>
#include <atomic>
#include <string>
namespace uhd { namespace rfnoc {
/*!
* Extends the streamer_impl to be an rfnoc node so it can connect to the
* graph. Configures the streamer conversion and rate parameters with values
* received through property propagation.
*/
class rfnoc_rx_streamer : public node_t,
public transport::rx_streamer_impl<chdr_rx_data_xport>
{
public:
/*! Constructor
*
* \param num_ports The number of ports
* \param stream_args Arguments to aid the construction of the streamer
*/
rfnoc_rx_streamer(const size_t num_ports, const uhd::stream_args_t stream_args);
/*! Returns a unique identifier string for this node. In every RFNoC graph,
* no two nodes cannot have the same ID. Returns a string in the form of
* "RxStreamer#0".
*
* \returns The unique ID as a string
*/
std::string get_unique_id() const;
/*! Returns the number of input ports for this block.
*
* \return noc_id The number of ports
*/
size_t get_num_input_ports() const;
/*! Returns the number of output ports for this block.
*
* Always returns 0 for this block.
*
* \return noc_id The number of ports
*/
size_t get_num_output_ports() const;
/*! Implementation of rx_streamer API method
*
* \param stream_cmd the stream command to issue
*/
void issue_stream_cmd(const stream_cmd_t& stream_cmd);
/*! Returns stream args provided at creation
*
* \return stream args provided when streamer is created
*/
const uhd::stream_args_t& get_stream_args() const;
/*! Check that all streamer ports are connected to blocks
*
* Overrides node_t to ensure there are no unconnected ports.
*
* \param connected_inputs A list of input ports that are connected
* \param connected_outputs A list of output ports that are connected
* \returns true if the block can deal with this configuration
*/
bool check_topology(const std::vector<size_t>& connected_inputs,
const std::vector<size_t>& connected_outputs);
/*! Connects a channel to the streamer port
*
* Overrides method in rx_streamer_impl.
*
* \param channel The streamer channel to which to connect
* \param xport The transport for the specified channel
*/
void connect_channel(const size_t channel, chdr_rx_data_xport::uptr xport);
private:
void _register_props(const size_t chan, const std::string& otw_format);
void _handle_rx_event_action(
const res_source_info& src, rx_event_action_info::sptr rx_event_action);
void _handle_stream_cmd_action(
const res_source_info& src, stream_cmd_action_info::sptr stream_cmd_action);
void _handle_overrun();
// Properties
std::vector<property_t<double>> _scaling_in;
std::vector<property_t<double>> _samp_rate_in;
std::vector<property_t<double>> _tick_rate_in;
std::vector<property_t<std::string>> _type_in;
std::vector<property_t<size_t>> _mtu_in;
// Streamer unique ID
const std::string _unique_id;
// Stream args provided at construction
const uhd::stream_args_t _stream_args;
std::atomic<bool> _overrun_handling_mode{false};
size_t _overrun_channel = 0;
};
}} // namespace uhd::rfnoc
#endif /* INCLUDED_LIBUHD_RFNOC_RX_STREAMER_HPP */
|
