30 #ifndef __ZMQ_ROUTER_HPP_INCLUDED__ 31 #define __ZMQ_ROUTER_HPP_INCLUDED__ 59 int xsetsockopt (
int option_,
const void *optval_,
size_t optvallen_);
bool terminate_current_in
const router_t & operator=(const router_t &)
router_t(zmq::ctx_t *parent_, uint32_t tid_, int sid)
void xpipe_terminated(zmq::pipe_t *pipe_)
int xsend(zmq::msg_t *msg_)
int xrecv(zmq::msg_t *msg_)
void xattach_pipe(zmq::pipe_t *pipe_, bool subscribe_to_all_)
std::basic_string< unsigned char > blob_t
std::set< pipe_t * > anonymous_pipes
void xwrite_activated(zmq::pipe_t *pipe_)
std::map< blob_t, outpipe_t > outpipes_t
zmq::pipe_t * current_out
void xread_activated(zmq::pipe_t *pipe_)
int xsetsockopt(int option_, const void *optval_, size_t optvallen_)
blob_t get_credential() const
bool identify_peer(pipe_t *pipe_)