GNU Radio 3.6.5 C++ API
|
Gather received items into messages and insert into msgq. More...
#include <gr_stream_pdu_base.h>
Public Member Functions | |
void | run () |
gr_stream_pdu_base (int MTU=10000) | |
~gr_stream_pdu_base () | |
void | send (pmt::pmt_t msg) |
bool | wait_ready () |
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 | |
void | start_rxthread (pmt::pmt_t _rxport) |
void | stop_rxthread () |
Public Attributes | |
boost::shared_ptr< boost::thread > | d_thread |
bool | d_finished |
bool | d_started |
std::vector< uint8_t > | d_rxbuf |
int | d_fd |
Gather received items into messages and insert into msgq.
gr_stream_pdu_base::gr_stream_pdu_base | ( | int | MTU = 10000 | ) |
gr_stream_pdu_base::~gr_stream_pdu_base | ( | ) |
void gr_stream_pdu_base::run | ( | ) |
void gr_stream_pdu_base::send | ( | pmt::pmt_t | msg | ) |
void gr_stream_pdu_base::start_rxthread | ( | pmt::pmt_t | _rxport | ) |
void gr_stream_pdu_base::stop_rxthread | ( | ) |
bool gr_stream_pdu_base::wait_ready | ( | ) |
int gr_stream_pdu_base::work | ( | int | noutput_items, |
gr_vector_const_void_star & | input_items, | ||
gr_vector_void_star & | output_items | ||
) | [virtual] |
just like gr_block::general_work, only this arranges to call consume_each for you
The user must override work to define the signal processing code
Implements gr_sync_block.
boost::shared_ptr<boost::thread> gr_stream_pdu_base::d_thread |