diff options
Diffstat (limited to 'gr-zeromq/lib/pub_msg_sink_impl.h')
| -rw-r--r-- | gr-zeromq/lib/pub_msg_sink_impl.h | 33 |
1 files changed, 17 insertions, 16 deletions
diff --git a/gr-zeromq/lib/pub_msg_sink_impl.h b/gr-zeromq/lib/pub_msg_sink_impl.h index 0cedfed482..cfd81ca399 100644 --- a/gr-zeromq/lib/pub_msg_sink_impl.h +++ b/gr-zeromq/lib/pub_msg_sink_impl.h @@ -27,29 +27,30 @@ #include <zmq.hpp> namespace gr { - namespace zeromq { +namespace zeromq { - class pub_msg_sink_impl : public pub_msg_sink - { - private: - float d_timeout; - zmq::context_t *d_context; - zmq::socket_t *d_socket; +class pub_msg_sink_impl : public pub_msg_sink +{ +private: + float d_timeout; + zmq::context_t* d_context; + zmq::socket_t* d_socket; - public: - pub_msg_sink_impl(char *address, int timeout); - ~pub_msg_sink_impl(); +public: + pub_msg_sink_impl(char* address, int timeout); + ~pub_msg_sink_impl(); - void handler(pmt::pmt_t msg); - std::string last_endpoint() override { + void handler(pmt::pmt_t msg); + std::string last_endpoint() override + { char addr[256]; size_t addr_len = sizeof(addr); d_socket->getsockopt(ZMQ_LAST_ENDPOINT, addr, &addr_len); - return std::string(addr, addr_len-1); - } - }; + return std::string(addr, addr_len - 1); + } +}; - } // namespace zeromq +} // namespace zeromq } // namespace gr #endif /* INCLUDED_ZEROMQ_PUB_MSG_SINK_IMPL_H */ |