55 int rc = probe_msg_.
init ();
58 rc = pipe_->
write (&probe_msg_);
62 rc = probe_msg_.
close ();
73 bool is_int = (optvallen_ ==
sizeof (
int));
75 if (is_int) memcpy(&value, optval_,
sizeof (
int));
79 if (is_int && value >= 0) {
void xread_activated(zmq::pipe_t *pipe_)
blob_t get_credential() const
int sendpipe(zmq::msg_t *msg_, zmq::pipe_t **pipe_)
int xsetsockopt(int option_, const void *optval_, size_t optvallen_)
void pipe_terminated(pipe_t *pipe_)
int recvpipe(msg_t *msg_, pipe_t **pipe_)
int recvpipe(zmq::msg_t *msg_, zmq::pipe_t **pipe_)
void xattach_pipe(zmq::pipe_t *pipe_, bool subscribe_to_all_)
void pipe_terminated(pipe_t *pipe_)
#define LIBZMQ_UNUSED(object)
int sendpipe(msg_t *msg_, pipe_t **pipe_)
void attach(pipe_t *pipe_)
blob_t get_credential() const
std::basic_string< unsigned char > blob_t
void xpipe_terminated(zmq::pipe_t *pipe_)
void attach(pipe_t *pipe_)
int xrecv(zmq::msg_t *msg_)
void activated(pipe_t *pipe_)
void xwrite_activated(zmq::pipe_t *pipe_)
dealer_t(zmq::ctx_t *parent_, uint32_t tid_, int sid)
int xsend(zmq::msg_t *msg_)
void activated(pipe_t *pipe_)