64 bool ok =
outpipes.insert (outpipes_t::value_type (routing_id, outpipe)).second;
85 outpipes_t::iterator it;
87 if (it->second.pipe == pipe_)
92 it->second.active =
true;
104 outpipes_t::iterator it =
outpipes.find (routing_id);
107 if (!it->second.pipe->check_write ()) {
108 it->second.active =
false;
122 bool ok = it->second.pipe->write (msg_);
129 it->second.pipe->flush ();
blob_t get_credential() const
int recvpipe(msg_t *msg_, pipe_t **pipe_)
void xwrite_activated(zmq::pipe_t *pipe_)
void pipe_terminated(pipe_t *pipe_)
void set_routing_id(uint32_t routing_id_)
uint32_t get_routing_id()
void xattach_pipe(zmq::pipe_t *pipe_, bool subscribe_to_all_)
void xread_activated(zmq::pipe_t *pipe_)
#define LIBZMQ_UNUSED(object)
server_t(zmq::ctx_t *parent_, uint32_t tid_, int sid)
uint32_t generate_random()
void attach(pipe_t *pipe_)
std::basic_string< unsigned char > blob_t
int xsend(zmq::msg_t *msg_)
int xrecv(zmq::msg_t *msg_)
void activated(pipe_t *pipe_)
void xpipe_terminated(zmq::pipe_t *pipe_)
int set_routing_id(uint32_t routing_id_)
blob_t get_credential() const
uint32_t get_routing_id()