![]() |
libzmq master
The Intelligent Transport Layer
|
#include <msg.hpp>
Classes | |
struct | content_t |
Public Types | |
enum | { more = 1, identity = 64, shared = 128 } |
Public Member Functions | |
void | add_refs (int refs_) |
bool | check () |
int | close () |
int | copy (msg_t &src_) |
void * | data () |
unsigned char | flags () |
int | init () |
int | init_data (void *data_, size_t size_, msg_free_fn *ffn_, void *hint_) |
int | init_delimiter () |
int | init_size (size_t size_) |
bool | is_delimiter () |
bool | is_vsm () |
int | move (msg_t &src_) |
void | reset_flags (unsigned char flags_) |
bool | rm_refs (int refs_) |
void | set_flags (unsigned char flags_) |
size_t | size () |
Private Types | |
enum | { max_vsm_size = 29 } |
enum | type_t { type_min = 101, type_vsm = 101, type_lmsg = 102, type_delimiter = 103, type_max = 103 } |
Private Attributes | |
union { | |
struct { | |
unsigned char flags | |
unsigned char type | |
unsigned char unused [max_vsm_size+1] | |
} base | |
struct { | |
unsigned char flags | |
unsigned char type | |
unsigned char unused [max_vsm_size+1] | |
} delimiter | |
struct { | |
content_t * content | |
unsigned char flags | |
unsigned char type | |
unsigned char unused [max_vsm_size+1-sizeof(content_t *)] | |
} lmsg | |
struct { | |
unsigned char data [max_vsm_size] | |
unsigned char flags | |
unsigned char size | |
unsigned char type | |
} vsm | |
} | u |
enum zmq::msg_t::type_t [private] |
void zmq::msg_t::add_refs | ( | int | refs_ | ) |
Definition at line 246 of file msg.cpp.
References shared, and zmq_assert.
Referenced by zmq::dist_t::distribute().
bool zmq::msg_t::check | ( | ) |
Definition at line 39 of file msg.cpp.
References type_max, type_min, and u.
Referenced by copy(), move(), zmq::socket_base_t::recv(), and zmq::socket_base_t::send().
int zmq::msg_t::close | ( | ) |
Definition at line 105 of file msg.cpp.
References shared, and unlikely.
Referenced by zmq::session_base_t::clean_pipes(), zmq::dist_t::distribute(), zmq::lb_t::has_out(), zmq::ctx_t::log(), zmq::pipe_t::process_hiccup(), zmq::pipe_t::process_pipe_term_ack(), zmq::fq_t::recvpipe(), zmq::pipe_t::rollback(), zmq::lb_t::send(), zmq::pair_t::xhas_out(), zmq::xpub_t::xread_activated(), zmq::xrep_t::xrecv(), zmq::xpub_t::xrecv(), zmq::req_t::xrecv(), zmq::pair_t::xrecv(), zmq::xrep_t::xsend(), and zmq::sub_t::xsetsockopt().
int zmq::msg_t::copy | ( | msg_t & | src_ | ) |
void* zmq::msg_t::data | ( | ) |
unsigned char zmq::msg_t::flags | ( | ) |
int zmq::msg_t::init | ( | ) |
Definition at line 44 of file msg.cpp.
Referenced by zmq::session_base_t::clean_pipes(), zmq::decoder_t::decoder_t(), zmq::dist_t::distribute(), zmq::encoder_t::encoder_t(), zmq::lb_t::has_out(), move(), zmq::fq_t::recvpipe(), zmq::lb_t::send(), zmq::session_base_t::write(), zmq::pair_t::xhas_out(), zmq::xpub_t::xread_activated(), zmq::req_t::xrecv(), zmq::pair_t::xrecv(), zmq::xrep_t::xrep_t(), zmq::xrep_t::xsend(), zmq::req_t::xsend(), zmq::pair_t::xsend(), and zmq::xsub_t::xsub_t().
int zmq::msg_t::init_data | ( | void * | data_, |
size_t | size_, | ||
msg_free_fn * | ffn_, | ||
void * | hint_ | ||
) |
int zmq::msg_t::init_delimiter | ( | ) |
Definition at line 98 of file msg.cpp.
Referenced by zmq::pipe_t::terminate().
int zmq::msg_t::init_size | ( | size_t | size_ | ) |
Definition at line 52 of file msg.cpp.
Referenced by zmq::socket_base_t::connect(), zmq::ctx_t::log(), zmq::session_base_t::read(), zmq::xsub_t::send_subscription(), zmq::xrep_t::xrecv(), zmq::xpub_t::xrecv(), and zmq::sub_t::xsetsockopt().
bool zmq::msg_t::is_delimiter | ( | ) |
Definition at line 236 of file msg.cpp.
Referenced by zmq::pipe_t::is_delimiter(), and zmq::pipe_t::read().
bool zmq::msg_t::is_vsm | ( | ) |
Definition at line 241 of file msg.cpp.
Referenced by zmq::dist_t::distribute().
int zmq::msg_t::move | ( | msg_t & | src_ | ) |
Definition at line 138 of file msg.cpp.
References check(), init(), and unlikely.
Referenced by zmq::xsub_t::xrecv(), and zmq::xrep_t::xrecv().
void zmq::msg_t::reset_flags | ( | unsigned char | flags_ | ) |
Definition at line 231 of file msg.cpp.
Referenced by zmq::socket_base_t::send().
bool zmq::msg_t::rm_refs | ( | int | refs_ | ) |
Definition at line 266 of file msg.cpp.
References shared, and zmq_assert.
Referenced by zmq::dist_t::distribute().
void zmq::msg_t::set_flags | ( | unsigned char | flags_ | ) |
Definition at line 226 of file msg.cpp.
Referenced by zmq::socket_base_t::send(), zmq::session_base_t::write(), zmq::xrep_t::xrecv(), and zmq::req_t::xsend().
size_t zmq::msg_t::size | ( | ) |
struct { ... } zmq::msg_t::base |
Referenced by copy().
void * zmq::msg_t::data |
Definition at line 125 of file msg.hpp.
Referenced by zmq::ctx_t::log(), zmq::session_base_t::read(), zmq::xsub_t::send_subscription(), zmq::xpub_t::xread_activated(), zmq::xrep_t::xrecv(), zmq::xpub_t::xrecv(), zmq::xsub_t::xsend(), zmq::xrep_t::xsend(), zmq::xpub_t::xsend(), and zmq::sub_t::xsetsockopt().
struct { ... } zmq::msg_t::delimiter |
unsigned char zmq::msg_t::flags |
Definition at line 122 of file msg.hpp.
Referenced by zmq::socket_base_t::extract_flags(), zmq::session_base_t::read(), zmq::pipe_t::read(), zmq::fq_t::recvpipe(), zmq::pipe_t::rollback(), zmq::lb_t::send(), zmq::dist_t::send_to_matching(), zmq::req_session_t::write(), zmq::pipe_t::write(), zmq::dist_t::write(), zmq::xsub_t::xrecv(), zmq::xreq_t::xrecv(), zmq::xrep_t::xrecv(), zmq::req_t::xrecv(), zmq::rep_t::xrecv(), zmq::xrep_t::xsend(), zmq::xpub_t::xsend(), zmq::req_t::xsend(), and zmq::rep_t::xsend().
struct { ... } zmq::msg_t::lmsg |
Referenced by copy().
size_t zmq::msg_t::size |
Definition at line 126 of file msg.hpp.
Referenced by zmq::ctx_t::log(), zmq::req_session_t::write(), zmq::xpub_t::xread_activated(), zmq::xrep_t::xrecv(), zmq::req_t::xrecv(), zmq::rep_t::xrecv(), zmq::xsub_t::xsend(), zmq::xrep_t::xsend(), and zmq::xpub_t::xsend().
unsigned char zmq::msg_t::type |
union { ... } zmq::msg_t::u [private] |
unsigned char zmq::msg_t::unused[max_vsm_size+1] |
struct { ... } zmq::msg_t::vsm |