30 #ifndef __ZMQ_RADIO_HPP_INCLUDED__ 31 #define __ZMQ_RADIO_HPP_INCLUDED__ 95 int push_msg (
msg_t *msg_);
96 int pull_msg (
msg_t *msg_);
void xread_activated(zmq::pipe_t *pipe_)
void xwrite_activated(zmq::pipe_t *pipe_)
int xrecv(zmq::msg_t *msg_)
int xsend(zmq::msg_t *msg_)
radio_t(zmq::ctx_t *parent_, uint32_t tid_, int sid_)
void xattach_pipe(zmq::pipe_t *pipe_, bool subscribe_to_all_=false)
std::multimap< std::string, pipe_t * > subscriptions_t
void xpipe_terminated(zmq::pipe_t *pipe_)
const radio_t & operator=(const radio_t &)
std::vector< pipe_t * > udp_pipes_t
subscriptions_t subscriptions