23 #ifndef INCLUDED_GR_BASIC_BLOCK_H
24 #define INCLUDED_GR_BASIC_BLOCK_H
29 #include <boost/enable_shared_from_this.hpp>
30 #include <boost/function.hpp>
37 #include <boost/foreach.hpp>
38 #include <boost/thread/condition_variable.hpp>
54 typedef boost::function<void(pmt::pmt_t)> msg_handler_t;
66 if (d_msg_handlers.find(which_port) != d_msg_handlers.end())
67 d_msg_handlers[which_port](msg);
71 typedef std::map<pmt::pmt_t , msg_handler_t, pmt::pmt_comperator> d_msg_handlers_t;
72 d_msg_handlers_t d_msg_handlers;
74 typedef std::deque<pmt::pmt_t> msg_queue_t;
75 typedef std::map<pmt::pmt_t, msg_queue_t, pmt::pmt_comperator> msg_queue_map_t;
76 typedef std::map<pmt::pmt_t, msg_queue_t, pmt::pmt_comperator>::iterator msg_queue_map_itr;
77 std::map<pmt::pmt_t, boost::shared_ptr<boost::condition_variable>,
pmt::pmt_comperator> msg_queue_ready;
107 d_input_signature = iosig;
112 d_output_signature = iosig;
128 std::string
name()
const {
return d_name; }
134 std::string
alias(){
return alias_set()?d_symbol_alias:symbol_name(); }
136 void set_block_alias(std::string name);
139 void message_port_register_in(
pmt::pmt_t port_id);
140 void message_port_register_out(
pmt::pmt_t port_id);
173 if(msg_queue.find(which_port) == msg_queue.end())
174 throw std::runtime_error(
"port does not exist!");
175 return msg_queue[which_port].empty();
179 BOOST_FOREACH(msg_queue_map_t::value_type &i, msg_queue){ rv &= msg_queue[i.first].empty(); }
196 return msg_queue[which_port].begin();
200 msg_queue[which_port].erase(it);
204 if(msg_queue.find(which_port) != msg_queue.end()){
259 if(msg_queue.find(which_port) == msg_queue.end()){
260 throw std::runtime_error(
"attempt to set_msg_handler() on bad input message port!"); }
261 d_msg_handlers[which_port] = msg_handler_t(msg_handler);
267 return lhs->unique_id() < rhs->unique_id();
277 os << basic_block->name() <<
"(" << basic_block->unique_id() <<
")";