23 #ifndef INCLUDED_GR_BASIC_BLOCK_H
24 #define INCLUDED_GR_BASIC_BLOCK_H
32 #include <boost/enable_shared_from_this.hpp>
33 #include <boost/function.hpp>
34 #include <boost/foreach.hpp>
35 #include <boost/thread/condition_variable.hpp>
59 public boost::enable_shared_from_this<basic_block>
61 typedef boost::function<void(pmt::pmt_t)> msg_handler_t;
65 typedef std::map<pmt::pmt_t , msg_handler_t, pmt::comparator> d_msg_handlers_t;
66 d_msg_handlers_t d_msg_handlers;
68 typedef std::deque<pmt::pmt_t> msg_queue_t;
69 typedef std::map<pmt::pmt_t, msg_queue_t, pmt::comparator> msg_queue_map_t;
70 typedef std::map<pmt::pmt_t, msg_queue_t, pmt::comparator>::iterator msg_queue_map_itr;
71 std::map<pmt::pmt_t, boost::shared_ptr<boost::condition_variable>,
pmt::comparator> msg_queue_ready;
77 friend class flat_flowgraph;
78 friend class tpb_thread_body;
104 d_input_signature = iosig;
109 d_output_signature = iosig;
122 return (d_msg_handlers.find(which_port) != d_msg_handlers.end());
134 if(has_msg_handler(which_port)) {
135 d_msg_handlers[which_port](msg);
147 std::string
name()
const {
return d_name; }
153 std::string
alias(){
return alias_set()?d_symbol_alias:symbol_name(); }
155 void set_block_alias(std::string name);
158 void message_port_register_in(
pmt::pmt_t port_id);
159 void message_port_register_out(
pmt::pmt_t port_id);
192 throw std::runtime_error(
"port does not exist!");
197 BOOST_FOREACH(msg_queue_map_t::value_type &i,
msg_queue) {
205 return (empty_p(which_port) || !has_msg_handler(which_port));
209 BOOST_FOREACH(msg_queue_map_t::value_type &i,
msg_queue) {
210 rv &= empty_handled_p(i.first);
218 throw std::runtime_error(
"port does not exist!");
267 d_rpc_vars.push_back(s);
342 throw std::runtime_error(
"attempt to set_msg_handler() on bad input message port!");
344 d_msg_handlers[which_port] = msg_handler_t(msg_handler);
347 virtual void set_processor_affinity(
const std::vector<int> &mask)
348 {
throw std::runtime_error(
"set_processor_affinity not overloaded in child class."); }
350 virtual void unset_processor_affinity()
351 {
throw std::runtime_error(
"unset_processor_affinity not overloaded in child class."); }
353 virtual std::vector<int> processor_affinity()
354 {
throw std::runtime_error(
"processor_affinity not overloaded in child class."); }
359 return lhs->unique_id() < rhs->unique_id();
369 os << basic_block->name() <<
"(" << basic_block->unique_id() <<
")";