1 files changed, 75 insertions, 0 deletions
diff --git a/host/lib/rfnoc/tick_node_ctrl.cpp b/host/lib/rfnoc/tick_node_ctrl.cpp
new file mode 100644
index 000000000..fa5c7b6a1
--- /dev/null
+++ b/host/lib/rfnoc/tick_node_ctrl.cpp
@@ -0,0 +1,75 @@
+//
+// Copyright 2014-2015 Ettus Research LLC
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU General Public License for more details.
+//
+// You should have received a copy of the GNU General Public License
+// along with this program.  If not, see <http://www.gnu.org/licenses/>.
+//
+
+#include <uhd/rfnoc/tick_node_ctrl.hpp>
+
+using namespace uhd::rfnoc;
+
+const double tick_node_ctrl::RATE_UNDEFINED = 0;
+
+double tick_node_ctrl::get_tick_rate(
+    const std::set< node_ctrl_base::sptr > &_explored_nodes
+) {
+    // First, see if we've implemented _get_tick_rate()
+    {
+        double my_tick_rate = _get_tick_rate();
+        if (my_tick_rate != RATE_UNDEFINED) {
+            return my_tick_rate;
+        }
+    }
+
+    // If not, we ask all our neighbours for the tick rate.
+    // This will fail if we get different values.
+    std::set< node_ctrl_base::sptr > explored_nodes(_explored_nodes);
+    explored_nodes.insert(shared_from_this());
+    // Here, we need all up- and downstream nodes
+    std::vector< sptr > neighbouring_tick_nodes = find_downstream_node<tick_node_ctrl>();
+    {
+        std::vector< sptr > upstream_neighbouring_tick_nodes = find_upstream_node<tick_node_ctrl>();
+        neighbouring_tick_nodes.insert(
+                neighbouring_tick_nodes.end(),
+                upstream_neighbouring_tick_nodes.begin(),
+                upstream_neighbouring_tick_nodes.end()
+        );
+    } // neighbouring_tick_nodes is now initialized
+    double ret_val = RATE_UNDEFINED;
+    BOOST_FOREACH(const sptr &node, neighbouring_tick_nodes) {
+        if (_explored_nodes.count(node)) {
+            continue;
+        }
+        double tick_rate = node->get_tick_rate(explored_nodes);
+        if (tick_rate == RATE_UNDEFINED) {
+            continue;
+        }
+        if (ret_val == RATE_UNDEFINED) {
+            ret_val = tick_rate;
+            // TODO: Remember name of this node so we can make the throw message more descriptive.
+            continue;
+        }
+        if (tick_rate != ret_val) {
+            throw uhd::runtime_error(
+                str(
+                    // TODO add node names
+                    boost::format("Conflicting tick rates: One neighbouring block specifies %d MHz, another %d MHz.")
+                    % tick_rate % ret_val
+                )
+            );
+        }
+    }
+    return ret_val;
+}
+