2 files changed, 11 insertions, 0 deletions
diff --git a/host/lib/include/uhdlib/rfnoc/radio_control_impl.hpp b/host/lib/include/uhdlib/rfnoc/radio_control_impl.hpp
index 0d10fd13b..6b50cc31c 100644
--- a/host/lib/include/uhdlib/rfnoc/radio_control_impl.hpp
+++ b/host/lib/include/uhdlib/rfnoc/radio_control_impl.hpp
@@ -303,6 +303,7 @@ private:
     std::unordered_map<size_t, double> _rx_bandwidth;
 
     std::vector<uhd::stream_cmd_t> _last_stream_cmd;
+    std::vector<bool> _restart_cont;
 };
 
 }} // namespace uhd::rfnoc
diff --git a/host/lib/include/uhdlib/rfnoc/rfnoc_rx_streamer.hpp b/host/lib/include/uhdlib/rfnoc/rfnoc_rx_streamer.hpp
index 6ced60d19..1d1d0805d 100644
--- a/host/lib/include/uhdlib/rfnoc/rfnoc_rx_streamer.hpp
+++ b/host/lib/include/uhdlib/rfnoc/rfnoc_rx_streamer.hpp
@@ -11,6 +11,7 @@
 #include <uhdlib/rfnoc/chdr_rx_data_xport.hpp>
 #include <uhdlib/transport/rx_streamer_impl.hpp>
 #include <string>
+#include <atomic>
 
 namespace uhd { namespace rfnoc {
 
@@ -77,6 +78,13 @@ public:
 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_restart_request(
+        const res_source_info& src, action_info::sptr rx_event_action);
+    void _handle_stream_cmd_action(
+        const res_source_info& src, stream_cmd_action_info::sptr stream_cmd_action);
+
     // Properties
     std::vector<property_t<double>> _scaling_in;
     std::vector<property_t<double>> _samp_rate_in;
@@ -88,6 +96,8 @@ private:
 
     // Stream args provided at construction
     const uhd::stream_args_t _stream_args;
+
+    std::atomic<bool> _overrun_handling_mode{false};
 };
 
 }} // namespace uhd::rfnoc