diff options
Diffstat (limited to 'gr-zeromq/lib/push_msg_sink_impl.h')
-rw-r--r-- | gr-zeromq/lib/push_msg_sink_impl.h | 33 |
1 files changed, 17 insertions, 16 deletions
diff --git a/gr-zeromq/lib/push_msg_sink_impl.h b/gr-zeromq/lib/push_msg_sink_impl.h index 0d0503cd55..4d3017f782 100644 --- a/gr-zeromq/lib/push_msg_sink_impl.h +++ b/gr-zeromq/lib/push_msg_sink_impl.h @@ -27,29 +27,30 @@ #include <zmq.hpp> namespace gr { - namespace zeromq { +namespace zeromq { - class push_msg_sink_impl : public push_msg_sink - { - private: - float d_timeout; - zmq::context_t *d_context; - zmq::socket_t *d_socket; +class push_msg_sink_impl : public push_msg_sink +{ +private: + float d_timeout; + zmq::context_t* d_context; + zmq::socket_t* d_socket; - public: - push_msg_sink_impl(char *address, int timeout); - ~push_msg_sink_impl(); +public: + push_msg_sink_impl(char* address, int timeout); + ~push_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_ZMQ_PUSH_MSG_SINK_IMPL_H */ |