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
|
//
// Copyright 2019 Ettus Research, a National Instruments Brand
//
// SPDX-License-Identifier: GPL-3.0-or-later
//
#pragma once
#include <uhd/rfnoc/chdr_types.hpp>
#include <uhdlib/rfnoc/chdr_packet_writer.hpp>
#include <uhdlib/transport/io_service.hpp>
#include <mutex>
namespace uhd { namespace rfnoc {
/*!
* Represents a transport for CHDR control streams and management streams
*/
class chdr_ctrl_xport
{
public:
using io_service = uhd::transport::io_service;
using frame_buff = uhd::transport::frame_buff;
using send_link_if = uhd::transport::send_link_if;
using recv_link_if = uhd::transport::recv_link_if;
using send_io_if = uhd::transport::send_io_if;
using recv_io_if = uhd::transport::recv_io_if;
using disconnect_callback_t = uhd::transport::disconnect_callback_t;
using sptr = std::shared_ptr<chdr_ctrl_xport>;
/*!
* Make a chdr_ctrl_xport
*
* \param io_srv The I/O service that send_link and recv_link are attached to
* \param send_link Link to use for sending packets
* \param recv_link Link to use for receiving packets
* \param my_epid The local EPID for this transport
* \param num_send_frames Number of frames to reserve for TX
* \param num_recv_frames Number of frames to reserve for RX
* \param disconnect Callback function to disconnect the links
*/
static sptr make(io_service::sptr io_srv,
send_link_if::sptr send_link,
recv_link_if::sptr recv_link,
const chdr::chdr_packet_factory& pkt_factory,
sep_id_t my_epid,
size_t num_send_frames,
size_t num_recv_frames,
disconnect_callback_t disconnect)
{
return std::make_shared<chdr_ctrl_xport>(io_srv,
send_link,
recv_link,
pkt_factory,
my_epid,
num_send_frames,
num_recv_frames,
disconnect);
}
/*!
* Make a chdr_ctrl_xport
*
* \param io_srv The I/O service that send_link and recv_link are attached to
* \param send_link Link to use for sending packets
* \param recv_link Link to use for receiving packets
* \param my_epid The local EPID for this transport
* \param num_send_frames Number of frames to reserve for TX
* \param num_recv_frames Number of frames to reserve for RX
* \param disconnect Callback function to disconnect the links
*/
chdr_ctrl_xport(io_service::sptr io_srv,
send_link_if::sptr send_link,
recv_link_if::sptr recv_link,
const chdr::chdr_packet_factory& pkt_factory,
sep_id_t my_epid,
size_t num_send_frames,
size_t num_recv_frames,
disconnect_callback_t disconnect);
~chdr_ctrl_xport();
/*!
* Get an empty frame buffer in which to write packet contents.
*
* \param timeout_ms a positive timeout value specifies the maximum number
of ms to wait, a negative value specifies to block
until successful, and a value of 0 specifies no wait.
* \return a frame buffer, or null uptr if timeout occurs
*/
frame_buff::uptr get_send_buff(int32_t timeout_ms);
/*!
* Release a frame buffer, allowing the driver to reuse it.
*
* \param buffer frame buffer to release for reuse by the link
*/
void release_send_buff(frame_buff::uptr buff);
/*!
* Attempt to get a frame buffer with data from the recv link.
*
* Receives packets from the control stream.
*
* \param timeout_ms a positive timeout value specifies the maximum number
of ms to wait, a negative value specifies to block
until successful, and a value of 0 specifies no wait.
* \return a frame buffer, or null uptr if timeout occurs
*/
frame_buff::uptr get_recv_buff(int32_t timeout_ms);
/*!
* FIXME: Remove or alter when get threaded_io_service
*
* Receives packets from the management stream.
*/
frame_buff::uptr get_mgmt_buff(int32_t timeout_ms);
/*!
* Release a frame buffer, allowing the recv link driver to reuse it.
*
* \param buffer frame buffer to release for reuse by the link
*/
void release_recv_buff(frame_buff::uptr buff);
/*!
* Release a frame buffer, allowing the recv link driver to reuse it.
*
* \param buffer frame buffer to release for reuse by the link
*/
void release_mgmt_buff(frame_buff::uptr buff);
/*!
* Get this xport's EPID
*
* \return the source EPID for this transport
*/
sep_id_t get_epid() const;
private:
chdr_ctrl_xport(const chdr_ctrl_xport&) = delete;
void _release_cb(
uhd::transport::frame_buff::uptr buff, uhd::transport::recv_link_if* recv_link);
bool _ctrl_recv_cb(uhd::transport::frame_buff::uptr& buff);
bool _mgmt_recv_cb(uhd::transport::frame_buff::uptr& buff);
sep_id_t _my_epid;
// Packet for received data
chdr::chdr_packet_writer::uptr _recv_packet;
send_io_if::sptr _send_if;
recv_io_if::sptr _ctrl_recv_if;
recv_io_if::sptr _mgmt_recv_if;
// Disconnect callback
disconnect_callback_t _disconnect;
// FIXME: Remove this when have threaded_io_service
std::mutex _mutex;
};
}} // namespace uhd::rfnoc
|
