diff options
| author | Marcus Müller <mmueller@gnuradio.org> | 2019-08-07 21:45:12 +0200 |
|---|---|---|
| committer | Marcus Müller <marcus@hostalia.de> | 2019-08-09 23:04:28 +0200 |
| commit | f7bbf2c1d8d780294f3e016aff239ca35eb6516e (patch) | |
| tree | e09ab6112e02b2215b2d59ac24d3d6ea2edac745 /gr-zeromq/include/gnuradio/zeromq/req_source.h | |
| parent | 78431dc6941e3acc67c858277dfe4a0ed583643c (diff) | |
Tree: clang-format without the include sorting
Diffstat (limited to 'gr-zeromq/include/gnuradio/zeromq/req_source.h')
| -rw-r--r-- | gr-zeromq/include/gnuradio/zeromq/req_source.h | 62 |
1 files changed, 33 insertions, 29 deletions
diff --git a/gr-zeromq/include/gnuradio/zeromq/req_source.h b/gr-zeromq/include/gnuradio/zeromq/req_source.h index dfe3929ebf..0cec5268da 100644 --- a/gr-zeromq/include/gnuradio/zeromq/req_source.h +++ b/gr-zeromq/include/gnuradio/zeromq/req_source.h @@ -27,41 +27,45 @@ #include <gnuradio/sync_block.h> namespace gr { - namespace zeromq { +namespace zeromq { + +/*! + * \brief Receive messages on ZMQ REQ socket and source stream + * \ingroup zeromq + * + * \details + * This block will connect to a ZMQ REP socket, then produce all + * incoming messages as streaming output. + */ +class ZEROMQ_API req_source : virtual public gr::sync_block +{ +public: + typedef boost::shared_ptr<req_source> sptr; /*! - * \brief Receive messages on ZMQ REQ socket and source stream - * \ingroup zeromq + * \brief Return a shared_ptr to a new instance of zeromq::req_source. * - * \details - * This block will connect to a ZMQ REP socket, then produce all - * incoming messages as streaming output. + * \param itemsize Size of a stream item in bytes. + * \param vlen Vector length of the input items. Note that one vector is one item. + * \param address ZMQ socket address specifier. + * \param timeout Receive timeout in milliseconds, default is 100ms, 1us increments. + * \param pass_tags Whether source will look for and deserialize tags. + * \param hwm High Watermark to configure the socket to (-1 => zmq's default) */ - class ZEROMQ_API req_source : virtual public gr::sync_block - { - public: - typedef boost::shared_ptr<req_source> sptr; + static sptr make(size_t itemsize, + size_t vlen, + char* address, + int timeout = 100, + bool pass_tags = false, + int hwm = -1); - /*! - * \brief Return a shared_ptr to a new instance of zeromq::req_source. - * - * \param itemsize Size of a stream item in bytes. - * \param vlen Vector length of the input items. Note that one vector is one item. - * \param address ZMQ socket address specifier. - * \param timeout Receive timeout in milliseconds, default is 100ms, 1us increments. - * \param pass_tags Whether source will look for and deserialize tags. - * \param hwm High Watermark to configure the socket to (-1 => zmq's default) - */ - static sptr make(size_t itemsize, size_t vlen, char *address, - int timeout=100, bool pass_tags=false, int hwm=-1); - - /*! - * \brief Return a std::string of ZMQ_LAST_ENDPOINT from the underlying ZMQ socket. - */ - virtual std::string last_endpoint() = 0; - }; + /*! + * \brief Return a std::string of ZMQ_LAST_ENDPOINT from the underlying ZMQ socket. + */ + virtual std::string last_endpoint() = 0; +}; - } // namespace zeromq +} // namespace zeromq } // namespace gr #endif /* INCLUDED_ZEROMQ_SOURCE_REQREP_H */ |