gr::zeromq::pub_sink Class Reference

Sink the contents of a stream to a ZMQ PUB socket. More...

#include </build/gnuradio-O4UjFN/gnuradio-3.7.5/gr-zeromq/include/gnuradio/zeromq/pub_sink.h>

Public Types
typedef boost::shared_ptr < pub_sink >	sptr

Static Public Member Functions
static sptr	make (size_t itemsize, size_t vlen, char *address, int timeout=100)
	Return a shared_ptr to a new instance of zeromq::pub_sink.

Additional Inherited Members
Public Member Functions inherited from gr::sync_block
virtual int	work (int noutput_items, gr_vector_const_void_star &input_items, gr_vector_void_star &output_items)=0
	just like gr::block::general_work, only this arranges to call consume_each for you
void	forecast (int noutput_items, gr_vector_int &ninput_items_required)
	Estimate input requirements given output request.
int	general_work (int noutput_items, gr_vector_int &ninput_items, gr_vector_const_void_star &input_items, gr_vector_void_star &output_items)
	compute output items from input items
int	fixed_rate_ninput_to_noutput (int ninput)
	Given ninput samples, return number of output samples that will be produced. N.B. this is only defined if fixed_rate returns true. Generally speaking, you don't need to override this.
int	fixed_rate_noutput_to_ninput (int noutput)
	Given noutput samples, return number of input samples required to produce noutput. N.B. this is only defined if fixed_rate returns true. Generally speaking, you don't need to override this.
Protected Types inherited from gr::basic_block
enum	vcolor { WHITE, GREY, BLACK }
Protected Member Functions inherited from gr::sync_block
	sync_block (void)
	sync_block (const std::string &name, gr::io_signature::sptr input_signature, gr::io_signature::sptr output_signature)
Protected Attributes inherited from gr::block
std::vector< long >	d_max_output_buffer
std::vector< long >	d_min_output_buffer
gr::thread::mutex	d_setlock
gr::logger_ptr	d_logger
gr::logger_ptr	d_debug_logger

Detailed Description

Sink the contents of a stream to a ZMQ PUB socket.

This block acts a a streaming sink for a GNU Radio flowgraph and writes its contents to a ZMQ PUB socket. A PUB socket may have subscribers and will pass all incoming stream data to each subscriber. Subscribers can be either another gr-zeromq source block or a non-GNU Radio ZMQ socket.

Member Typedef Documentation

typedef boost::shared_ptr<pub_sink> gr::zeromq::pub_sink::sptr

Member Function Documentation

static sptr gr::zeromq::pub_sink::make ( size_t  itemsize, size_t  vlen, char *  address, int  timeout = 100  )

static

Return a shared_ptr to a new instance of zeromq::pub_sink.

Parameters

itemsize	Size of a stream item in bytes
vlen	Vector length of the input items. Note that one vector is one item.
address	ZMQ socket address specifier
timeout	Receive timeout in seconds, default is 100ms, 1us increments

---

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

• pub_sink.h