rfnoc: graph: Add commit/release API

2 files changed, 31 insertions, 2 deletions

diff --git a/host/lib/rfnoc/graph.cpp b/host/lib/rfnoc/graph.cpp
index d311a00bd..f687e8984 100644
--- a/host/lib/rfnoc/graph.cpp
+++ b/host/lib/rfnoc/graph.cpp
@@ -173,12 +173,21 @@ void graph_t::connect(node_ref_t src_node, node_ref_t dst_node, graph_edge_t edg
     }
 }
 
-void graph_t::initialize()
+void graph_t::commit()
 {
-    UHD_LOG_DEBUG(LOG_ID, "Initializing graph.");
+    if (_release_count) {
+        _release_count--;
+    }
+    UHD_LOG_TRACE(LOG_ID, "graph::commit() => " << _release_count.load());
     resolve_all_properties();
 }
 
+void graph_t::release()
+{
+    UHD_LOG_TRACE(LOG_ID, "graph::release() => " << _release_count.load());
+    _release_count++;
+}
+
 
 /******************************************************************************
  * Private methods to be called by friends
@@ -188,6 +197,9 @@ void graph_t::resolve_all_properties()
     if (boost::num_vertices(_graph) == 0) {
         return;
     }
+    if (_release_count) {
+        return;
+    }
     node_accessor_t node_accessor{};
 
     // First, find the node on which we'll start.
@@ -323,6 +335,13 @@ void graph_t::resolve_all_properties()
 void graph_t::enqueue_action(
     node_ref_t src_node, res_source_info src_edge, action_info::sptr action)
 {
+    if (_release_count) {
+        UHD_LOG_WARNING(LOG_ID,
+            "Action propagation is not enabled, graph is not committed! Will not "
+            "propagate action `"
+                << action->key << "'");
+        return;
+    }
     // First, make sure that once we start action handling, no other node from
     // a different thread can throw in their own actions
     std::lock_guard<std::recursive_mutex> l(_action_mutex);
diff --git a/host/lib/rfnoc/rfnoc_graph.cpp b/host/lib/rfnoc/rfnoc_graph.cpp
index 22c9b7294..94d59da05 100644
--- a/host/lib/rfnoc/rfnoc_graph.cpp
+++ b/host/lib/rfnoc/rfnoc_graph.cpp
@@ -101,6 +101,16 @@ public:
         return _mb_controllers.at(mb_index);
     }
 
+    void commit()
+    {
+        _graph->commit();
+    }
+
+    void release()
+    {
+        _graph->release();
+    }
+
 private:
     /**************************************************************************
      * Device Setup