From bffef674fbbcd892967017e81515bb76e0b850b5 Mon Sep 17 00:00:00 2001 From: Ciro Nishiguchi Date: Thu, 8 Aug 2019 10:25:20 -0500 Subject: rfnoc: tx_streamer: add support for async messages Add an async message queue that aggregates errors from multiple sources. Errors can come from the strs packets originating from the stream endpoint or from the radio block through control packets to the host. --- host/lib/include/uhdlib/transport/tx_streamer_impl.hpp | 11 ++++------- host/lib/include/uhdlib/transport/tx_streamer_zero_copy.hpp | 6 ++++++ 2 files changed, 10 insertions(+), 7 deletions(-) (limited to 'host/lib/include/uhdlib/transport') diff --git a/host/lib/include/uhdlib/transport/tx_streamer_impl.hpp b/host/lib/include/uhdlib/transport/tx_streamer_impl.hpp index 819ed5558..35a724fa9 100644 --- a/host/lib/include/uhdlib/transport/tx_streamer_impl.hpp +++ b/host/lib/include/uhdlib/transport/tx_streamer_impl.hpp @@ -99,7 +99,6 @@ public: return _spp; } - /*! Get width of each over-the-wire item component. For complex items, * returns the width of one component only (real or imaginary). */ @@ -178,15 +177,13 @@ public: } } - //! Implementation of rx_streamer API method - bool recv_async_msg( - uhd::async_metadata_t& /*async_metadata*/, double /*timeout = 0.1*/) +protected: + //! Returns the tick rate for conversion of timestamp + double get_tick_rate() const { - // TODO: implement me - return false; + return _zero_copy_streamer.get_tick_rate(); } -protected: //! Returns the size in bytes of a sample in a packet size_t get_mtu() const { diff --git a/host/lib/include/uhdlib/transport/tx_streamer_zero_copy.hpp b/host/lib/include/uhdlib/transport/tx_streamer_zero_copy.hpp index 1b6f55238..5ac7a1e8c 100644 --- a/host/lib/include/uhdlib/transport/tx_streamer_zero_copy.hpp +++ b/host/lib/include/uhdlib/transport/tx_streamer_zero_copy.hpp @@ -51,6 +51,12 @@ public: return _xports.size(); } + //! Returns the tick rate for conversion of timestamp + double get_tick_rate() const + { + return _tick_rate; + } + //! Configures tick rate for conversion of timestamp void set_tick_rate(const double rate) { -- cgit v1.2.3