aboutsummaryrefslogtreecommitdiffstats
path: root/host/lib/transport/muxed_zero_copy_if.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'host/lib/transport/muxed_zero_copy_if.cpp')
-rw-r--r--host/lib/transport/muxed_zero_copy_if.cpp26
1 files changed, 13 insertions, 13 deletions
diff --git a/host/lib/transport/muxed_zero_copy_if.cpp b/host/lib/transport/muxed_zero_copy_if.cpp
index 2602d8596..f7cc88c9c 100644
--- a/host/lib/transport/muxed_zero_copy_if.cpp
+++ b/host/lib/transport/muxed_zero_copy_if.cpp
@@ -39,7 +39,7 @@ public:
boost::thread(std::bind(&muxed_zero_copy_if_impl::_update_queues, this));
}
- virtual ~muxed_zero_copy_if_impl()
+ ~muxed_zero_copy_if_impl() override
{
UHD_SAFE_CALL(
// Interrupt buffer updater loop
@@ -58,7 +58,7 @@ public:
_streams.clear(););
}
- virtual zero_copy_if::sptr make_stream(const uint32_t stream_num)
+ zero_copy_if::sptr make_stream(const uint32_t stream_num) override
{
boost::lock_guard<boost::mutex> lock(_mutex);
if (_streams.size() >= _max_num_streams) {
@@ -75,12 +75,12 @@ public:
return stream;
}
- virtual size_t get_num_dropped_frames() const
+ size_t get_num_dropped_frames() const override
{
return _num_dropped_frames;
}
- void remove_stream(const uint32_t stream_num)
+ void remove_stream(const uint32_t stream_num) override
{
boost::lock_guard<boost::mutex> lock(_mutex);
_streams.erase(stream_num);
@@ -96,12 +96,12 @@ private:
public:
stream_mrb(size_t size) : _buff(new char[size]) {}
- ~stream_mrb()
+ ~stream_mrb() override
{
delete[] _buff;
}
- void release() {}
+ void release() override {}
UHD_INLINE sptr get_new(char* buff, size_t len)
{
@@ -138,7 +138,7 @@ private:
}
}
- ~stream_impl(void)
+ ~stream_impl(void) override
{
// First remove the stream from muxed transport
// so no more frames are pushed in
@@ -150,17 +150,17 @@ private:
}
}
- size_t get_num_recv_frames(void) const
+ size_t get_num_recv_frames(void) const override
{
return _num_recv_frames;
}
- size_t get_recv_frame_size(void) const
+ size_t get_recv_frame_size(void) const override
{
return _recv_frame_size;
}
- managed_recv_buffer::sptr get_recv_buff(double timeout)
+ managed_recv_buffer::sptr get_recv_buff(double timeout) override
{
managed_recv_buffer::sptr buff;
if (_buff_queue.pop_with_timed_wait(buff, timeout)) {
@@ -177,17 +177,17 @@ private:
_buffer_index %= _buffers.size();
}
- size_t get_num_send_frames(void) const
+ size_t get_num_send_frames(void) const override
{
return _num_send_frames;
}
- size_t get_send_frame_size(void) const
+ size_t get_send_frame_size(void) const override
{
return _send_frame_size;
}
- managed_send_buffer::sptr get_send_buff(double timeout)
+ managed_send_buffer::sptr get_send_buff(double timeout) override
{
return _muxed_xport->base_xport()->get_send_buff(timeout);
}