97 unsigned char *data = (
unsigned char *) msg_->
data ();
99 if (size > 0 && *data == 1) {
109 if (size > 0 && *data == 0) {
118 int rc = msg_->
close ();
234 unsigned char *data = (
unsigned char*) msg.
data ();
240 memcpy (data + 1, data_, size_);
244 bool sent = pipe->
write (&msg);
void xread_activated(zmq::pipe_t *pipe_)
blob_t get_credential() const
int send_to_all(zmq::msg_t *msg_)
void xwrite_activated(zmq::pipe_t *pipe_)
void activated(zmq::pipe_t *pipe_)
void pipe_terminated(pipe_t *pipe_)
static void send_subscription(unsigned char *data_, size_t size_, void *arg_)
int init_size(size_t size_)
void xattach_pipe(zmq::pipe_t *pipe_, bool subscribe_to_all_)
void xpipe_terminated(zmq::pipe_t *pipe_)
bool match(zmq::msg_t *msg_)
#define LIBZMQ_UNUSED(object)
void attach(zmq::pipe_t *pipe_)
blob_t get_credential() const
void attach(pipe_t *pipe_)
std::basic_string< unsigned char > blob_t
bool add(unsigned char *prefix_, size_t size_)
int xsend(zmq::msg_t *msg_)
xsub_t(zmq::ctx_t *parent_, uint32_t tid_, int sid_)
void xhiccuped(pipe_t *pipe_)
void activated(pipe_t *pipe_)
int xrecv(zmq::msg_t *msg_)
unsigned char data[max_vsm_size]
void pipe_terminated(zmq::pipe_t *pipe_)
bool check(unsigned char *data_, size_t size_)
void apply(void(*func_)(unsigned char *data_, size_t size_, void *arg_), void *arg_)
bool rm(unsigned char *prefix_, size_t size_)