23 #ifndef INCLUDED_GR_STREAM_PDU_BASE_H
24 #define INCLUDED_GR_STREAM_PDU_BASE_H
48 int work (
int noutput_items,
49 gr_vector_const_void_star &input_items,
50 gr_vector_void_star &output_items);
boost::shared_ptr< boost::thread > d_thread
Definition: gr_stream_pdu_base.h:38
Definition: gr_sync_block.h:27
int d_fd
Definition: gr_stream_pdu_base.h:43
static pmt::pmt_t send(msg_accepter_sptr accepter, const pmt::pmt_t &which_port, const pmt::pmt_t &msg)
send message to msg_accepter
Definition: msg_passing.h:49
#define GR_CORE_API
Definition: gr_core_api.h:30
bool d_finished
Definition: gr_stream_pdu_base.h:39
bool d_started
Definition: gr_stream_pdu_base.h:40
std::vector< uint8_t > d_rxbuf
Definition: gr_stream_pdu_base.h:41
boost::intrusive_ptr< pmt_base > pmt_t
typedef for shared pointer (transparent reference counting). See http://www.boost.org/libs/smart_ptr/smart_ptr.htm
Definition: pmt.h:54
Gather received items into messages and insert into msgq.
Definition: gr_stream_pdu_base.h:35
virtual int work(int noutput_items, gr_vector_const_void_star &input_items, gr_vector_void_star &output_items)
just like gr_block::general_work, only this arranges to call consume_each for you ...