2 files changed, 5 insertions, 4 deletions
diff --git a/host/lib/include/uhdlib/rfnoc/radio_control_impl.hpp b/host/lib/include/uhdlib/rfnoc/radio_control_impl.hpp
index 5440c1e37..5327105c8 100644
--- a/host/lib/include/uhdlib/rfnoc/radio_control_impl.hpp
+++ b/host/lib/include/uhdlib/rfnoc/radio_control_impl.hpp
@@ -324,7 +324,6 @@ 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 1d1d0805d..d39d88f43 100644
--- a/host/lib/include/uhdlib/rfnoc/rfnoc_rx_streamer.hpp
+++ b/host/lib/include/uhdlib/rfnoc/rfnoc_rx_streamer.hpp
@@ -10,8 +10,8 @@
 #include <uhd/rfnoc/node.hpp>
 #include <uhdlib/rfnoc/chdr_rx_data_xport.hpp>
 #include <uhdlib/transport/rx_streamer_impl.hpp>
-#include <string>
 #include <atomic>
+#include <string>
 
 namespace uhd { namespace rfnoc {
 
@@ -75,16 +75,17 @@ public:
      */
     bool check_topology(const std::vector<size_t>& connected_inputs,
         const std::vector<size_t>& connected_outputs);
+
 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);
 
+    void _handle_overrun();
+
     // Properties
     std::vector<property_t<double>> _scaling_in;
     std::vector<property_t<double>> _samp_rate_in;
@@ -98,6 +99,7 @@ private:
     const uhd::stream_args_t _stream_args;
 
     std::atomic<bool> _overrun_handling_mode{false};
+    size_t _overrun_channel = 0;
 };
 
 }} // namespace uhd::rfnoc