16 #include <unordered_map> 17 #include <unordered_set> 18 #include <boost/graph/adjacency_list.hpp> 26 namespace uhd {
namespace rfnoc {
40 std::function<void(const res_source_info&, action_info::sptr)>;
42 std::unordered_map<res_source_info, std::vector<res_source_info>>;
63 static const size_t ANY_PORT = size_t(~0);
79 virtual std::string get_unique_id()
const;
87 virtual size_t get_num_input_ports()
const = 0;
95 virtual size_t get_num_output_ports()
const = 0;
109 std::vector<std::string> get_property_ids()
const;
126 template <
typename prop_data_t>
128 const std::string&
id,
const prop_data_t& val,
const size_t instance = 0);
181 template <
typename prop_data_t>
182 const prop_data_t& get_property(
183 const std::string&
id,
const size_t instance = 0) ;
200 virtual void set_command_time(
uhd::time_spec_t time,
const size_t instance);
213 virtual void clear_command_time(
const size_t instance);
239 void register_property(
274 void add_property_resolver(
298 void set_prop_forwarding_policy(
333 template <
typename prop_data_t>
335 const std::string&
id,
const prop_data_t& val,
const res_source_info& src_info);
348 template <
typename prop_data_t>
349 const prop_data_t& get_property(
368 void register_action_handler(
const std::string&
id,
action_handler_t&& handler);
388 void set_action_forwarding_policy(
451 virtual bool check_topology(
const std::vector<size_t>& connected_inputs,
452 const std::vector<size_t>& connected_outputs);
459 virtual void shutdown();
468 friend class node_accessor_t;
489 template <
typename PredicateType>
490 prop_ptrs_t filter_props(PredicateType&& predicate)
493 for (
const auto& type_prop_pair : _props) {
494 for (
const auto& prop : type_prop_pair.second) {
495 if (predicate(prop)) {
496 filtered_props.insert(prop);
501 return filtered_props;
511 property_base_t* inject_edge_property(
512 property_base_t* blueprint, res_source_info new_src_info);
552 void resolve_props();
568 void set_resolve_all_callback(resolve_callback_t&& resolver)
570 _resolve_all_cb = resolver;
575 void clear_resolve_all_callback()
577 _resolve_all_cb = _default_resolve_all_cb;
614 void forward_edge_property(
615 property_base_t* incoming_prop,
const size_t incoming_port);
623 void set_post_action_callback(action_handler_t&& post_handler)
625 _post_action_cb = std::move(post_handler);
642 bool _has_port(
const res_source_info& port_info)
const;
648 mutable std::mutex _prop_mutex;
652 std::vector<property_base_t*>,
657 std::unordered_map<property_base_t*, resolve_callback_t> _clean_cb_registry;
659 using property_resolver_t = std::tuple<prop_ptrs_t, prop_ptrs_t, resolver_fn_t>;
661 std::vector<property_resolver_t> _prop_resolvers;
665 resolve_callback_t _resolve_all_cb;
669 const resolve_callback_t _default_resolve_all_cb = [
this]() {
680 std::unordered_set<std::unique_ptr<property_base_t>> _dynamic_props;
685 std::unordered_map<std::string, forwarding_policy_t> _prop_fwd_policies{
686 {
"", forwarding_policy_t::ONE_TO_ONE}};
689 forwarding_map_t _prop_fwd_map;
694 mutable std::mutex _action_mutex;
697 std::unordered_map<std::string, action_handler_t> _action_handlers;
700 std::unordered_map<std::string, forwarding_policy_t> _action_fwd_policies{
701 {
"", forwarding_policy_t::ONE_TO_ONE}};
706 action_handler_t _post_action_cb = [](
const res_source_info&,
710 forwarding_map_t _action_fwd_map;
715 std::vector<uhd::time_spec_t> _cmd_timespecs;
std::function< void(const res_source_info &, action_info::sptr)> action_handler_t
Definition: node.hpp:40
static dirtifier_t ALWAYS_DIRTY
A dirtifyer object, useful for properties that always need updating.
Definition: node.hpp:465
Definition: time_spec.hpp:28
Definition: dirtifier.hpp:18
Definition: build_info.hpp:12
access_t
Definition: property.hpp:28
std::function< void(void)> resolve_callback_t
Definition: node.hpp:38
std::unordered_map< res_source_info, std::vector< res_source_info > > forwarding_map_t
Definition: node.hpp:42
std::shared_ptr< action_info > sptr
Definition: actions.hpp:32
forwarding_policy_t
Types of property/action forwarding for those not defined by the block itself.
Definition: node.hpp:45
source_t
Definition: res_source_info.hpp:21
Definition: res_source_info.hpp:17
std::unique_ptr< scope_exit > uptr
Definition: scope_exit.hpp:25
#define UHD_API
Definition: config.h:70
Definition: property.hpp:25
std::unordered_set< property_base_t * > prop_ptrs_t
Definition: node.hpp:219
std::function< void(void)> resolver_fn_t
Definition: node.hpp:37
Definition: device_addr.hpp:37
virtual ~node_t()
Definition: node.hpp:70