41 static void free_id (
void *data,
void *hint)
50 receiving_reply (false),
51 message_begins (true),
53 request_id_frames_enabled (false),
86 uint32_t *request_id_copy = (uint32_t *) malloc (
sizeof (uint32_t));
90 int rc =
id.
init_data (request_id_copy,
sizeof (uint32_t),
101 int rc = bottom.
init ();
222 bool is_int = (optvallen_ ==
sizeof (
int));
225 memcpy (&value, optval_,
sizeof (
int));
229 if (is_int && value >= 0) {
236 if (is_int && value >= 0) {
288 if (msg_->
size () ==
sizeof (uint32_t)) {
292 else if (msg_->
size () == 0) {
307 if (msg_->
flags () == 0) {
int xsend(zmq::msg_t *msg_)
req_t(zmq::ctx_t *parent_, uint32_t tid_, int sid_)
int sendpipe(zmq::msg_t *msg_, zmq::pipe_t **pipe_)
virtual int push_msg(msg_t *msg_)
int xsetsockopt(int option_, const void *optval_, size_t optvallen_)
int xsetsockopt(int option_, const void *optval_, size_t optvallen_)
int recvpipe(zmq::msg_t *msg_, zmq::pipe_t **pipe_)
req_session_t(zmq::io_thread_t *io_thread_, bool connect_, zmq::socket_base_t *socket_, const options_t &options_, address_t *addr_)
void xpipe_terminated(zmq::pipe_t *pipe_)
int push_msg(msg_t *msg_)
enum zmq::req_session_t::@51 state
#define LIBZMQ_UNUSED(object)
static void free_id(void *data, void *hint)
uint32_t generate_random()
void xpipe_terminated(zmq::pipe_t *pipe_)
int xrecv(zmq::msg_t *msg_)
void set_flags(unsigned char flags_)
bool request_id_frames_enabled
int xrecv(zmq::msg_t *msg_)
unsigned char data[max_vsm_size]
int recv_reply_pipe(zmq::msg_t *msg_)
int xsend(zmq::msg_t *msg_)
#define ZMQ_REQ_CORRELATE
int init_data(void *data_, size_t size_, msg_free_fn *ffn_, void *hint_)