GNU Radio 3.6.4.2 C++ API
gr_stream_pdu_base Class Reference

Gather received items into messages and insert into msgq. More...

#include <gr_stream_pdu_base.h>

Inheritance diagram for gr_stream_pdu_base:
gr_sync_block gr_block gr_socket_pdu

List of all members.

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_td_rxbuf
int d_fd

Detailed Description

Gather received items into messages and insert into msgq.


Constructor & Destructor Documentation


Member Function Documentation

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

Reimplemented from gr_sync_block.


Member Data Documentation


The documentation for this class was generated from the following file: